如何为VS2022创建的.NET 6 AWS Lambda函数添加S3Event触发器？

一、修改Lambda函数代码适配S3事件 #

• 先确认项目已引用Amazon.Lambda.S3Events NuGet包，未安装的话通过VS的NuGet包管理器添加。
• 修改核心处理方法的签名，将输入参数替换为S3Event类型，示例代码：

using Amazon.Lambda.Core;
using Amazon.Lambda.S3Events;

[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]

namespace YourLambdaNamespace;

public class Function
{
    public async Task FunctionHandler(S3Event s3Event, ILambdaContext context)
    {
        foreach (var record in s3Event.Records)
        {
            var bucketName = record.S3.Bucket.Name;
            var objectKey = record.S3.Object.Key;
            context.Logger.LogInformation($"触发S3事件：存储桶 {bucketName}，对象 {objectKey}");
            
            // 在此添加你的业务逻辑处理代码
        }
    }
}

• 注意：LambdaEntryPoint和LocalEntryPoint无需修改，它们仅负责不同环境的启动逻辑，核心业务逻辑集中在上述FunctionHandler中。

二、本地测试S3事件（可选） #

如果需要本地调试，可通过模拟S3事件进行测试：

• 在项目中创建模拟事件JSON文件（如s3-event.json），示例内容：

{
  "Records": [
    {
      "eventVersion": "2.1",
      "eventSource": "aws:s3",
      "awsRegion": "us-east-1",
      "eventTime": "2023-10-01T12:00:00.000Z",
      "eventName": "ObjectCreated:Put",
      "s3": {
        "bucket": {
          "name": "your-test-bucket"
        },
        "object": {
          "key": "test-file.txt"
        }
      }
    }
  ]
}

• 将VS启动项目设置为LocalEntryPoint，在调试配置中指定上述JSON文件路径，或直接在代码中构造S3Event对象进行测试。

三、在AWS控制台配置S3触发器 #

1. 通过VS的AWS工具链将Lambda函数部署到AWS。
2. 登录AWS控制台，进入Lambda服务找到目标函数。
3. 在函数页面的配置标签下选择触发器，点击添加触发器。
4. 触发器类型选择S3，完成以下配置：
   • 选择目标S3存储桶（需确保桶与Lambda函数同区域，或提前配置跨区域权限）。
   • 选择触发事件类型，比如所有对象创建事件或特定的Put/Copy等事件。
   • 可选：设置前缀/后缀过滤，仅处理特定路径或后缀的文件。
   • 勾选递归调用警告确认（若函数会修改桶内对象，需避免循环触发）。
5. 点击添加完成触发器配置。

四、配置IAM权限 #

确保Lambda执行角色拥有访问目标S3桶的权限：

1. 在Lambda函数配置标签下选择权限，点击执行角色进入IAM控制台。
2. 为该角色添加内联策略，示例策略如下（可根据业务需求调整操作和资源范围）：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "s3:GetObject",
        "s3:ListBucket"
      ],
      "Resource": [
        "arn:aws:s3:::your-bucket-name",
        "arn:aws:s3:::your-bucket-name/*"
      ]
    }
  ]
}

内容的提问来源于stack exchange，提问作者ZedZip