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

Question

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

这就是我要做的：

基本上我有一个消费者类，例如：

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()

我认为路由密钥应该是“method.routing_键“来自amqmessage函数，但我不确定如何使其正常工作。在

Answer 1

我想把答案写下来，因为这个问题是在谷歌文档之前。在

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

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