if (process.env.AWS_REGION !== event.Records[0].awsRegion) { throw new Error('Lambda and SQS queue must be in the same region.'); }
确认 Lambda 角色拥有正确的权限,如 SQS:ReceiveMessage 和 SQS:DeleteMessage。如果没有,请在 Lambda 控制台中更新权限。
请注意,在 Lambda 中使用 SQS 接收消息时,每条消息需要在规定的时间内处理并删除,否则它会重新出现在队列中并被其他消费者消费。以下代码展示了如何从队列中接收和删除消息:
const AWS = require('aws-sdk'); const sqs = new AWS.SQS(); const queueUrl = 'SQS_QUEUE_URL';
exports.handler = async (event) => { const params = { QueueUrl: queueUrl, MaxNumberOfMessages: 1, VisibilityTimeout: 30, WaitTimeSeconds: 0 };
const messages = await sqs.receiveMessage(params).promise();
if (!messages.Messages) { console.log('No messages to process'); return; }
// Process the message
const deleteParams = { QueueUrl: queueUrl, ReceiptHandle: messages.Messages[0].ReceiptHandle };
await sqs.deleteMessage(deleteParams).promise(); };