python - 无法获得适用于 RabbitPy 的示例

Question

我似乎无法运行代码 - 我一直在使用 Pika，并热衷于尝试这个线程安全且可能更简洁的版本。

import rabbitpy

with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
    with conn.channel() as channel:
        queue = rabbitpy.Queue(channel, 'example')

        # Exit on CTRL-C
        try:
            # Consume the message
            for message in queue:
                message.pprint(True)
                message.ack()

        except KeyboardInterrupt:
            print 'Exited consumer' 

我得到的错误:

Traceback (most recent call last):
  File "newshift.py", line 3, in <module>
    with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
AttributeError: 'module' object has no attribute 'Connection'

我的系统设置是:

numpy==1.11.2
pamqp==1.6.1
pandas==0.19.0
pika==0.10.0
pkg-resources==0.0.0
python-dateutil==2.5.3
pytz==2016.7
rabbitpy==1.0.0
six==1.10.0
SQLAlchemy==1.1.3

<小时/>

dir(rabbitpy)
['__builtins__', '__doc__', '__file__', '__name__', '__package__']

不知何故，在模块中加载时看不到这些类

最初的问题是由 .pyc 文件挂起引起的，但新的错误消息是:

Traceback (most recent call last):
  File "newshift.py", line 15, in <module>
    print 'Exited consumer' 
  File "/home/brett/code/SimpleConsumers/local/lib/python2.7/site-packages/rabbitpy/connection.py", line 149, in __exit__
    raise exc_val
rabbitpy.exceptions.AMQPNotFound: <pamqp.specification.Channel.Close object at 0x7f39a91da7d0>

Answer 1

rabbitpy.exceptions.AMQPNotFound: <pamqp.specification.Channel.Close

我认为rabbitpy给出此错误，因为它尝试连接到不存在的 queue姓名 example

queue = rabbitpy.Queue(channel, 'example')

但是rabbitpy如果此队列尚不存在，则不会创建该队列。

我检查了examples with pika他们工作是因为 pika当队列(名称为 hello )不存在时创建它，以便它可以安全地从此队列发送和接收。

pika在两种情况下都会自动创建队列 - 当您发送或接收消息时。

<小时/>

您可以使用命令检查rabbitmq中的现有队列(在Linux上)

sudo rabbitmqctl list_queues

即。结果

Listing queues ...
celery  3
hello   0
...done.

<小时/>

如果我用 pika 发送消息然后我可以通过 rabbitpy 接收它因为pika如果队列不存在则创建队列，然后 rabbitpy可以安全地使用这个队列。

<小时/>

看来你必须使用 queue.declare()如果队列不存在则创建队列。

import rabbitpy

with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
    with conn.channel() as channel:
        queue = rabbitpy.Queue(channel, 'example')
        queue.declare() # <---