pika 相关问题

Python-Pika是AMQP 0-9-1协议的纯Python实现，试图保持相当独立于底层网络支持库。 Python-Pika主要开发用于RabbitMQ，但也应该与其他AMQP 0-9-1经纪人一起使用。

我无法在RabbitMQ上使用MQTT协议

我想在RabbitMQ代理上使用MQTT协议，但是在尝试运行Producer时出现错误。这是我的代码。我只想测试先发送一些消息，然后导入pika ip ='192.168.43.101'user = ...

rabbitmq mqtt pika

回答 1 投票 0

Pika-RabbitMQ-为什么为消费者使用预取计数1时我的交付率大于确认率

我在Python中使用RabbitMQ实现PIKA时遇到问题。我想从队列中使用1条消息，对其进行处理，并在工作完成后对其进行确认。然后下一条消息应该是...

python rabbitmq pika

回答 1 投票 2

[aio-pika 2使用者不同时通过扇出接收消息

我是RabbitMQ和Pika的新手，但我认为我已经清楚地了解了它的工作原理。我需要实现：生产者创建消息并通过扇出交换发送，多个生产者（2 in ...

python rabbitmq pika

回答 1 投票 0

basic_get之后的pika确认消息

我有一个python代码，一次消耗RMQ的消息message_count = queue_state.method.message_count，如果不是queue_empty：message_cursor = 1而message_cursor＆...

python rabbitmq pika

回答 1 投票 0

无法远程访问RabbitMq服务器

我无法远程访问RabbitMq服务器。当我在一台机器上执行此操作并连接到localhost：15672时，它可以工作，但是当我从远程计算机上尝试时，它却没有。我已经创建了一个...

python linux rabbitmq ip pika

回答 1 投票 0

由于身份验证错误，无法从网络上的其他客户端访问RabbitMQ服务器

我已在Ubuntu . 上安装RabbitMQ，但无法从网络上的其他计算机连接到RabbitMQ服务器。从安装RabbitMQ的计算机仅从网络上的其他计算...

rabbitmq pika rabbitmqctl python-pika

回答 2 投票 1

使用pika.BlockingConnection，我想使用队列中的消息然后退出

我已经使用pika.BlockingConnection和channel.start_using（）编写了一个使用者，该使用者使用来自特定队列的消息，当消息从队列中耗尽时，使用者等待...

pika python-pika

回答 1 投票 0

如何使用pika 1.1.0添加超时？

我已经使用pika 0.12。*一段时间了，我习惯于使用以下代码添加超时。 connection = pika.BlockingConnection（）... connection.add_timeout（30，error）...现在我是...

rabbitmq pika

回答 1 投票 0

RabbitMQ未确认的消息未重新排队

我长期运行RabbitMQ使用者时遇到问题。我的几封邮件最终都处于未确认状态。我的RabbitMQ版本：3.6.15皮卡版本：0.11.0b import pika import time ...

python rabbitmq pika

回答 1 投票 0

RabbitMQ的使用线程时，鼠不采取一种以上的工作

我有ConnectionResetError的一个问题，当我阻止IOLoop是channel.start_consuming（）正在运行很长一段时间。所以，我读过这样的代码：HTTPS：//github.com/pika/pika/blob/0.12.0/examples / ...

rabbitmq pika python-pika

回答 1 投票 0

发送大邮件的RabbitMQ与鼠兔0.9.5：消息默默兔下降

我有一大堆的是把他们的结果，并将其张贴到RabbitMQ的消息队列芹菜任务。该贴得到的结果可能会变得非常大（可达几MEG）。意见是混合是否...

rabbitmq celery pika

回答 2 投票 1

有没有注册到的RabbitMQ的内存报警方式

我的应用刚刚冻结，因为RabbitMQ的内存使用量超过其阈值。我使用的鼠兔和pyrabbit作为一个Python包装的处理通道和连接。我徘徊，如果有...

rabbitmq pika

回答 1 投票 0

在一个线程异步鼠兔发行

我跟着从鼠异步出版商示例，并试图在单独的线程运行其self._connection.ioloop.start（）。到目前为止，我设法使用队列主线程将邮件添加...

python-3.x pika

回答 1 投票 2

RabbitMQ持久队列绑定

我正在尝试使用RabbitMQ主题交换从发布者可靠地向多个消费者发送消息。我已配置持久队列（每个消费者一个），我发送持久消息...

python rabbitmq pika

回答 1 投票 1

在多个线程中使用Pika通道

虽然很明显不跨多个线程使用单个PIKA连接，但我们是否可以使用跨多个线程的连接通道。这样做我得到了这个错误，答案是......

python rabbitmq pika

回答 2 投票 0

如何用pika和rabbitmq禁用心跳

我正在使用rabbitmq来帮助从我的兔子服务器到我各自的消费者的一些任务。我注意到，当我进行一些相当冗长的测试，20多分钟时，我的消费者将失去与...的联系。

python rabbitmq pika

回答 2 投票 0

保持pika BlockingConnection不会禁用心跳

我正在开发一个带有pika 0.10.0和python 2.7版本的RabbitMQ使用者。在我的消费者客户端中，我有一个根据输入消息运行一段时间的进程。它可以从3到40 ......

python-2.7 rabbitmq pika

回答 2 投票 2

Pika BlockingConnection和RabbitMQ：连接已关闭

我有2个rabbitmq在群集负载平衡Azure内部负载均衡器。客户端使用BlockingConnection连接到LB.当客户交换消息时，一切......

python azure rabbitmq pika

回答 1 投票 1

RabbitMQ Pika连接重置，（ - 1，ConnectionResetError（104，'通过peer重置连接'））

通过stackoverflow搜索并发布此问题，因为没有解决方案适用于我，我的问题可能与其他问题不同。我正在写一个脚本，从...获取一篇文章

python-3.x multithreading rabbitmq pika python-pika

回答 1 投票 1

RabbitMQ pika.exceptions.ConnectionClosed（-1，“error（104，'peer reset by peer'）”）

我在RabbitMQ中有一个任务队列，其中包含多个生产者（12）和一个用于Web应用程序中繁重任务的消费者。当我运行消费者时，它开始出现一些消息，然后崩溃...

python python-2.7 rabbitmq pika python-pika

回答 1 投票 1

pika 相关问题

最新问题