python - 使用 pika 检索 AMQP 路由 key 信息

Question

RabbitMQ 的新手，我正在尝试确定一种检索 AMQP 消息的路由 key 信息的方法。有人真的试过这个吗？我没有找到很多明确说明如何使用 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 = '#')

我设置了一个队列并绑定(bind)到一个交换器，所有路由键(或我想的绑定(bind)键)都通过该交换器传递。

我还有一个功能:

def amqmessage( channel 、方法、属性、正文):
channel.basic_consume(amqmessage，queue=queue_name，no_ack=True)
channel.start_consuming()

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

Answer 1

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

def amqmessage( channel 、方法、属性、正文):
channel.basic_consume(amqmessage，queue=queue_name，no_ack=True)
channel.start_consuming()

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