javascript - AWS Lambda 函数和 S3 - 仅当对象发生更改时才更改 S3 中对象的元数据

Question

我在 Lambda 中有一个函数，仅当对象发生更改时，该函数才应将元数据 header 添加到 s3 上的对象。

ContentType: 'application/javascript'
CacheControl: 'max-age=600'

但事实证明，Lambda 每秒检查存储桶大约 100 次，不仅是对象是否发生变化，而且成本很高。

访问S3日志:

b6234e2652b93344f7 aa [02/Mar/2016:11:00:55 +0000] 54.0.0.209 arn:aws:sts::718436:assumed-role/lambda_s3_exec_role/awslambda_642_201609 805 REST.COPY.OBJECT /local.js "PUT /local.js HTTP/1.1" 200 - 234 4404 50 24 "-" "aws-sdk-nodejs/2.2.32 linux/v0.10.36" -
b6234ee5f9cf0344f7 aa [02/Mar/2016:11:00:55 +0000] 54.0.0.209 arn:aws:sts::71836:assumed-role/lambda_s3_exec_role/awslambda_642_209 890005 REST.COPY.OBJECT_GET local.js - 200 - - 4404 - - - - -

功能:

console.log('Loading function');

var aws = require('aws-sdk');
var s3 = new aws.S3({ apiVersion: '2006-03-01' });

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

    // Get the object from the event and show its content type
    var bucket = event.Records[0].s3.bucket.name;
    var key =  decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, ' '));
    var params = {
        Bucket: bucket,
        Key: key,
        CopySource: encodeURIComponent(bucket+"/"+key),
        ContentType: 'application/javascript',
        CacheControl: 'max-age=600',
        "Metadata":{
        },
        MetadataDirective: 'REPLACE'
    };
    //s3.getObject(params, function(err, data) {
    s3.copyObject(params, function(err, data) {
        if (err) {
            console.log(err);
            var message = "Error getting object " + key + " from bucket " + bucket +
                ". Make sure they exist and your bucket is in the same region as this function.";
            console.log(message);
            context.fail(message);
        } else {
            console.log('CONTENT TYPE:', data.ContentType);
            context.succeed(data.ContentType);
        }
    });
};

我需要更改什么才能使该函数仅在 s3 中的对象发生更改时才起作用？

提前致谢!

Answer 1

你为自己创造了一个无限循环错误!当对象发生更改时，将触发 Lambda 函数，通过更改元数据并使用 copyObject，您可以更改对象，从而再次加载 Lambda 函数。您立即达到 100 个并发请求 Lambda 限制，该限制是为了确保您现在不必因为编写了无限循环而支付一百万欧元。

为了避免这种情况，您需要重新思考您的架构。有多种选择，但我认为最简单的是这个:

在您的 Lambda 代码中，首先执行 s3.getObject 并检查您要更改的 header 是否已存在。如果是这样，请关闭 Lambda 函数。这样，每次编辑只需执行 Lambda 函数两次。不是 100% 理想，但在我看来已经足够实用了。