node.js – AWS Lambda函数在context.fail之后继续一点

我有一个简单的AWS Lambda函数,可以对保存到S3存储桶的映像进行一些验证.我正在使用async.waterfall下载图像并对其进行处理,但在我输入第一个瀑布函数之前,我对从S3 PutObject触发器获取的事件数据进行了一些基本验证,特别是大小信息(事件) .Records [0] .s3.object.sizE).如果事件引用的图像大于我的MAX_SIZE,我使用COntext.fail(new Error(“验证错误：文件太大了.”))来结束执行.

这一切都运行正常,但我在日志中注意到,在记录错误后,该函数会在退出之前继续运行一段时间.例如,我的async.waterfall调用中的第一个函数被调用(即来自该函数的消息显示在日志中).我甚至尝试在context.fail之后立即添加一个context.done(errormessagE),然后执行它(即我传入的消息被记录)以及几行代码.

这是预期的行为吗？我在文档中找不到任何提及.该函数是否需要一点时间才能退出,或者我是否误解了async.waterfall之前的处理函数中代码的同步性？

下面是我的一些代码. context.fail之后显示的所有console.log消息都会打印到日志中,这是我不希望发生的.

exports.handler = function(event,context) {
  console.log('Received event:',JSON.Stringify(event,null,2));

  if (event.Records[0].s3.object.size > MAX_FILE_SIZE) {
    var error = new Error("Validation error: the file is too big.")
    context.fail(error);
  }
  console.log('Event validation complete.')

  var bucket = event.Records[0].s3.bucket.name;
  var key = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g,' '));
  var filename = key.split("/")[1];
  var params = {
    Bucket: bucket,Key: key
  };
  console.log('StarTing processing of the following file: ' + JSON.Stringify(params,2));

  async.waterfall([
    function download(callBACk) {
        // Download the image from S3 into a buffer.
        console.log("Downloading the image from S3...");
        s3.getObject(params,function(err,data) {
            if (err) {
                callBACk(err);
            } else {
                callBACk(null,data);
            }
        });
    },...
  ],...)
}