如何实现Amazon SQS (FIFO)结合Lambda按顺序逐个处理消息

核心配置方法 #

• 所有发送到FIFO队列的消息指定同一个Message Group ID。SQS FIFO原生支持同一消息组内的消息严格按顺序交付，且当前消息未被成功删除（即处理完成）前，同组的下一条消息不会被暴露给消费者，从队列侧杜绝提前推送的可能。
• 调整Lambda SQS事件源映射配置：
  • 将批量大小（Batch size）设为1，确保Lambda每次仅拉取1条消息处理
  • 将最大并发度（Maximum concurrency）设为1，限制该触发源最多同时运行1个Lambda实例，彻底避免并行处理
• 合理配置超时参数：将SQS队列的可见性超时（Visibility Timeout）设置为大于Lambda函数的最大超时时间，避免消息还在处理时被队列判定为处理失败重新交付，打乱处理顺序。

注意：如果存在消息处理失败的场景，建议搭配死信队列（DLQ）使用，将处理失败的消息转移到死信队列，避免单条失败消息阻塞整个消息组的后续处理。

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