pika 相关问题

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

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 RabbitMQ，消费者在长时间空闲时会默默地断开队列？

在我的公司，我们目前正面临使用 rabbitMQ 的奇怪行为。我们托管在 Kubernetes 集群中的微服务之一是用 Python 构建的（其他的是用 Java 构建的，它们没有显示这个问题......

rabbitmq pika messagebroker

回答 0 投票 0

如何在python中使用RabbitMQ进行简单的单元测试？

在我的单元测试中，我想简单地开始消耗，发布一个消息，并收到一个响应回来，并断言如果响应是我所期望的。然而，我已经尝试做了几个小时......。

rabbitmq pika

回答 1 投票 0

龙卷风上的皮卡消费者跑不动了

我想使用RabbitMQ和Tornado建立监控系统。我可以运行生产者，我的消费者可以消费队列中的数据，但数据不能显示在网站上。这只是我之前的实验...

python-2.7 rabbitmq tornado producer-consumer pika

回答 1 投票 0

是让RabbitMQ的连接保持开放还是只在必要时才开放？

我有一个应用程序，它循环进行一系列的测试。在失败的测试中，它将消息发布到 RabbitMQ 队列中，其他应用程序将监视并从中获取。有数百个测试...

python rabbitmq pika

回答 1 投票 0

我可以使用aws角色认证rabbitmq连接吗？

我在AWS EC2上托管了一个rabbitmq集群。我的远程应用程序是否可以使用AWS IAM角色或任何其他方式使用AWS服务来验证连接到rabbitmq服务器？...

amazon-web-services rabbitmq amazon-iam pika

回答 1 投票 0

rabbitmq一个队列中的多个消费者--只有一个人得到消息。

我实现了多个消费者，他们从一个队列中获取消息，我使用类似于这个例子的东西来做这件事，除了我在一个无限循环上做basic.get ...

python rabbitmq amqp pika

回答 1 投票 8

pika 相关问题

最新问题