如何重新连接到RabbitMQ？
当我的Python脚本接收到另一个数据源的消息后，必须不断向RabbitMQ发送消息。 Python脚本发送消息的频率可能会有所变化，比如1分钟到30分钟。 以下是我连接RabbitMQ的方法： rabt_conn = pika.BlockingConnection(pika.Connec...
队列中的不等价参数“durable”
我需要帮助。我有以下代码，并且日志告诉我我没有传递持久化参数，但是您可以看到我正在传递它。我尝试了一切，但总是出现相同的错误。 为了挂载此代码，我使用了这些链接： https://github.com/sk2/ANK-NG/blob/master/rabbitmq/rabbit_webso...
有没有办法通过pika在rabbitmq中列出队列？
我知道我们可以用这种方式来列出RabbitMQ中的队列。rabbitmqctl list_queues 但是我该如何通过pika来实现呢？
Python和RabbitMQ - 听取并消费多个频道事件的最佳方式是什么？
我有两个独立的RabbitMQ实例。 我正在尝试找到最佳方法来从这两个实例中监听事件。 例如，我可以使用以下方式消费其中一个实例的事件：credentials = pika.PlainCredentials(user, pass) connection = pika.BlockingConn...
RabbitMQ在处理长时间运行的任务时会关闭连接，而超时设置会产生错误。
我正在使用RabbitMQ生产者将运行时间长（30分钟以上）的任务发送给消费者。问题在于当连接关闭并未确认完成的任务重新排队时，消费者仍在处理任务。 经过调查，我了解到可以使用 心跳 或 增加连接超时 来解决这个问题。但是，在尝试这些方法时会引发错误。通过阅读类似帖子的答案，我还了解到自那些...
RabbitMQ、Pika和重新连接策略
我正在使用Pika从RabbitMQ处理数据。由于遇到了不同类型的问题，因此我决定编写一个小型的测试应用程序，以查看如何处理断开连接的情况。 我编写了以下测试应用程序: 连接代理，直到成功 连接成功后创建队列。 消费此队列并将结果放入Python Queue.Queue(0)中 从Que...
使用pika在python中实现SparkStreaming、RabbitMQ和MQTT
为了增加难度，我想从rabbitMQ队列中消费消息。现在我知道rabbit上有一个针对MQTT的插件（https://www.rabbitmq.com/mqtt.html）。 然而，我似乎无法使一个从pika发送过来的消息被Spark消费成功。 例如，我正在使用这里的简单wordcount...
在Pika或RabbitMQ中，我如何检查当前是否有任何消费者正在消费？
我想检查是否存在一个消费者/工作者来消费我即将发送的消息。 如果没有任何工作者，我将启动一些工作者（消费者和发布者都在单个机器上），然后开始发布消息。 如果有一个类似于 connection.check_if_has_consumers 的函数，我会实现它类似于这样 - import p...
没有找到与日志记录器“pika.adapters.blocking_connection”相匹配的处理程序。
类似的问题好像都是围绕着使用自定义日志记录器展开的，但我很乐意只使用默认/根本不使用。我的pika python应用程序运行并接收消息，但几秒钟后就会崩溃，并显示No handlers could be found for logger "pika.adapters.blocking_conn...
如何将pika连接到远程的rabbitMQ服务器？（使用python和pika）
在我的本地机器上，我可以有：connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) 为了建立适当的通信，(send.py和recv.py)这两个脚本都需要，但是如何从12.23.45.67到132...