我在想那段代码他们正在将所有消息发送到我的 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)