如何通过AWS原生方案实现Lambda按组顺序、跨组并行处理请求并返回结果？

针对你的需求，以下是AWS原生的标准合规实现方案：

方案1：Lambda + DynamoDB分布式锁 #

这是最直接的原生方案，核心通过DynamoDB实现分布式锁来控制同组请求的串行执行：

• 锁逻辑：创建一张DynamoDB表，用group字段作为主键，额外存储锁的过期时间、持有者标识等信息。
• 请求处理流程：
  1. 当请求到达时，Lambda尝试通过DynamoDB的ConditionExpression（如attribute_not_exists(group) OR expires_at < :now）原子性获取对应group的锁；
  2. 成功获取锁：处理请求，完成后删除锁或更新过期时间；
  3. 获取锁失败：进入轮询等待逻辑，每隔固定时间重试获取锁，直到锁释放或触发超时；
• 优势：完全基于AWS托管服务，无需额外依赖；不同group的请求天然并行，同一group严格串行；锁的过期机制可避免死锁。

方案2：Lambda + ElastiCache for Redis分布式锁 #

如果你的场景并发量较高，Redis锁的性能会更优：

• 锁逻辑：利用Redis的SETNX（SET if Not eXists）命令，以group为键设置带过期时间的锁；
• 请求处理流程：
  1. 请求到达时，Lambda调用Redis的SETNX尝试加锁；
  2. 加锁成功则处理请求，完成后删除锁；
  3. 加锁失败则轮询等待锁释放；
• 优势：Redis的锁操作延迟更低，适合高吞吐量场景；同样是AWS原生托管服务，运维成本低。

方案3：Lambda + Step Functions 工作流 #

通过Step Functions的执行流特性实现同组请求的串行：

• 核心逻辑：每个group对应一个Step Functions执行流，Step Functions会自动保证流内任务的串行执行；
• 请求处理流程：
  1. 前端请求进入API Gateway后，触发Lambda根据group生成唯一的执行流ID；
  2. 调用Step Functions的StartExecution API将请求加入对应执行流；
  3. Lambda作为执行流中的任务节点处理请求，处理完成后返回结果；
  4. 发起请求的Lambda可以轮询Step Functions的执行状态，直到完成后将结果同步返回给用户；
• 优势：无需自己实现锁逻辑，利用Step Functions的原生特性保证串行；执行流支持动态创建，适配未知的group数量。

关键注意事项 #

• 所有分布式锁必须设置合理的过期时间，防止Lambda执行异常导致锁永久占用；
• 轮询等待时要设置超时阈值，避免无限制阻塞；
• 同步返回场景下，Lambda的执行超时时间需要覆盖锁等待+请求处理的总时长。

内容的提问来源于stack exchange，提问作者Bronislav Klučka