目前，我正在使用 AWS PHP SDK 与 AWS SQS 进行通信。我正在使用 FIFO 队列。
我们有不同的“模型”需要与 SQS 进行通信，因此它们都有不同的消息组 ID，以使 SQS 更有效地处理数据。
我制作了一个方法，可以将调用分派到名为 DispatchSQSJob($arrayData, $messageGroupId = 'default') 的 AWS SQS
我目前正在遍历一组联系人，对于每个联系人，我使用联系人的数据和特定的 messageGroupId 调用 DispatchSQSJob，即：“联系人”
不幸的是，似乎当我的联系人数组的大小大于 1 时，SQS 只接收 1 个消息，而不是数组中的联系人数量。
如果有人知道为什么这可能是问题，我很想知道。谢谢
事实证明，我没有启用基于内容的重复数据删除和启用高吞吐量 FIFO。我的方法还发送了 MessageDeduplicationId。
启用这些选项并删除我发送的 MessageDeduplicationId 修复了它。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句