pika 相关问题

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

对于队列,不等价的arg'持久'

我需要一些帮助。我在下面有这个代码,日志告诉我,我没有传递持久参数,但你可以看到我正在通过。我已经尝试过所有的东西,但总会有同样的错误。 ...

回答 1 投票 3

如何删除rabbitmq(pika)中的消息

如何删除发布和接收的消息,在rabbitmq我用python测试rabitmq,同样的消息继续发布和接收,如何避免这种情况。我该怎么删除...

回答 1 投票 0

Docker连接上的RabbitMq失败

我正在学习RabbitMQ的基础知识,将其安装在容器上。检查容器时似乎没问题。 PS C:\ Users \ jvidin> docker port rabbitmq 25672 / tcp - > 0.0.0.0:32776 4369 / tcp - > 0.0 ....

回答 1 投票 2

Pika - 处理RabbitMQ连接丢失

假设您创建了一个频道并开始在其中消费消息。 channel = get_channel()channel.queue_declare(queue = QUEUE_NAME,durable = True)channel.basic_qos(prefetch_count = 1)channel ....

回答 1 投票 0

队列最大长度或TTL使用get但不消耗

我看到许多帖子询问限制队列长度。在我对Pika和RabbitMQ的实验中,如果我使用arguments = {'x-message-ttl':1000,'x-max-length':2,'x-overflow':'drop-head'}声明队列。 ..

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.