如何在Amazon DynamoDB导出到S3完成后才调用AWS Lambda函数

你当前使用的Lambda内置轮询方案虽然可以实现需求，但存在两个明显缺陷：

1. AWS Lambda最大运行时长仅为15分钟，若表数据量较大、导出时长超过15分钟，Lambda会被强制终止，流程直接中断
2. 导出全程Lambda处于运行状态，会产生不必要的成本，资源利用率极低

推荐使用以下两种事件驱动的无轮询方案，稳定性和成本表现都远优于轮询方案：

DynamoDB的点时间导出任务的所有状态变更都会自动推送到EventBridge默认事件总线，你可以通过配置规则直接捕获导出完成/失败事件触发目标Lambda，完全不需要自定义轮询逻辑。
配置步骤：

• 简化原有触发导出的Lambda：仅保留调用exportTableToPointInTime接口的逻辑，无需等待任务完成，调用后直接返回即可，单次运行时长不超过1秒，成本几乎可忽略
• 在EventBridge控制台创建自定义规则，事件匹配规则参考如下：

{
  "source": ["aws.dynamodb"],
  "detail-type": ["DynamoDB Export Table to Point In Time State Change"],
  "detail": {
    "TableArn": ["<你的DynamoDB表ARN>"],
    "ExportStatus": ["COMPLETED", "FAILED"]
  }
}

• 将规则的触发目标设置为你需要调用的第二个Lambda，EventBridge会自动把导出任务的完整信息（包括导出状态、S3存储路径、失败原因等）作为参数传递给目标Lambda

该方案全链路异步，不受导出时长限制，没有额外冗余成本，是当前场景的最优解。

如果你的后续逻辑不需要处理导出失败的情况，可以直接监听目标S3桶的对象创建事件实现触发：
DynamoDB导出成功后，会自动在目标S3路径下生成名为EXPORT_COMPLETED的标记文件，你只需给S3桶配置事件通知，当后缀为EXPORT_COMPLETED的对象被创建时，直接触发你的第二个Lambda即可。
该方案配置简单，缺点是无法捕获导出失败的事件，不支持异常处理逻辑。

如果你的导出后流程存在多步串行编排需求（比如导出完成后还要跑数据清洗、入仓等多步任务），可以使用AWS Step Functions托管轮询逻辑：
通过Step Functions内置的Wait状态和调用AWS API的能力实现定时查询导出状态，不需要Lambda长期运行，Wait状态几乎不产生费用，也不受Lambda运行时长限制。

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