Muh*_*ota 5 google-cloud-platform google-cloud-pubsub
我正在尝试一次发布多条消息(大约 50 条),但 Pub/Sub 给出的是Deadline Exceeded at /user_code/node_modules/@google-cloud/pubsub/node_modules/grpc/src/client.js:55
错误。
const pubsub = PubSub();
const topic = pubsub.topic('send_wishes');
const publisher = topic.publisher();
//data is dictionary object
Object.keys(data).forEach(function(key){
var userObj = data[key];
const dataBuffer = Buffer.from(JSON.stringify(userObj));
const publisher = topic.publisher();
publisher.publish(dataBuffer)
.then((results) => {
const messageId = results[0];
console.log(`Message ${messageId} published.`);
return;
});
})
Run Code Online (Sandbox Code Playgroud)
对于单个消息,它工作正常。对于批处理,我尝试了发布者的批处理配置,但它也不起作用
const publisher = topic.publisher({
batching: {
maxMessages: 15,
maxMilliseconds: 2000
}
});
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
3044 次 |
最近记录: |