AWS：从 Lambda 向 SQS 队列发送消息时没有可用消息

Question

以下对我不起作用的一些可能原因是什么？

1. 创建一个至少包含一个 id 字段的 DynamoDB 表 card_auth_events。
2. 创建一个调用 lambda 的触发器。这是 lambda：

 console.log('Loading publishCardAuthEvent...');

 var QUEUE_URL = 'https://sqs.us-west2.amazonaws.com/XXXXXXXXXXXX/CardAuthEvents';
 var AWS = require('aws-sdk');
 var sqs = new AWS.SQS({region : 'us-west-2'});
 var http = require('https');

 exports.handler = function(event, context) {
 event.Records.forEach(function(record) {
      console.log(record.eventID);
      console.log(record.eventName);
      console.log('DynamoDB Record: %j', record.dynamodb);
      sendToQueue(record);
 });
 context.succeed("Successfully processed " + event.Records.length + " records.");
};

function sendToQueue(message){
//Send SQS message with details of file uploaded to S3.
var params = {
  MessageBody: JSON.stringify(event),
  QueueUrl: QUEUE_URL
};

sqs.sendMessage(params, function(err,data){
  if (err) {
    console.log('error:',"Fail Send Message" + err);
    context.done('error', "ERROR Put SQS");  // ERROR with message

    } else {
      console.log('data:',data.MessageId);
      context.done(null,'');  // SUCCESS
    }
  });
}

1. 将 Lambda 配置为具有 AmazonSQSFullAccess、AmazonDynamoDBFullAccess 和 AmazonAppStreamFullAccess 的角色。

2. 在 SQS 中创建队列

3. 在表中插入一条记录。

触发器被调用，但是为什么消息没有放入队列？？？

队列中没有消息，Cloud Watch 中也没有错误。有什么我遗漏的秘密吗？

Answer 1

我认为问题在于您正在调用 sendToQueue() 函数，然后调用 context.succeed() 而不等待生成的 SQS API 调用完成。这将在您的 Lambda 函数完成之前终止它。

一旦你克服了这个问题，另一个问题是你在 SQS 回调中调用了context.done()，但你可能会多次调用sendToQueue()。一旦第一个 SQS API 调用返回，您的 Lambda 函数就会终止。

Answer 2

问题在于您的访问策略。如果您正在使用 IAMFullAccess，您所做的就是授予您的 lambda 权限以访问和更改 IAM 策略、组、用户等。您需要授予您对 SQS 的 lambda 访问权限。如果你想全面测试 lambda，我建议使用托管策略：AWSLambdaFullAccess 和 AmazonSQSFullAccess。这将打开 S3、Lambda、DynamoDb、SQS 和 Cloudwatch。