S3.putObject 无法执行

Question

var aws = require('aws-sdk');
var s3 = new aws.S3({ apiVersion: '2006-03-01' });
var bucket = 'ashish-3245';
var acl = 'public-read';
var s3prefix = 'DeepSecurityEvents/';
var ext = '.json';

exports.handler = async(event, context) => {
    //console.log('Received event:', JSON.stringify(event, null, 2));
    const message = event.Records[0].Sns.Message;
    console.log("records", message);

    var timestamp = event.Records[0].Sns.Timestamp;
    var date = getFormattedDate(new Date(timestamp));
    console.log('from date', date);

    //add 5 random digits to prevent overwriting an existing file if two messages are received at the same ms.
    var random5digits = Math.floor(Math.random() * 90000) + 10000;
    //ie. DeepSecurityEvents/2016/07/20/2016-07-20T15:30:00.000Z12345.json
    var filename = s3prefix + date + '/' + timestamp + random5digits + ext;


    putObjectToS3(message, filename);
    console.log('From S3:', message);
    console.log(filename);

};

function getFormattedDate(d) {
    //returns yyyy/MM/dd
    return d.getFullYear() + '/' + twoDigits(d.getMonth() + 1) + '/' + twoDigits(d.getDate());
}

function twoDigits(n) {
    return n < 10 ? '0' + n : n;
}

function putObjectToS3(message, filename) {
    console.log('From async:', message);
    var params = { Bucket: bucket, Key: filename, ACL: acl, Body: message };
    s3.putObject(params, function(err, message) {
        console.log('p SNS:', message);
        if (err) console.log(err, err.stack);
        else console.log(message);
        context.done();
    });
}

输出

kkk

Response
null

Function Logs
START RequestId: 8d6f4394-9b87-49e5-bbec-ad88cf16813e Version: $LATEST
2021-11-21T11:22:16.379Z    8d6f4394-9b87-49e5-bbec-ad88cf16813e    INFO    records omly message
2021-11-21T11:22:16.380Z    8d6f4394-9b87-49e5-bbec-ad88cf16813e    INFO    from date 1970/01/01
2021-11-21T11:22:16.380Z    8d6f4394-9b87-49e5-bbec-ad88cf16813e    INFO    From async: omly message
2021-11-21T11:22:16.492Z    8d6f4394-9b87-49e5-bbec-ad88cf16813e    INFO    From S3: omly message
2021-11-21T11:22:16.505Z    8d6f4394-9b87-49e5-bbec-ad88cf16813e    INFO    DeepSecurityEvents/1970/01/01/1970-01-01T00:00:00.000Z99418.json
END RequestId: 8d6f4394-9b87-49e5-bbec-ad88cf16813e
REPORT RequestId: 8d6f4394-9b87-49e5-bbec-ad88cf16813e  Duration: 148.84 ms Billed Duration: 149 ms Memory Size: 400 MB Max Memory Used: 78 MB  Init Duration: 415.78 ms

Request ID
8d6f4394-9b87-49e5-bbec-ad88cf16813e

Answer 1

您正在使用async handler，因此您的函数在您的代码实际运行之前完成。您可以将代码包装在Promise 中，如docs 所示以解决此问题。

Answer 2

您的处理程序是异步的，因此为了让其他异步调用（例如：putObject）能够完成您：

1. 返回包装您的代码的承诺（请参阅@Marcin 的回答）
2. 使用async-await 模式。为此，您必须执行以下操作：

重构putObjectToS3 以返回promise：

function putObjectToS3(message, filename) {
    console.log('From async:', message);
    const params = { Bucket: bucket, Key: filename, ACL: acl, Body: message };
    try {
        return s3.putObject(params).promise();
    } catch(e) {
        console.err(e);
    }
}

在 Lambda 处理程序中，我们还必须调用 putObjectToS3 和 await：

const result = await putObjectToS3(message, filename);
console.log('p SNS:', result);