pika 相关问题

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

Pika: 如何从回调函数中获取返回值？

我的程序中有一个回调函数我需要检查successfailure. 我怎样才能做到这一点呢？在我下面的例子中，failail_code去了哪里？我的代码： def mq_callback(job_id, ch, method, ...)

rabbitmq pika

回答 1 投票 0

为Scrapy时间表创建新请求

通过皮卡，我从rabbitmq获取URL并尝试创建对Scrapy蜘蛛的新请求，当我通过刮y的爬行蜘蛛蜘蛛启动我的蜘蛛时，由于提高了DontCloseSpider（）而不会关闭，但不要创建...]] >

python scrapy rabbitmq pika

回答 1 投票 0

通过扩展名添加请求

我创建了自定义的scrapy扩展名，并将其添加到scrapy setting.py中。该扩展名必须通过pika从Rabbitmq中提取网址，然后发出请求scrapy spider的请求。 [

python scrapy rabbitmq twisted pika

回答 1 投票 0

pika与Qt的积分

最近，一个用户问如何在Qt上使用pika，但出乎意料的是，当我要发布答案时我删除了它，这使我有机会在自动应答器中向我提出这个问题……

python pyqt5 amqp pyside2 pika

回答 1 投票 0

RabbitMQ返回404，经纪人关闭

我有一个使用以下命令运行的RabbitMQ docker映像：docker pull rabbitmq sudo docker run -d -p 5672：5672 -p 15672：15672 --name Rabbitmq rabbitmq之后，我尝试运行一个...

python docker rabbitmq pika

回答 1 投票 0

RabbitMQ Pika和Django Channels websocket

我第一次使用Django Channels和RabbitMQ pika。我正在尝试从RabbitMQ队列中消费。我正在使用Django Channels AsyncConsumer将其分组发送给在...

django rabbitmq django-channels pika

回答 1 投票 1

来自消费者的Pika RabbitMQ发布

我有一个RabbitMQ消费者。我希望该使用者进行一些由time.sleep（10）模拟的消息处理，然后将消息发布到另一个队列。我知道使用者回调函数具有...

python python-3.x rabbitmq pika python-pika

回答 1 投票 0

Rabbitmq和Python NameError：全局名称问题

我正在尝试将JSON发送到Rabbitmq。这是我的生产者，并且可以正常运行：import pika import json certificate = pika.PlainCredentials（'admin'，'123'）parameters = pika.ConnectionParameters（'...

python rabbitmq pika

回答 1 投票 1

rabbitmq Pika连接经常断开连接

我有以下代码：import pika import os从eventlet.green导入threadlet pika = eventlet.import_patched（'pika'）eventlet.monkey_patch（）＃更多代码，如果__name __ =='...

flask rabbitmq flask-socketio pika eventlet

回答 2 投票 0

我如何停止在Java和Python客户端的RabbitMQ中消费？

我同时拥有使用channel.basicConsume（）的Java和Python客户端。在某些时候，我想停止那些消费者而不停止整个程序。在带有Pika的Python中，我已将...

java python rabbitmq pika

回答 2 投票 3

[aio-pika RPC模式示例崩溃，并带有：RobustConnection：连接已关闭

我正在尝试使用RPC模式的aio-pika运行RPC。我按原样运行了所有文档，只是更改了AMPQ URL，但出现一个错误：从未检索到任务异常quart_service_01_1 |未来：

python rabbitmq python-asyncio pika

回答 1 投票 0

使用rabbitmq和pika运行长任务

我正在使用pika执行长任务。不幸的是，这最终导致心跳超时。不幸的是，延长心跳周期不是解决方案，我想避免类似的解决方法，例如...

python rabbitmq pika

回答 1 投票 0

从Python发送XML文件到RabbitMQ时获取'位置参数'错误

[我正在尝试从python发送XML文件到RabbitMQ，但是出现以下错误错误文件“ ”，第3行channel.basic_publish（exchange =''，queue ='abc'，...

python-3.x dataframe rabbitmq pika python-pika

回答 1 投票 5

调用多个功能作为RABBITMQ消息

我刚开始一般使用RabbitMQ和Python。我一直在阅读Rabbit官方页面上的Tut，但是我不知道如何使用Rabbitmq做其他事情。我一直在尝试...

python function rabbitmq queue pika

回答 1 投票 0

[使用端口转发从一个泊坞站连接到另一个泊坞站，并且network = host失败

[我在python3.7.5中编写了一个连接RabbitMQ的应用程序：使用Ubuntu作为docker-machine，我在docker上运行Rabbitmq：docker run --name Rabbitmq -p 5671：5671 -p 5672：5672 -p 15672：15672 --...

python-3.x docker rabbitmq network-programming pika

回答 2 投票 0

[AttributeError：module'pika'在rabbitmq中没有属性'BlockingConnection'错误

最近我尝试使用pika库将队列作为rabitmq（rabbitmq_tutorials_partOne）的文档，我输入了以下代码：import pika connection = pika.BlockingConnection（pika ....

python python-3.x rabbitmq queue pika

回答 1 投票 2

pika rabbitmq python 3.6

我正在尝试使用pika与Rabbitmq def get_connection（）：凭据= pika.PlainCredentials（MQ_USER，MQ_PASS）connection = pika.BlockingConnection（pika.ConnectionParameters（...

python rabbitmq pika

回答 1 投票 0

connection_workflow.AMQPConnectorStackTimeout from BlockingConnection

pika BlockingConnection尝试失败（pika版本1.0.0）。应用程序日志中显示的异常-adapters.utils.connection_workflow.AMQPConnectorStackTimeout-似乎不是...

python pika python-pika

回答 1 投票 2

如何识别传递通知中的邮件？

在pika中，我已调用channel.confirm_delivery（on_confirm_delivery），以便在成功传递消息（或传递失败）时收到通知。然后，我将channel.basic_publish称为...

python rabbitmq pika

回答 1 投票 0

RabbitMQ Python Pika-多个消息的连接处理

我已经阅读了多个博客和有关正确设置RabbitMQ连接以进行发布的文档。以下是我的场景：执行一些任务并发布...的几个计划作业...