FIFO SQS队列批处理机制咨询：Lambda消费时的消息顺序与批量逻辑

批量消息的组成规则 #

当你把Lambda批量大小设为10，且队列包含G1到G5共5个消息组时，Lambda不会直接从单个消息组拉取多条消息来填满批量。FIFO SQS的批量消费逻辑是：

• 优先从不同消息组各取一条消息组成批量，直到达到批量上限（10条）或队列中无可用消息。所以初始情况下，你会拿到5条消息（每组1条），而非从某个组拉取多条。
• 只有当其他消息组没有待处理消息时，Lambda才会从同一个消息组拉取多条消息填充剩余的批量名额。比如如果G2到G5都没有消息了，才会从G1里拉取多条，凑够10条的批量上限。

同组消息的顺序保障 #

假设G1的M1（先入队）和M2（后入队）被纳入同一批，绝对不会出现乱序处理的情况：

• FIFO SQS对同一个消息组有严格的顺序约束：同一个组的下一条消息，必须等上一条消息被成功处理并删除后，才会被确认消费状态。哪怕它们在同一批里，Lambda也必须按入队顺序处理M1和M2，只有M1处理完成并被删除，M2的处理结果才会被认可。
• 同时，Lambda收到的批量消息中，同一个消息组的消息本身就是按入队顺序排列的，不需要额外排序。

额外注意点 #

• 同一批中的消息可以来自多个消息组，不同组的消息之间可以并行处理，互不影响各自的顺序。
• 批量大小只是上限，实际拉取的消息数量取决于队列中可用消息的分布情况。

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