python - pika を使用して Python クライアントで RabbitMQ クラスターに接続する方法は?

Question

Pika パッケージ (0.9.13) を使用し、RabbitMQ クラスター内の 1 つのノードからデータを取得する Python クライアントがあります。クラスターは、2 つの異なるホスト (url_1 と url_2) に配置された 2 つのノードで構成されます。Python クライアントを両方のノードにサブスクライブさせるにはどうすればよいですか?

それが私のコードの主な構造です:

import pika
credentials = pika.PlainCredentials(user, password)
connection = pika.BlockingConnection(pika.ConnectionParameters(host=url_1,
                                     credentials=credentials, ssl=ssl, port=port))
channel = connection.channel() 
channel.exchange_declare(exchange=exchange.name, 
                         type=exchange.type, durable=exchange.durable)

result = channel.queue_declare(queue=queue.name, exclusive=queue.exclusive, 
                             durable=queue.durable, auto_delete=queue.autoDelete)
channel.queue_bind(exchange=exchange.name, queue=queue.name, 
                   routing_key=binding_key)
channel.basic_consume(callback,
                  queue=queue.name,
                  no_ack=True)

channel.start_consuming()