使用SQS专用端点批量发送消息



我使用的是nodejs,需要使用sendMessageBatch函数向SQS队列发送批量消息。将消息推送到SQS的lambda在VPC内,所以我需要使用SQS的私有端点。任何人都可以帮助了解如何包含端点的语法吗。我可以使用以下示例进行推送:https://stackoverflow.com/a/60047048/7649369但是,这并不是使用私有端点。

const splitArray = require("split-array");
async function sendMessages(queueUrl, messages) {
const spilttedArray = splitArray(messages, 10);
for (const arr of spilttedArray) {
var params = {
QueueUrl: queueUrl,
Entries: []
};
for (const message of arr) {
params.Entries.push({
Id: uuid.v4(),
MessageBody: JSON.stringify(message)
});
}
await sqs.sendMessageBatch(params).promise();
}
}

你尝试过这个链接吗?您可以将端点作为参数传递给SQS客户端。

const sqs = new AWS.SQS({endpoint: 'https://my-vpc-url.com'}) // credentials also
// everything else
await sqs.sendMessageBatch(params).promise();

最新更新