如何解决使用pika在rabbitMQ中批量发送消息
我想在 python 中使用 pika 在 rabbitMQ 中一次发送大量消息(大约 500k)。一种方法是遍历所有消息并按顺序发送它们,但这会很慢。
有什么办法可以解决这个问题吗?
解决方法
默认情况下,AMQP 不提供任何批处理机制,因此您无法使用 pika 对消息进行批处理。
顺便说一句,您可以使用一些提示:
- 在客户端聚合消息,从而将更多消息集中在一个
- 您可以创建压缩消息,例如 zip/lzo 或某些可以在内存中压缩/解压缩的库。
注意:如果你想压缩消息,500k太高了,你应该把它们分开
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。