使用 pika 检索 AMQP 路由密钥信息

use*_*014 5 python amqp pika

RabbitMQ 新手,我正在尝试确定一种检索 AMQP 消息的路由密钥信息的方法。以前有人真正尝试过这个吗?我没有找到很多明确说明如何使用 pika (python) 查询 AMQP 的文档。

这就是我正在尝试做的事情:

基本上我有一个 Consumer 类,例如:

channel.exchange_declare(exchange='test', type='topic') channel.queue_declare(queue='topic_queue',auto_delete=True) channel.queue_bind(queue='topic_queue', exchange='test', routing_key = '#')

我设置了一个队列,并绑定到一个交换器,所有的路由密钥(或我认为的绑定密钥)都通过该交换器传递。

我还有一个功能:

def amqmessage(ch, method, properties, body): channel.basic_consume(amqmessage, queue=queue_name, no_ack=True) channel.start_consuming()

我认为routing_key应该是amqmessage函数中的“method.routing_key”,但我不确定如何让它正常工作。

小智 3

我想写下答案,因为这个问题是在谷歌文档之前出现的。

def amqmessage(ch, method, properties, body): channel.basic_consume(amqmessage, queue=queue_name, no_ack=True) channel.start_consuming()

可以通过以下方式找到路由密钥:method.routing_key