如何处理卡住的RabbitMQ Dynamic Shovel消息

qfe3c7zg  于 2023-08-05  发布在  RabbitMQ
关注(0)|答案(2)|浏览(172)

我们目前使用RabbitMQ Dynamic Shovels将消息转发到Azure Event Hub。最近,我们设置了一个新的队列,以转发到事件中心。此队列中的某些消息的大小超过1MB,这是Event Hub上的消息限制。由于这个限制,消息每秒会反弹并再次发送几次。这会产生大量的网络流量,这可能是一个问题。
是否有任何方法可以将消息发送回DLX(死信交换)或其他队列?我们已经寻找了一些动态铲的选择,但找不到任何将是任何使用。

vmdwslir

vmdwslir1#

谢谢你Jesse Squire。将您的建议作为答案发布,以帮助其他社区成员。
一般来说,对于负载大于(或可能大于)允许大小的情况,我们建议考虑使用claim check pattern,将负载存储在其他持久性存储(如Blob存储)中,然后使用指向该资源的主体发布事件。
可以参考Dead-lettering dead-lettered messages in RabbitMQ
您也可以在GitHub上打开一个问题:rabbitmq-server

ippsafx7

ippsafx72#

我注意到文本“我们目前正在使用RabbitMQ Dynamic Shovels将消息转发到Azure Event Hub。最近,我们设置了一个新的队列,将其转发到Event Hub。
如何将RMQ迁移到Azure Event Hub?你怎么让它工作的
我只是创建RabbitMQ Shovel to Azure Event Hub or Service Bus
谨致问候

相关问题