pika

7热度

1回答

我试图为python实现异步，分布式计算引擎，它与jupyter笔记本兼容。该系统应该基于“推送通知”方法，使得用户无法等待特定的计算结果（即，直到具有预期结果的消息被递送为止），使得它（几乎我希望）不可能等待特定的计算结果。准确地说，我想：添加新的任务jupyter笔记本事件循环（任务定期检查是否存在特定的味精已经抵达while循环，休息时味精到达）阻止当前单元格等待任务完成。依然能够处理

-2热度

1回答

尝试连接到远程RabbitMQ服务器时出现AccessDeniedError

我试图用两个主机连接RabbitMQ & python pika。这里是工人： #!/usr/bin/env python import pika, time NEW_TASK_HOST_IP = '192.168.0.2' credentials = pika.PlainCredentials('login-to-remote', 'pass') connection = pika.B

1热度

1回答

Python ActiveMQ：是否有可能使用pika客户端来处理ActiveMQ？

据我所知ActiveMQ支持amqp://协议，现在我想连接python中的ActiveMQ实例。是否可以使用pika包来获得它？当我读到pika的文件时，它似乎只是与RabbitMQ一起使用而设计的。否则，我应该使用哪种协议最适合于Python上的ActiveMQ？

1热度

1回答

保持鼠BlockingConnection活着没有禁用心跳

我正在开发一个RabbitMQ的消费与鼠兔0.10.0和Python 2.7 version.In我消费的客户，我有对依赖于输入消息的时间段运行的进程。它可以从3到40分钟不等。我不想禁用心跳。相反，我正在寻找一些可以保持连接活动的collback机制，直到delivery_tag被发回。那可能吗？很少联系我，一切都暗示禁用心跳的解决方法。但我不想禁用它。编号： Socket Error:

0热度

1回答

如何删除rabbitmq中的消息（pika）

如何删除发布和接收的消息，在rabbitmq 我正在用python测试rabitmq，同样的消息还在继续发布和接收，如何避免这种情况。我怎样才能删除公布并收到

0热度

1回答

socket.gaierror gaierror：[Errno -2]名称或服务未知 - pika rabbitMQ

我试图从托管在本地主机上的python服务器发送消息：5000到RabbitMQ服务器（使用Docker镜像的RabbitMQ），但我收到以下错误： socket.gaierror gaierror: [Errno -2] Name or service not known 我使用的，其中“rabbithost”是我使用的主机名命令运行的泊坞窗图像的RabbitMQ： sudo docker ru

0热度

1回答

pika.exceptions.ConnectionClosed：连接到172.18.0.3:5672失败：[Errno 111]连接被拒绝

我试图连接一个Pika客户端与RabbitMQ服务器。他们都在不同的码头图像上，他们在同一个码头网络上。设置我的网络 docker network create my_first_net 我运行的是RabbitMQ的图像rabbitmq作为 docker run -d --network my_first_net --hostname rabbitmqhost -p 35672:15672

1热度

1回答

Pika和gevent - 兼容性

是Pika兼容gevent？与gevent补丁标准套接字库提供的猴子补丁 - 这是足够的有效切换pika与gevent？此致敬礼，马特。

0热度

1回答

在皮卡实施了TTL吗？

我希望我的队列放弃在特定时间内未处理的邮件。我已经在消费者通过记录发布时间来做到这一点。但是，如果没有人正在订阅，则最好让队列简单地放弃陈旧的消息。我可以在Pika中的消息中设置到期时间（TTL）。 RabbitMQ文档讨论它，但我没有看到Pika文档中的TTL参考。

0热度

1回答

PostgreSQL的查询时间太长通过Python

#!/usr/bin/env python import pika def doQuery(conn, i) : cur = conn.cursor() cur.execute("SELECT * FROM table OFFSET %s LIMIT 100000", (i,)) return cur.fetchall() print "Using