如何将S3中的JSON文件通过AWS EventBridge传递至AWS Lambda？

方案1：Lambda主动读取S3参数文件 #

保持现有EventBridge定时触发逻辑，修改Lambda函数添加S3读取步骤：

• 配置方式：将S3桶名和参数文件路径通过Lambda环境变量配置（避免硬编码）
• 核心步骤：
  1. 在Lambda执行角色中添加S3 s3:GetObject权限
  2. 使用AWS SDK读取指定S3文件，解析JSON内容作为业务参数
• Python代码示例：

import boto3
import json
import os

s3_client = boto3.client('s3')

def lambda_handler(event, context):
    # 从环境变量获取S3配置
    bucket_name = os.getenv('PARAM_S3_BUCKET')
    file_key = os.getenv('PARAM_S3_KEY')
    
    # 读取并解析JSON参数文件
    try:
        response = s3_client.get_object(Bucket=bucket_name, Key=file_key)
        params = json.loads(response['Body'].read().decode('utf-8'))
    except Exception as e:
        raise RuntimeError(f"读取S3参数文件失败: {str(e)}")
    
    # 执行原有业务逻辑，传入动态参数
    process_business_logic(params)

方案2：用EventBridge Pipes串联定时触发与S3数据传递 #

通过EventBridge Pipes实现定时触发+自动拉取S3参数的能力，无需修改Lambda核心逻辑：

• 管道配置：
  1. 源：选择Schedule类型，设置每日定时规则（匹配原有触发频率）
  2. 中间步骤：添加Lambda Invocation或API调用步骤，拉取S3中的JSON文件内容
  3. 目标：指向你的业务Lambda函数，将拉取到的JSON内容作为事件传入
• 优势：将数据获取逻辑与业务逻辑解耦，Lambda只需处理业务参数

方案3：S3更新触发参数预加载，定时执行Lambda #

适合参数文件定期更新的场景：

• 第一步：配置S3事件通知，当参数JSON文件上传/更新时，发送事件到EventBridge事件总线
• 第二步：创建EventBridge规则，捕获S3更新事件后，将参数内容存入AWS Systems Manager Parameter Store或DynamoDB
• 第三步：保持原有定时触发Lambda的规则，Lambda从Parameter Store/DynamoDB读取预加载的参数执行逻辑
• 优势：避免Lambda每次执行都调用S3，提升性能，同时保证参数是最新版本

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