获知所有并发运行的AWS Lambda均已执行结束的最佳方法是什么？

核心实现逻辑是引入统一的状态协调层追踪所有并行Lambda的执行进度，待全部执行完成后再触发时间采集和用户通知逻辑，尽量使用AWS托管服务降低自研和运维成本。

方案1：使用AWS Step Functions（最优选择，适配全量级场景） #

这是AWS官方推荐的并行任务编排方案，无需自行维护状态存储，自带重试、异常处理能力，可用性和可扩展性最高

• 替换原有S3直接触发业务Lambda的配置，改为S3触发Step Functions状态机启动
• 在状态机中使用分布式映射（Distributed Map）节点，配置并行调用业务Lambda的参数，最高支持上万级别的并行任务调度
• 配置分布式映射节点的执行完成后跳转逻辑，指向专门的收尾通知Lambda，该Lambda可以直接从Step Functions上下文中获取所有子Lambda全部执行完成的时间戳，再按业务需求推送给用户（支持邮件、站内信、接口回调等多种通知方式）
• 可根据业务需求自定义异常处理规则，比如部分Lambda执行失败时是否终止流程、是否重试等，无需额外开发代码

核心状态机配置参考示例：

{
  "Comment": "S3触发并行Lambda执行状态机",
  "StartAt": "并行调用业务Lambda",
  "States": {
    "并行调用业务Lambda": {
      "Type": "Map",
      "MaxConcurrency": 100, // 按需调整并行度
      "Iterator": {
        "StartAt": "执行业务逻辑",
        "States": {
          "执行业务逻辑": {
            "Type": "Task",
            "Resource": "arn:aws:states:::lambda:invoke",
            "Parameters": {
              "FunctionName": "替换为你的业务Lambda ARN",
              "Payload.$": "$"
            },
            "End": true
          }
        }
      },
      "Next": "收集完成时间并通知用户"
    },
    "收集完成时间并通知用户": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Parameters": {
        "FunctionName": "替换为你的通知Lambda ARN",
        "Payload": {
          "AllLambdaCompletedTime.$": "$$.State.EnteredTime" // 直接取当前节点进入时间即全部Lambda完成时间
        }
      },
      "End": true
    }
  }
}

方案2：DynamoDB原子计数器实现（适合并行Lambda数量<100的轻量场景） #

如果业务规模小不想引入Step Functions，可以用DynamoDB的原子计数能力自行实现状态追踪：

• 提前创建DynamoDB表，主键设置为S3触发事件的唯一标识（推荐用S3对象ETag + 事件ID组合），表字段包含：待执行Lambda总数量、已完成Lambda数量、任务启动时间、可选存储每个Lambda的单独结束时间
• S3触发每个业务Lambda时，先写入/更新对应任务ID的记录，Lambda执行完成后调用UpdateItem接口原子性将已完成数量+1
• 每次更新完成后判断已完成数量是否等于总数量，如果相等则触发通知逻辑，将当前时间作为所有Lambda的完成时间反馈给用户
• 建议配置DynamoDB TTL自动清理过期的任务记录，避免冗余存储占用

注意事项 #

• 不要采用Lambda递归调用、自行轮询的方式判断任务状态，会产生额外的计算成本，也容易触发Lambda超时限制
• 如果需要采集每个Lambda单独的结束时间，可以在业务Lambda执行完成后把自身结束时间写入DynamoDB，或者传入Step Functions的执行上下文，最后在收尾逻辑中统一汇总

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