我什么时候应该使用DynamoDB触发器来调用另一个Lambda？

Question

我目前有一个AWS Lambda函数正在更新DynamoDB表，我需要另一个Lambda函数，该函数需要在数据更新后运行。在这种情况下，使用DynamoDB触发器而不是使用第一个Lambda调用第二个Lambda有什么好处吗？

看起来编程调用会让我更好地控制何时调用Lambda（即。我可以在调用之前等待几个更新发生），并且从DynamoDB Stream读取会花钱，而简单地调用Lambda不会。

那么，在这里使用触发器有什么好处吗？还是我自己调用Lambda会更好？

Answer 1

var QUEUE_URL = 'https://sqs.us-east-1.amazonaws.com/{AWS_ACCUOUNT_}/matsuoy-lambda';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'us-east-1'});

exports.handler = function(event, context) {
  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 
    }
  });
}

请不要忘记将另一个函数的触发器添加到此SQS主题中。该功能将接收自动处理的SQS消息。

Answer 2

数据更新后，您可以发布一条SQS消息，然后添加一个触发器来配置另一个函数，以便在Lambda控制台中从Amazon SQS读取数据，创建一个SQS触发器。

创建触发器

>

打开Lambda控制台功能页面。

选择一个函数。

在Designer下，选择Add trigger。

选择触发器类型。

配置所需选项，然后选择“添加”。

Lambda支持Amazon SQS事件源的以下选项。

事件源选项

• SQS队列–从中读取记录的Amazon SQS队列
• Batch size–每个批次中从队列中读取的项目数，最多10个。如果Lambda从队列中读取的批次具有更少的项目，则事件可能包含更少的项目
• Enabled–禁用事件源以停止处理项目

Answer 3

DynamoDB Stream似乎是更好的做法，因为：

• 您委托从Writer-Lambda调用后处理器函数的责任。使Writer更简单（又名更快），
• 您简化了将新的外部写入器连接到同一个Table，否则您必须实现逻辑来调用所有这些表中的后处理器，
• 您保证所有数据都经过后处理（即使有人在DynamoDB的Web界面中添加了新项目。：）
• 就金钱而言，您将花费在从编写器Lambda发送call oke（）操作上的执行时间可能会覆盖流的成本。
• 除非您使用DynamoDB事务，否则如果您过早地从Writer调用他，您的数据可能仍然无法用于后处理器。如果您的业务逻辑不需要事务，那么使用它们只是为了解决这个问题=额外的时间/成本。

P、 当然，您可以通过简单的设置从DynamoDB流中进行批处理。您没有义务为每个写操作调用后处理器。