pika 相关问题

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

我使用 pika 使用这个简单的代码： conn = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) 通道 = conn.channel() def on_message(ch, 方法, 属性, 消息): 打印（“

python rabbitmq message-queue pika python-pika

回答 1 投票 0

Pika/RabbitMQ 如何从单个连接创建新通道？

我有一个使用 python pica 的方法。这里消费者需要为每个队列创建一个通道。当我编写这段代码时出现错误。在此输入图像描述 def 进程（通道、exc、que）：

pika

回答 1 投票 0

皮卡吃得停不下来

我无法从 Pika 返回数据，因为它的 start_consuming 没有停止。它打印结果但不返回输出 def on_request(ch, 方法, 道具, 正文): 目录=

python python-3.x pika

回答 2 投票 0

在Python中创建生产者和消费者应用程序

我正在尝试使用pika为rabbitmq在python中编写生产者和消费者代码。然而，对于我的具体情况，我需要在不同的主机上运行生产者，在其他主机上运行消费者。我已经

python rabbitmq pika

回答 3 投票 0

使用 Pika 的 RabbitMQ 队列中的“messages_ready”

我需要获取准备好的消息数量。队列具有三种类型的消息： 1. Total 2. Unack'd 3. Ready 就绪是那些在队列中但尚未被消耗的。当前...

python-requests rabbitmq pika

回答 1 投票 0

如何获取pika中请求是否获得basic_ack或basic_nack

例如我有一个消费者和一个生产者。在生产者中，我为消费者发布一些数据。在消费者中，我做了一些事情，我可以确认或拒绝请求。怎样才能在制作人那里找到...

python rabbitmq pika

回答 1 投票 0

pika 有没有办法获取特定 RabbitMQ 交换的所有路由密钥列表？

我有一些代码使用pika将routing_keys绑定到RabbitMQ交换： ROUTING_KEYS = [“a”，“b”，“c”] 参数= pika.ConnectionParameter（主机=什么，端口=

pika

回答 1 投票 0

RabbitMQ 发布消息时的延迟

我们正在开发一个项目，该项目使用rabbitMQ作为消息代理，并使用pika作为主干。我们使用在同一网络上的计算机上运行的发布者每 0.5 秒发布一条消息。一个合作...

rabbitmq delay message latency pika

回答 1 投票 0

如何使用 Pika 发布持久消息

我正在使用 Pika 与 Rabbit MQ 配合使用。我使用以下命令向经纪人发送消息： Channel.basic_publish('direct', 'samt_routing',json.dumps({'name':'reza','lastname':'rastgoo','id':i}))

python rabbitmq pika

回答 1 投票 0

皮卡示例 https://github.com/pika/pika/blob/main/examples/basic_consumer_threaded.py

我读过这个小组的一些帖子，但我不明白使用的意义是什么： https://github.com/pika/pika/blob/main/examples/basic_consumer_threaded.py 我的意思是，为什么我们需要额外的...

python rabbitmq pika

回答 1 投票 0

Pika Amqps 连接：连接尝试已完成，AMQPConnectorAMQPHandshakeError：不兼容协议错误

我正在尝试使用 pika 连接到 AMQPS 服务（我没有配置访问权限或获取证书的方法）。这是代码：进口鼠兔从 urllib.parse 导入 urlparse 导入SSL

python ssl amqp pika python-pika

回答 2 投票 0

RabbitMQ 传送确认超时解决方法：pika 或编辑 Amazon-MQ 托管集群的 RabbitMQ 配置文件

背景：RabbitMQ 3.8.x 的最新更改创建了 30 分钟的传送确认超时。根据文档，可以通过在rabbitmq.conf文件中设置

amazon-web-services rabbitmq pika rabbitmqctl amazon-mq

回答 1 投票 0

1 分钟内发送 100 万条消息到队列

我正在使用rabbitMQ接收消息。我有 1,000,000 条消息需要在 1 分钟内发送并排队。我正在使用 python 的多重处理。我的代码可以发送超过 5 分钟。有可能吗...

python multithreading rabbitmq python-multiprocessing pika

回答 1 投票 0

确保aio_pika消费者永远与FastAPI一起运行

我编写了一个 aio_pika 消费者任务，该任务应该在 FastAPI 应用程序中永远运行。此任务是实现发布/订阅模式的管理器对象的一部分：从 aio_pika 导入 connect_robust 来自

python python-asyncio fastapi pika python-pika

回答 1 投票 0

如何通过死信交换拒绝aio_pika中的消息？

我正在使用 aio_pika，并且在拒绝来自队列的消息时，rabbitMQ 订阅工作程序遇到了问题。我拒绝了队列中的消息并交换到死信队列。消息已到达死者...

python rabbitmq pika aio

回答 1 投票 0

程序运行 Pika 抛出 AMQPConnectionError

浏览此处的 Rabbit MQ Pika HelloWorld 教程： https://www.rabbitmq.com/tutorials/tutorial-one-python.html 问题是，每当我运行接收脚本时，我都会收到此错误...

python rabbitmq pika

回答 6 投票 0

Python - RabbitMQ Pika 消费者 - 如何使用异步函数作为回调

我有以下代码，我在其中初始化侦听队列的消费者。消费者=我的消费者() Consumer.declare_queue(queue_name="my-jobs") Consumer.declare_exchange(exchange_name=...

python rabbitmq pika

回答 2 投票 0

Pika，选择适配器和 gevent

有谁知道使用 SelectConnection 适配器将 pika 与 gevent 一起使用是否安全？看看代码，我不明白为什么不。据我所知，它只是调用 select.epoll() 我保证......

python gevent pika

回答 1 投票 0

通过 RabbitMQ 队列上的侦听器执行芹菜任务

我正在尝试为消息传递消费者运行脚本，该脚本会监听 rabbitMQ 实例并根据该消息值执行 celery 作业。我收到了循环依赖的问题......

python django rabbitmq celery pika

回答 1 投票 0

在 python 上使用 pika 修改和重新排队消息

我正在使用 Pika/RabbitMQ 库处理 python 3.8 项目中的消息。处理消息时，该功能可能由于多种原因而失败。在某些情况下，消息可以是

python python-3.x rabbitmq pika

回答 1 投票 0

pika 相关问题

最新问题