小编Fab*_*cio的帖子

如何使用 SQS sendMessageBatch() 发送超过 10 条消息?

我在想那段代码他们正在将所有消息发送到我的 SQS 队列,但是当在我的数组上使用超过 10 个值时,我总是收到错误消息,表明已达到超出限制。

我无法增加我的 SQS,所以我必须将消息从 10 发送到 10。

任何人都对我需要从那个特定案例中获得的最佳方法提出建议?

module.exports.sendMessageBatch = function sendMessages(queueUrl, messages) {    
for (var i = 0; i < messages.length;) {
    var params = { 
        QueueUrl: queueUrl,
        Entries: [] 
    };
    for (var j = 0; j < 10 && i < messages.length; i++ , j++) {
        params.Entries.push({
            Id: uuid.v4(),
            MessageBody: JSON.stringify(messages[i])
        });
    }
    return sqs.sendMessageBatch(params).promise();
}
Run Code Online (Sandbox Code Playgroud)

amazon-sqs amazon-web-services node.js

2
推荐指数
1
解决办法
5961
查看次数

标签 统计

amazon-sqs ×1

amazon-web-services ×1

node.js ×1