node.js – 在AWS Lambda中测试函数时,在完成请求错误之前退出流程

在完成用于创建缩略图的AWS Lambda教程之后,我决定尝试调整代码以检查文件是否是jpg或csv文件,以及是否只是将其移动到新存储桶.我从代码中删除的唯一内容是async.waterfall中的注释和函数,它们将调整图像大小.但是,每当我测试或运行这个新代码时,我都会在完成请求之前“退出进程”,并且该函数不会正确传输文件.这是代码：

var async = require('async');
var AWS = require('aws-sdk');
var gm = require('gm')
            .subClass({ imageMagick: true }); // Enable ImageMagick integration.
var util = require('util');






var s3 = new AWS.S3();

exports.handler = function(event, context) {

    console.log("Reading options from event:\n", util.inspect(event, {depth: 5}));
    var srcBucket = event.Records[0].s3.bucket.name;

    var srcKey    =
    decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, " "));  
    var dstBucket = 'datacollectionbucket';
    var dstKey    = srcKey;


    if (srcBucket == dstBucket) {
        console.error("Destination bucket must not match source bucket.");
        return;
    }


    var typeMatch = srcKey.match(/\.([^.]*)$/);
    if (!typeMatch) {
        console.error('unable to infer file type for key ' + srcKey);
        return;
    }
    var imageType = typeMatch[1];
    if (imageType != "jpg" && imageType != "csv") {
        console.log('skipping unrecognized file ' + srcKey);
        return;
    }


    async.waterfall([
        function download(next) {
            s3.getObject({
                    Bucket: srcBucket,
                    Key: srcKey
                },
                next);

        function upload(contentType, data, next) {

            s3.putObject({
                    Bucket: dstBucket,
                    Key: dstKey,
                    Body: data,
                    ContentType: contentType
                },
                next);
            }
        ], function (err) {
            if (err) {
                console.error(
                    'Unable to resize ' + srcBucket + '/' + srcKey +
                    ' and upload to ' + dstBucket + '/' + dstKey +
                    ' due to an error: ' + err
                );
            } else {
                console.log(
                    'Successfully classified ' + srcBucket + '/' + srcKey +
                    ' and uploaded to ' + dstBucket + '/' + dstKey
                );
            }

            context.done();
        }
    );
};

多谢你们

这意味着你在从函数返回之前没有调用context.done(),或者你的工作没有在lambda的超时内完成.

对于第一种可能性,在您的示例中有几个这样的代码块：

if (srcBucket == dstBucket) {
    console.error("Destination bucket must not match source bucket.");
    return;
}

那些都应该是这样的,相反：

if (srcBucket == dstBucket) {
    var errorText = "Destination bucket must not match source bucket."
    console.error(errorText);
    context.done(errorText);
    return;
}

如果将任何参数传递给context.done(),那么它们会假设第一个是错误. (如果没有错误,那么只需调用context.done(),就像在瀑布结束时一样).

因此,很可能会遇到其中一个错误案例,但您没有收到lambda中的错误.

另一种可能发生的方式是,如果S3 getObject和putObject调用的时间超过了lambda函数指定的超时值.你可以尝试在lambda函数设置的“config”选项卡中将其提升到最多60秒,看看你是否开始得到你的回复.