我们有一个 SQS FIFO 队列,有大量积压的消息需要处理。我们引入了一些发送到此队列的新消息组,以帮助我们在这些事件的消费中引入更多并行化。我们已确认正在发送带有新组 ID 的消息。尽管如此,我们一次最多只能看到两条正在传输的消息(组 ID 的原始数量)。 SQS 是否需要处理现有 250k+ 积压的可用消息中的某些块,然后才能识别并开始使用新组 ID 发送消息?
发现它埋藏在 AWS 文档中:
FIFO 队列查看前 20k 消息以确定可用的消息组。这意味着,如果单个消息组中有积压的消息,则在成功消费积压中的消息之前,您无法使用稍后发送到队列的其他消息组中的消息。