【发布时间】:2019-04-17 00:09:44
【问题描述】:
通过此处找到的 Rabbit MQ Pika HelloWorld 教程: https://www.rabbitmq.com/tutorials/tutorial-one-python.html
问题是,每当我运行接收脚本时,我都会收到此错误:
Traceback (most recent call last):
File "receive.py", line 5, in <module>
pika.ConnectionParameters(host='localhost'))
File "C:\Users\Colin Warn\PycharmProjects\untitled2\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 360, in __init__
self._impl = self._create_connection(parameters, _impl_class)
File "C:\Users\Colin Warn\PycharmProjects\untitled2\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 451, in _create_connection
raise self._reap_last_connection_workflow_error(error)
pika.exceptions.AMQPConnectionError
这是我尝试运行的代码:
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(
queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
非常感谢任何帮助。非常感谢您。
【问题讨论】:
-
你的机器上运行的是rabbit服务器吗?
-
不确定如何检查。我还重新创建了我认为会创建一个的 send.py 脚本,但它只是向我发送了同样的错误。我的磁盘驱动器上有超过 200 MB 的空间,所以我不确定还有什么会导致此问题。
-
你必须在你的机器上安装一个rabbit 检查这个rabbitmq.com/download.html 安装rabbit服务器后返回并重新运行脚本。希望一切顺利。
-
解决了,谢谢!