我在NodeJs中编写了一个AWS lambda函数,它将id从数据库中拉出并将它们排队到AWS SQS队列.我有它工作正常,直到我部署一个函数来接收消息,现在原来的功能不起作用.这是相关代码:
async function sendHelper(rows)
{
let i;
let params;
let res;
let sqs = new AWS.SQS({apiVersion: '2012-11-05'});
for (i = 0; i < rows.length; i++) {
params = {
MessageBody: rows[i].ID.toString(),
QueueUrl: 'https://sqs.' + process.env.AWS_REGION_NAME + '.amazonaws.com/' + process.env.AWS_ID_SHORT + '/' + process.env.SQS_VENDPERSON_QUEUE_NAME
};
res = await sqs.sendMessage(params).promise().catch(err => errorHandler(err));
console.log(res);
}
return null;
}
Run Code Online (Sandbox Code Playgroud)
问题是它不会在任何地方抛出错误.无论你花多长时间,它都会在第一个sendMessage上超时.我已经删除了消息接收功能,问题仍然存在.一些可能有用的其他信息是我一直在使用无服务器进行部署.