问题描述
我想在 python 中使用 pika 在 rabbitMQ 中一次发送大量消息(大约 500k)。一种方法是遍历所有消息并按顺序发送它们,但这会很慢。
有什么办法可以解决这个问题吗?
解决方法
默认情况下,AMQP 不提供任何批处理机制,因此您无法使用 pika 对消息进行批处理。
顺便说一句,您可以使用一些提示:
- 在客户端聚合消息,从而将更多消息集中在一个
- 您可以创建压缩消息,例如 zip/lzo 或某些可以在内存中压缩/解压缩的库。
注意:如果你想压缩消息,500k太高了,你应该把它们分开