Pika and RabbitMQ - 특정 노드에 대기열 만들기

Question

두 개의 노드가있는 rabbitmq 클러스터가 있습니다. node1에서 호스팅 될 큐와 node2에서 호스팅되는 다른 큐를 생성하고 싶습니다.

ConnectionParameters에서 node2로 호스트를 설정하더라도 대기열은 node1에서 계속 생성됩니다.

프로그래밍 방식으로 pika를 사용하여 대기열을 만들려는 노드를 지정하는 방법을 잘 모르겠습니다. 이 이러한 매개 변수는 queue_declare에 없다,이 같은 인수를 전달하는 것은 작동하지 않습니다 호스팅 노드를 지정하기위한 모든 인터페이스는

channel.queue_declare(queue="whereami", durable=True, exclusive=False, auto_delete=False, callback=on_queue_declared, arguments= {'node':'rabbit@node1'}) 

있습니까? 이 사건을 처리 할 다른 방법이 있습니까?

감사합니다.

Answer 1

클러스터 대기열의 노드를 만들 때 지정할 인수를 찾을 수 없지만이 문제는 해결해야합니다. 당신이 클러스터 토끼 @의 노드 1 토끼 @의 노드 2에서 두 개의 노드가 있다고 가정, 당신은 단순히 지정할 수 있습니다

arguments["x-ha-policy"] = "nodes" 
arguments["x-ha-policy-params"] = 'rabbit@node1' 

이 하나는 노드 1 잔분 것이다 큐를 생성합니다.

Answer 2

클러스터는 일반적으로 다른 호스트 또는 동일한 호스트의 다른 포트 (see docs for more on this)로 정의됩니다.

pika.connection.ConnectionParameters의 일부로 호스트와 포트 번호를 모두 정의 할 수 있습니다.