Rabbitmq 异步生产者脚本

Question

这里是RabbitMQ新手，希望你能帮我解决一个问题：

我有一个第三方程序，我想将它用作 RabbitMQ 的“生产者”。它会生成大量的日志消息，并且只能通过触发 shell 脚本将它们发送出去。

我可以使用 python 和 pika 编写一个 shell 脚本，但 AFAI 理解，这将为发送到 RabbitMQ 服务器的每条消息创建一个新连接。这似乎是个坏主意——我首先切换到 RabbitMQ 的原因是因为我之前的解决方案（wget 帖子）速度不够快，无法跟上日志的流出。

我确信有正确的方法可以做到这一点，但我想不通。每次我有日志要发送时，我都必须调用脚本——我不知道如何保持连接，或者我什至在思考正确的方向。

提前致谢。

Answer 1

您可以将同一连接用于多个操作。通常我们会重复使用它。

但是如果调用脚本来发送每条消息而不是 yupp，它每次都会创建（并关闭）新连接，这是巨大的开销。因此，一些建立连接并在本地端口上等待消息代理到rabbitmq的守护程序脚本可能会派上用场。

或者，也许某种 logstash-forwarder 可以解决您的问题？

另外，如果您刚接触RabbitMQ Python examples，还没有看到它，请仔细查看它。