如何通过HTTP请求触发EventBridge实现Lambda指定时间运行

• 授权配置错误：如果路由绑定了IAM授权但请求未携带SigV4签名，会直接返回该错误。测试阶段可将路由授权类型设置为NONE，调通流程后再补充鉴权逻辑。
• CORS规则缺失：跨域发起fetch请求时，若未在API Gateway配置对应源的跨域允许规则，浏览器会拦截请求表现为Forbidden。配置时需将前端业务域名加入允许源列表，放行GET方法及业务需要的请求头。
• 路由/集成不匹配：请求的路径、方法和控制台配置的路由不一致，或路由绑定的Lambda目标不存在、缺少调用权限，也会触发该错误。

整体逻辑链路：客户端携带参数发起GET请求 → API Gateway将请求转发给调度创建Lambda → Lambda解析参数调用EventBridge创建定时规则 → 规则到点自动触发你编写的业务Lambda运行。

1. 准备Lambda函数 #

你需要准备两个Lambda函数，运行时可自行选择Python/Node.js等熟悉的环境：

• 业务Lambda：你已经编写完成、需要在指定时间运行的逻辑，提前记录该函数的ARN备用。
• 调度创建Lambda：负责接收API请求、解析参数、创建EventBridge定时规则，Python参考实现如下：

import boto3
import json
from datetime import datetime

events_client = boto3.client('events')
lambda_client = boto3.client('lambda')

# 替换为你的业务Lambda ARN
TARGET_LAMBDA_ARN = "arn:aws:lambda:<你的区域>:<你的账号ID>:function:<你的业务Lambda名称>"

def lambda_handler(event, context):
    # 解析GET请求的查询参数
    query_params = event.get('queryStringParameters', {})
    run_at = query_params.get('run_at')
    payload = query_params.get('payload', '{}')

    if not run_at:
        return {
            "statusCode": 400,
            "headers": {"Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"error": "必须传入run_at参数，格式为ISO标准时间字符串"})
        }

    # 转换时间为EventBridge支持的cron表达式，注意EventBridge默认使用UTC时区
    try:
        run_time = datetime.fromisoformat(run_at.replace('Z', '+00:00'))
        cron_expr = f"cron({run_time.minute} {run_time.hour} {run_time.day} {run_time.month} ? {run_time.year})"
    except Exception as e:
        return {
            "statusCode": 400,
            "headers": {"Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"error": f"时间格式解析失败: {str(e)}"})
        }

    # 生成唯一规则名避免重名
    rule_name = f"sched-task-{int(datetime.utcnow().timestamp())}"

    # 创建定时规则
    rule_resp = events_client.put_rule(
        Name=rule_name,
        ScheduleExpression=cron_expr,
        State="ENABLED",
        Description=f"一次性定时触发业务Lambda，创建于{datetime.utcnow().isoformat()}"
    )

    # 绑定规则目标为业务Lambda，传入自定义参数
    events_client.put_targets(
        Rule=rule_name,
        Targets=[{"Id": "1", "Arn": TARGET_LAMBDA_ARN, "Input": payload}]
    )

    # 给EventBridge授予调用业务Lambda的权限
    try:
        lambda_client.add_permission(
            FunctionName=TARGET_LAMBDA_ARN,
            StatementId=f"{rule_name}-invoke-perm",
            Action="lambda:InvokeFunction",
            Principal="events.amazonaws.com",
            SourceArn=rule_resp["RuleArn"]
        )
    except:
        # 重复添加权限会报错，直接忽略即可
        pass

    return {
        "statusCode": 200,
        "headers": {
            "Access-Control-Allow-Origin": "*", # 生产环境替换为实际前端域名
            "Access-Control-Allow-Methods": "GET"
        },
        "body": json.dumps({
            "msg": "定时任务创建成功",
            "rule_name": rule_name,
            "trigger_time": run_at
        })
    }

注意：给调度创建Lambda绑定执行角色时，需要添加events:PutRule、events:PutTargets、lambda:AddPermission三个权限，否则运行时会报权限不足。

2. 配置API Gateway HTTP API #

• 打开API Gateway控制台，选择创建HTTP API，集成类型选择Lambda，选中刚才创建的调度创建Lambda，自定义API名称后进入下一步。
• 配置路由：请求方法选择GET，路径设置为/create-schedule，集成目标绑定调度创建Lambda，授权类型选择NONE（测试阶段先关闭鉴权）。
• 配置CORS规则：将前端业务域名加入允许源列表，允许方法勾选GET，允许请求头填*，保存配置。
• 部署API到默认的$default阶段，部署完成后即可得到调用地址，格式类似https://<api-id>.execute-api.<区域>.amazonaws.com/create-schedule。
• 直接在浏览器访问该地址拼接测试参数，例如https://<api地址>/create-schedule?run_at=2024-12-01T10:00:00Z，如果返回任务创建成功的JSON，说明Forbidden问题已经解决。

3. 验证流程 #

将调度时间设置为当前时间往后2-3分钟，等待时间到达后查看业务Lambda的执行日志，确认参数正常接收、逻辑正常运行即可。

• EventBridge默认使用UTC时区，前端传参时需要做好时区转换，避免调度时间和预期不一致。
• 生产环境建议给API接口添加API Key或其他鉴权逻辑，避免被恶意调用产生不必要的费用。
• 如果是一次性定时任务，可以在业务Lambda逻辑末尾添加EventBridge删除对应规则的代码，避免控制台残留无用规则。

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