我正在AWS上运行“ Node.JS” lambda，它将消息发送到SQS。由于某些原因，SQS回调函数每两次调用仅执行一次。看起来，运行lambda的线程完成了运行（因为它不是对SQS的同步调用，也无法返回Future），因此lambda不会“保持活动状态”以使回调得以执行。
如何解决此问题并使lambda等待SQS回调执行？
这是我的lambda代码：
exports.handler = async (event, context) => {
// Set the region
AWS.config.update({region: 'us-east-1'});
// Create an SQS service object
var sqs = new AWS.SQS({apiVersion: '2012-11-05'});
const SQS_QUEUE_URL = process.env.SQS_QUEUE_URL;
var params = {
MessageGroupId: "cv",
MessageDeduplicationId: key,
MessageBody: "My Message",
QueueUrl: SQS_QUEUE_URL
};
console.log(`Sending notification via SQS: ${SQS_QUEUE_URL}.`);
sqs.sendMessage(params, function(err, data) { //<-- This function get called about one time every 4 lambda calls
if (err) {
console.log("Error", err);
context.done('error', "ERROR Put SQS");
} else {
console.log("Success", data.MessageId);
context.done(null,'');
}
});
};
您应该坚持基于回调的方法，或者承诺基于方法的方法。我建议您使用后者：
exports.handler = async (event, context) => {
// Set the region
AWS.config.update({region: 'us-east-1'});
// Create an SQS service object
var sqs = new AWS.SQS({apiVersion: '2012-11-05'});
const SQS_QUEUE_URL = process.env.SQS_QUEUE_URL;
var params = {
MessageGroupId: "cv",
MessageDeduplicationId: key,
MessageBody: "My Message",
QueueUrl: SQS_QUEUE_URL
};
console.log(`Sending notification via SQS: ${SQS_QUEUE_URL}.`);
try {
await sqs.sendMessage(params).promise(); // since your handler returns a promise, lambda will only resolve after sqs responded with either failure or success
} catch (err) {
// do something here
}
};
PS在lambda环境中实例化处理程序中的aws类不是一个好主意，因为它会增加冷启动时间。最好将new AWS.SQS(...)动作也移出处理程序AWS.config.update()，因为这些动作将在处理程序的每次调用时执行，但是您实际上只需要执行一次即可。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句