将文件从一个 s3 存储桶复制到另一个存储桶的最简单 lambda 函数

Question

我完全是一个不喜欢使用 AWS 的菜鸟。我试图让一个非常简单和基本的操作工作。我想要做的是，将文件上传到一个 s3 存储桶后，我希望该上传触发一个 Lambda 函数，该函数将该文件复制到另一个存储桶。

我转到 AWS 管理控制台，在 us-west2 服务器上创建了一个名为“test-bucket-3x1”的 s3 存储桶作为我的“源”存储桶，另一个称为“test-bucket-3x2”作为我的“目标”存储桶. 创建这些存储桶时，我没有更改或修改任何设置。

在 Lambda 控制台中，我为“test-bucket-3x1”创建了一个 s3 触发器，将“事件类型”更改为“ObjectCreatedByPut”，并且没有更改任何其他设置。

这是我的实际 lamda_function 代码：

import boto3
import json
s3 = boto3.resource('s3')


def lambda_handler(event, context):
    bucket = s3.Bucket('test-bucket-3x1')
    dest_bucket = s3.Bucket('test-bucket-3x2')
    print(bucket)
    print(dest_bucket)

    for obj in bucket.objects():
        dest_key = obj.key
        print(dest_key)
        s3.Object(dest_bucket.name, dest_key).copy_from(CopySource = {'Bucket': obj.bucket_name, 'Key': obj.key})

当我使用 AWS Lambda 控制台提供的基本“HelloWorld”测试测试此函数时，我收到了“

{
  "errorMessage": "'s3.Bucket.objectsCollectionManager' object is not callable",
  "errorType": "TypeError",
  "stackTrace": [
    [
      "/var/task/lambda_function.py",
      12,
      "lambda_handler",
      "for obj in bucket.objects():"
    ]
  ]
}

我需要对代码进行哪些更改才能在将文件上传到 test-bucket-3x1 时触发 lambda 函数并将文件复制到 test-bucket-3x2？

谢谢你的时间。

Answer 1

for object in source_bucket.objects.all():
    print(object)
    sourceObject = { 'Bucket' : 'bucketName', 'Key': object}
    destination_bucket.copy(sourceObject, object)