本地Docker运行AWS Lambda时，如何获取S3触发的Event数据？

问题核心 #

本地运行基于Docker的Lambda函数时，未模拟S3上传触发的Event数据，导致代码无法读取bucket名称和object key。

解决步骤 #

1. 准备S3触发事件模拟JSON #

AWS Lambda的S3触发事件有固定格式，创建本地JSON文件（如s3-event.json），内容如下：

{
  "Records": [
    {
      "s3": {
        "bucket": {
          "name": "你的测试桶名称"
        },
        "object": {
          "key": "测试上传的JSON文件名"
        }
      }
    }
  ]
}

替换上述示例中的桶名和文件名为你的实际测试值。

2. 本地运行Docker镜像时传入事件数据 #

借助AWS Lambda Runtime Interface Emulator（RIE）实现本地运行，将事件数据传递给函数：

方式一：使用docker run命令

官方基础镜像已内置RIE，直接运行镜像：

docker run -v "$PWD":/var/task -p 9000:8080 你的镜像名称:latest

在另一个终端发送POST请求传入事件：

curl -XPOST "http://localhost:9000/2015-03-31/functions/function/invocations" -d @s3-event.json

方式二：使用AWS SAM CLI（更简便）

若已安装SAM CLI，直接执行：

sam local invoke "你的Lambda函数名" -e s3-event.json

SAM会自动处理镜像运行与事件传递流程。

3. 代码容错优化（可选） #

为避免事件格式异常导致报错，给代码添加基础容错逻辑：

import json

def handler(event, context):
    try:
        bucket = event['Records'][0]['s3']['bucket']['name']
        key = event['Records'][0]['s3']['object']['key']
        print(f"Bucket: {bucket}, Object Key: {key}")
        return {
            'statusCode': 200,
            'body': json.dumps('TTS processing initiated.')
        }
    except KeyError as e:
        print(f"事件数据缺失关键字段: {e}")
        return {
            'statusCode': 400,
            'body': json.dumps('接收到无效的事件格式。')
        }

注意事项 #

• 若Lambda函数需实际访问S3，需确保本地环境配置了AWS凭证（如~/.aws/credentials文件），且凭证拥有对应S3桶的操作权限。

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