Python 中的 RabbitMQ 绑定交换

Question

我需要将交换器 (amq.topic) 与 Python 中的特定队列绑定。我该怎么做？

现在我绑定了 RabbitMQ 的 GUI。

I'm refering to this TAB of Rabbit

我只用这段代码完成了队列的绑定：

connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()


channel.exchange_declare(exchange='topic_logs', exchange_type='topic')

result = channel.queue_declare(queue='coda-di-prova', exclusive=False)
queue_name = result.method.queue

channel.queue_bind(exchange='topic_logs', queue=queue_name, routing_key="test.*")

print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(" [x] %r:%r" % (method.routing_key, body))


channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()

我需要在我的代码中添加什么才能得到这个结果？ Result IMAGE

Answer 1

我可能没看懂问题。但是用amq.topic

就够了

import pika


connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()


result = channel.queue_declare(queue='coda-di-prova', exclusive=False)
queue_name = result.method.queue

channel.queue_bind(exchange='amq.topic', queue=queue_name, routing_key="test.*")

print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(" [x] %r:%r" % (method.routing_key, body))


channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()

Python 中的 RabbitMQ 绑定交换

RabbitMQ bind exchange in Python

python

amqp

rabbitmq

python-3.x

mqtt