当我们使用节点 js 触发 lambda 时，如何从 s3 存储桶获取最近上传的 zip 文件

Question

我正在将 zip 文件上传到 s3 存储桶，一旦我上传了 zip 文件，我的 lambda 函数将被触发。

在 Lambda 函数块中，我需要获取最近上传的 zip 文件名 来自 S3 存储桶的 zip 文件的最后修改日期或来自 Lambda 的对象创建日期 记录事件

不过可能是这样，但我需要从 s3 存储桶中获取最近上传的 zip 文件名。**

这是我的代码

s3.listObjects(params, function (err, data) {
    if (err)
        console.log(err, err.stack); // an error occurred


    var lastZipfile = null;
    var lastModified = null;
    data.Contents.forEach(function (c) {
        if (c.Key.endsWith('tar.gz')) {
            if (lastModified === null) {
                lastZipfile = c.Key;
                lastModified = c.LastModified;
            } else {
                // Compare the last modified dates
                if (lastModified <= c.LastModified) {
                    // Track the new latest file
                    lastZipfile = c.Key;
                    lastModified = c.LastModified;
                    //extractData(lastZipfile);
                }
            }
        }

    });
});

Answer 1

我将向您展示解决此问题的两个选项。

1º 选项（自动）：

我看到的最好的选择是让 lambda 函数准备好自动运行 每次将文件放入存储桶 S3 时。当 lambda 函数被调用时，带有来自创建文件的信息的事件将被发送到 lambda 函数。

下面是一个如何触发的例子：

下一个：

下面是一个例子：

exports.handler = (event, context, callback) => {

  var lastCreatedFile = event.Records[0].s3.object.key;
  //extractData(lastCreatedFile);

};

2º 选项（手动）：

但是，您可以在想要获取有关新文件的信息时手动调用 lambda 函数。 使用您的代码，您将始终获得最后修改/创建的文件。

我已经调整了你提交的 lambda 函数：

s3.listObjects(params, function (err, data) {
if (err)
    console.log(err, err.stack); // an error occurred

var sortArray;

data.Contents.sort(function(a,b) {
    return (b.LastModified > a.LastModified) ? 1 :
    ((a.LastModified > b.LastModified) ? -1 : 0);
});

for(var file of data.Contents){
    if (file.Key.endsWith('tar.gz')) {
        //extractData(file.Key);
        break;
    }
}

但是我们可能会遇到这样的问题，如果没有创建新文件，就会碰巧多次提取同一个文件。我建议稍后使用文件删除或寻找其他方式来识别该文件已被使用。

希望对你有所帮助！