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