如何通过AWS Lambda/Step Functions实现长时延外部资源异步处理流水线

你描述的长时延异步处理流水线完全可以实现，以下是两种成熟的落地方案：

方案1：纯Lambda事件驱动实现 #

• 第一个Lambda仅负责完成两个操作：调用外部长时延接口、将本次请求的唯一标识（如请求ID、校验参数）持久化存入DynamoDB，完成后直接终止运行，无需等待接口响应。
• 提前部署API Gateway绑定第二个结果处理Lambda，将API Gateway的端点地址提供给外部资源作为回调地址。外部资源处理完成后会主动推送结果到该端点，触发第二个Lambda执行结果处理逻辑，执行前可先查询DynamoDB校验请求合法性。
• 若外部资源不支持主动回调，可增加SQS队列+EventBridge定时规则实现轮询：第一个Lambda发起请求后将请求信息写入SQS，设置消息可见性时间匹配外部资源最大处理时延，通过EventBridge定时触发轮询Lambda拉取SQS消息查询请求状态，处理完成则触发结果处理Lambda，未完成则将消息放回SQS等待下次轮询。

方案2：Step Functions实现（更推荐，无需自行维护状态逻辑） #

直接使用Step Functions的内置能力实现全流程管控，支持最长1年的执行时长，完全覆盖你的时延需求：

• 回调模式（外部资源支持回调时使用）：
  1. 状态机第一个Task调用请求发起Lambda，该Lambda执行完外部请求调用后，将Step Functions生成的任务令牌（Task Token）与请求标识绑定存入持久化存储，随后直接返回，状态机进入等待状态。
  2. 外部资源处理完成后回调预设接口，对应的处理Lambda拿到请求标识后取出对应的任务令牌，调用SendTaskSuccess接口将结果回传给状态机，状态机自动跳转至下一个Task，调用结果处理Lambda完成后续逻辑。
• 轮询模式（外部资源不支持回调时使用）：
  在状态机中配置等待状态+轮询Task，按业务需求设置等待间隔，到点自动触发轮询Lambda查询外部请求状态，状态未完成则回到等待状态，状态完成则进入结果处理步骤。

之前问题的原因说明 #

你之前运行的官方Node.js Lambda handler示例为同步执行逻辑，默认会等待handler内所有代码执行完成才返回。如果要实现发起请求即终止的效果，Node.js环境下可在发起HTTP请求后不等待请求resolve，直接调用callback返回即可，不需要await请求的响应结果。

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