回答情况：
提问时间：
问题标签：
我用的是python pika，fow和rabbitmq一起工作。/usr/bin/env python
connection = pika.BlockingConnection(pika.ConnectionParameters(host='192.168.10.150', port=5672, virtual_host='/', credentials=pika.credentials.Plain
浏览 1修改于2014-04-08得票数 1
我为巨蟒在mac上运行安装了pika。sudo pip install pika==0.9.8Requirement already satisfied (use --upgrade to upgrade): pika==0.9.8 in /usr/local/lib/python2.7/site-packages我把进口叫做这样
impor
浏览 6修改于2017-01-02得票数 5
回答已采纳
我已经成功地安装了RabbitMQ版本2.8.4，并且我正在使用Python2.7.3和pika 0.9.14。/usr/bin/env python我得到以下错误： File "/home/pi&#x
浏览 0提问于2015-04-30得票数 0
1回答
我正在尝试运行一些使用pika和tornado的python代码。我同时安装了这两个软件，但得到了错误 pika.log.setup(color=True)# Helper class PikaClient
# Set our pika.log optionspik
浏览 0修改于2013-09-18得票数 1
回答已采纳
我正在尝试使用pika与rabbitmq连接。def get_connection(): connection = pika.BlockingConnectionpika.PlainCredentials(MQ_USER, MQ_PASS)上发生了一些事情，即使错误出现在下一行。:
credentials = pika.PlainCredentials(MQ_USER, MQ
浏览 1修改于2020-02-14得票数 0
我有以下代码：import osfrom eventlet.green import threadingeventlet.monkey_patch()
eventlet.spawn(pika_client)socketio.run(app, host='19
浏览 4提问于2020-04-14得票数 0
1回答
我用RabbitMQ设置了amazonMQ，并尝试使用Pika连接和发布消息： credentials = pika.PlainCredentials(MQUSER, MQPW)amqs_str='amqps://'+MQUSER+':'+MQPW + '@'+MQURL+':'+str(MQPORT)+'/%2F'
parameters= pika.URLParameters(a
浏览 15提问于2020-11-22得票数 3
回答已采纳
Host pika Hostname <pika_hostname> User <username_2> ProxyJump pika
IdentityFile这是练习，因为我可以只做ssh <em
浏览 13修改于2021-08-09得票数 0
我有一个运行python script.The脚本的docker容器，提供了一个AMQP url，Pika使用它作为BlockingConnection.When的pika.URLParameters。username__ + ":" + __password__ + __virtual__host + sessionconnection = pika.BlockingConnection(pika.URLParameters
浏览 1提问于2018-05-16得票数 1
当尝试使用pika和rabbitmq从一台笔记本电脑向另一台笔记本电脑发送消息时，我收到此错误。有什么办法解决这个问题吗？WARNING:pika.adapters.base_connection:Could not connect due to "timeout," retrying in 2 sec File "C:\Python27\lib\site-pa
浏览 1修改于2014-02-16得票数 3
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) body=message,
properties=pika.BasicProperties(pika.
浏览 7提问于2016-05-19得票数 9
, line 28, in <module> File "/usr/local/lib/python2.7/dist-packages/pika_handle_read():
File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connec
浏览 2提问于2015-07-23得票数 0
回答已采纳
1回答
我本以为在aio_pika中阻塞，但是即使没有设置超时参数，我也会立即得到一个错误：
不管怎么说，要阻止进入aio_pika？
浏览 0修改于2018-06-07得票数 4
1回答
我有一段代码，它使用pika将消息排入代理的队列。 self._publish(msg)2021-03-14 12:25:09,981 MainThread-140100212655936pika.heartbeat [INFO] - Connection is idle, 1 stale byte intervals
2021-03-14 12:25
浏览 2修改于2021-03-27得票数 3
我在kubernetes集群中使用pika，并使用队列中的消息，这会在新线程中触发一个函数。indicated on fd=9, but writer callback is None; events=0b100 {/usr/local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py:520}
2020-12-23 10:39:31,416] INFO - Pika versio
浏览 577提问于2020-12-23得票数 2
回答已采纳
我在一个消费者中使用pika.BlockingConnection，它为每条消息执行一些任务。我还添加了信号处理，以便使用者在完全执行所有任务后正常死亡。import signalimport pikaall_over = Falsesignal.signal(signal.SIGINT, signal_handler)
mq_connectio
浏览 1修改于2014-04-30得票数 7
在我的本地机器中，我可以：对于这两个脚本(send.py
浏览 1提问于2015-01-07得票数 10
回答已采纳
拉出基础图像odoo:9并安装pika库运行pip安装pika
但不能继续，因为我得到了这个错误。顺便说一句，我在windows环境中使用。
浏览 5提问于2017-04-07得票数 0
回答已采纳
虽然不能跨越多个线程使用单个的PIKA连接，但我们可以使用多个线程之间连接的通道got吗？我得到了这样的错误，答案似乎是否定的。只是张贴以供参考
INFO 2019-02-07 13:14:12,927 pika.connection _on_terminate 2095: Disconnected from RabbitMQ
浏览 0提问于2019-02-11得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号