AWS SQS 仅从两个不同的调度接收 1 条消息

AWS SQS only receiving 1 message from two different dispatch

目前,我正在使用 AWS PHP SDK 与 AWS SQS 通信。我正在使用 FIFO 队列。

我们有不同的“模型”需要与SQS通信,因此它们都有不同的消息组ID,以使SQS更有效地处理数据。

我创建了一个方法来调用 AWS SQS,名为 DispatchSQSJob($arrayData, $messageGroupId = 'default')

我目前正在遍历一组联系人,对于每个联系人,我使用联系人的数据和特定的 messageGroupId 调用 DispatchSQSJob,IE:“contact”

不幸的是,当我的联系人数组的大小大于 1 时,SQS 只收到了 1 条消息,而不是数组中的联系人数量。

如果有人知道这可能是问题的原因,我很想知道。谢谢

事实证明,我没有基于内容的重复数据删除和启用高吞吐量 FIFO 启用。我的方法还发送了 MessageDeduplicationId。

启用这些选项并删除我发送的 MessageDeduplicationId 修复它。