AWS SQS MessageGroupId能否保证同组消息由同一Lambda串行处理

相同orderId（即相同MessageGroupId）的消息被并行处理，核心原因是Lambda的SQS FIFO事件源映射默认未开启组级顺序保障。默认配置下Lambda会并发拉取多组消息调度，同一消息组的新消息在老消息未处理完成时，可能被分配到新的Lambda实例执行，直接破坏FIFO队列的组内顺序语义。

完成以下配置即可从平台层面保证同一orderId任意时间只有1个Lambda实例处理，不同orderId仍可并行调度，不损失集群扩展性：

• 进入Lambda控制台，找到绑定SQS FIFO队列的事件源映射，打开Additional settings下的FIFO消息配置，勾选按顺序处理同一消息组的消息。对应API/CDK配置项为MaximumConcurrencyPerMessageGroup = 1，该参数会强制每个MessageGroupId的并发度上限为1，从调度层阻断同组消息并行的可能。
• 同步开启批量项失败报告（ReportBatchItemFailures），处理逻辑中仅返回处理失败的消息ID，不要使用默认的整批成功/失败判定。避免单条消息失败导致整批消息回退重试、打乱处理顺序。

效果1：同orderId严格串行逐条处理 #

完成核心配置后调整以下参数：

• 将事件源的Batch size设置为1
• 将Batch window设置为0秒

配置后行为：Lambda每次仅从单个orderId的消息组拉取1条消息投递，等该条消息处理完成、返回成功响应后，才会拉取该组下一条消息，完全符合入队顺序串行处理的要求。

效果2：同orderId消息批量投递到单实例 #

完成核心配置后调整以下参数：

• 根据业务单批处理能力设置Batch size，SQS FIFO触发Lambda的单批上限为10条
• 根据业务可接受的消息延迟设置Batch window，最大支持5分钟：Lambda会在窗口时间内积攒同组消息，攒满batch size或窗口超时后，将同组积攒的所有消息作为一个批次投递给同一个Lambda实例处理

注意：开启单组并发为1的配置后，单批次内的消息全部属于同一个orderId，不会混入其他订单的消息，无需额外做消息分组过滤。

• 事件源映射的总并发预留值不要低于峰值时段同时活跃的orderId数量，否则会出现不同orderId抢占并发配额的情况，影响整体吞吐
• SQS队列的可见性超时建议设置为Lambda函数超时时间的6倍，作为兜底配置避免异常场景下消息被重复投递
• 消息处理逻辑不要在Lambda返回前启动未同步等待的异步任务，确保函数返回时对应消息的业务逻辑已经执行完成，避免业务层面的顺序错乱

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