正确处理上下文。succeed（）/上下文。AWS Lambda中AWS S3服务调用失败（）

Question

我已经在这里搜索过帖子（例如，如果所有调用都是异步的，那么如何在lambda中构建连续的AWS服务调用？）在其他地方，似乎找不到一点信息来帮助我克服这个恼人的问题。当有一个Lambda函数在循环中迭代时，在该循环中调用s3。putObject（），它在尝试正确处理上下文时遇到短路问题。succeed（）/上下文。fail（）或旧上下文。结束Lambda进程的方式。

一、 迭代需要调用s3。putObject（）包含要上载的当前对象，但仍将成功上载的文件输出到cloudwatch或可能的SQS/SNS。然而，我将这种类型的闭包放入函数的所有尝试都会遇到随机结果，有时会得到文件名，有时只得到一些文件名，等等。

最好的方法是什么？我曾尝试使用Q和async，但老实说，我仍在学习所有这些东西。。

下面是我尝试做的一个粗略示例：

function output(s3Object){
     s3.putObject(s3Object, function(err, data){
          if (err) {
               console.log('There was an issue with outputting the object.', err);
          } else {
             // how do you properly close this if you have x number of incoming calls??
          // context.done(null, 'success');
}


// and later in the code where it actually calls the output function
// and NOTE: it should output all of the file names that the invocation uploads!
for (var a = 0; a < myRecords.length; a++){
     output(myRecords[a]);
}

但是，正如我之前所说的，到目前为止，我所做的任何尝试都会产生不同的结果。

Successfully output object: myBucket/prefix/part_000000123432345.dat
Successfully output object: myBucket/prefix/part_000000123432346.dat

但是对函数输出的另一个测试：

Successfully output object: myBucket/prefix/part_000000123432346.dat

啊。

Answer 1

我将给出一个使用Async的简单示例，然后您可以对其进行调整：

var async = require('async');

var sleep = function(message, callback) {
    setTimeout(function() {
        callback(null, "Echo: " + message);
    }, Math.floor(Math.random() * 2000));
};

exports.handler = function(event, context) {
    async.map(['a', 'b', 'c', 'd', 'e'], sleep, context.done);
};

在这里，我定义了一个函数，该函数接受消息和回调，然后在0到2秒之间随机Hibernate一段时间，然后将消息回显到回调。

然后我们使用异步。map（）对5条不同的消息异步调用sleep（）函数。根据文档，此函数的回调，在本例中为上下文。所有迭代器函数完成后，将调用done。在Lambda控制台中运行此命令，您肯定会得到：

[
  "Echo: a",
  "Echo: b",
  "Echo: c",
  "Echo: d",
  "Echo: e"
]

因此，您的代码可能非常简单：

async.map(myRecords, s3.putObject, context.done);

但由于我无法测试这一点，我将把这部分留给你。