/** * Dependencies: * Dotenv, Express, BodyParser, Slack Web Client, Slack Events API */ require('dotenv').config(); const express = require('express'); const bodyParser = require('body-parser'); const createSlackEventAdapter = require('@slack/events-api').createSlackEventAdapter; //a new export, ErrorCode, is a dictionary of known error types const { WebClient } = require('@slack/client'); const twilio = require('twilio'); const firebase = require('firebase'); // Creates our express app const app = express(); // The channel we'll send TalkBot messages to const channel = 'CBY5883L3'; // The port we'll be using for our Express server const PORT = 3000; // Use BodyParser for app app.use(bodyParser.urlencoded({extended: true})); app.use(bodyParser.json()); /** * Tokens: * Slack, Firebase, Twilio */ //Retrieve bot token from dotenv file const bot_token = process.env.SLACK_BOT_TOKEN || ''; // Authorization token const auth_token = process.env.SLACK_AUTH_TOKEN || ''; // Verification token for Events Adapter const slackEvents = createSlackEventAdapter(process.env.SLACK_VERIFICATION_TOKEN); //Slack web client const web = new WebClient(auth_token); const bot = new WebClient(bot_token); //Twilio tokens const twilio_sid = process.env.TWILIO_SID || ''; const twilio_auth = process.env.TWILIO_AUTH_TOKEN || ''; // Initialize Twilio client using our Twilio SID and Authorization token const twilioClient = twilio(twilio_sid, twilio_auth); app.listen(PORT, function (err) { if (err) { throw err } console.log('Server started on port 3000') }) // Handles incoming SMS to Twilio number app.post('/sms', function (req, res) { const body = req.body.Body const num = req.body.From // Sends message to Slack - in format from { // `res` contains information about the posted message console.log('Message sent: ', res.ts); }) .catch(console.error); }
您会得到此错误
错误-11200 HTTP检索失败
因为Twilio在将POST请求发送到/sms
endpoint时希望得到响应。
// Handles incoming SMS to Twilio number
app.post('/sms', function (req, res) {
const body = req.body.Body
const num = req.body.From
// Sends message to Slack - in format from {
// `res` contains information about the posted message
console.log('Message sent: ', res.ts);
})
.catch(console.error);
}
// Handles incoming SMS to Twilio number
app.post('/sms', function (req, res) {
const body = req.body.Body
const num = req.body.From
// Sends message to Slack - in format from {
// `res` contains information about the posted message
const twiml = new twilio.twiml.MessagingResponse();
twiml.message('Your SMS was forwarded to Slack...');
res.writeHead(200, { 'Content-Type': 'text/xml' });
res.end(twiml.toString());
});
我用的是Kafka0.8.2。正如文件所说: batch.num.messages指定: 使用异步模式时要在一批中发送的消息数。生产者将等待该数量的消息准备好发送或排队。缓冲器已达到最大毫秒。 和请求。必修的。acks控制代理对请求的确认。 我想知道Kafka经纪人如何发送这个确认,它是否发送批次确认字符,还是每个单独的消息?
我在discord.py做了一个机器人,希望我的机器人在网络钩子在特定频道发送消息时定位一个角色。有办法这么做吗?现在所有我有的是通道ID和我很确定这是一个客户端事件
我正在使用spring data redis运行Spring Boot服务,下面是以下配置。 该服务似乎可以工作,但我在日志中看到了一条丢失哨兵消息流。哨兵节点可从运行服务的VM中访问。我能够直接从那个虚拟机对他们进行telnet。知道为什么会这样吗?
这是在使用Firebase消息传递推送通知时显示的错误... 这是Firebase消息的js代码 这个日志是打印出来的。。。 这是颤振代码 获得ios权限,但我正在使用android手机进行调试 onCreateActivityFeedItem活动源项已创建{commentData:'ab to man ja',mediaUrl:'https://firebasestorage.googleapi
在本地主机上运行时收到错误消息。下面是我得到的味精。我还添加了db连接代码。
物联网有很多设备,通过这条指令可以向某个特定的物联网设备发送特定的消息内容。 请求方式: "|4|1|3|topic|message|" 参数: topic 设置订阅的topic,获取设备topic可参考教程 message 发布消息的内容 返回值: "|4|1|3|1|\r" 消息发送成功 "|4|1|3|2|\r" 消息发送失败 Arduino样例: softSerial.print("|4|