셀러리 작업자 : 모든 대기열에서 소비하는 방법?

Question

나는

• 은하지 CELERY_QUEUES
• 정의 CELERY_DEFAULT_QUEUE = 'default' 이 표에서와 같이 즉시 경로를 생성
• 사용자 지정 라우터 클래스 (https://github.com/celery/celery/issues/150)을 (직접 형) 정의 CELERY_CREATE_MISSING_QUEUES = True
• 을 설정해야 .

CELERY_CREATE_MISSING_QUEUES 때문에 사용자 지정 라우터가 반환 한 경로의 새 큐가 생성된다고 가정합니다. 지금은 실행 작업자 노드

, 나는 -Q 인수를 전달하지 않고이 문서에 부합하는 것 같다 '기본'큐에서만 소비 -

기본 그것으로 CELERY_QUEUES 설정에 정의 된 모든 대기열에서 소비됩니다 (지정되지 않은 경우 대기열은 기본적으로 셀체라는 ).

동적으로 작성된 것을 포함하여 모든 대기열에서 작업자 노드를 사용할 수있는 방법이 있습니까?

덕분에,

Answer 1

작업자는 이러한 큐의 이름을 얻을 당신이 그들을 만들 때 어쩌면 그들을 저장하거나 rabbitmqctl list_queues에서 어쩌면 그들을 얻을 수있는 방법이 필요하므로, 이러한 자동 또는 동적으로 생성 된 큐에 대해 이야기 할 필요가 당신 경우 RabbitMQ를 브로커로 사용하고 예를 들어 신호 처리기를 추가하여 이러한 동적 대기열을 소비 할 작업자에 추가합니다.

#command all workers to consume from the 'dynamic_queue' queue 
app.control.add_consumer('dynamic_queue', reply=True) 

# command specific workers 
app.control.add_consumer('dynamic_queue', reply=True, destination=[w1@example]) 

참조 : 당신은 항상 새로운 동적 큐가 생성 한 경우

from celery.signals import celeryd_after_setup 

@celeryd_after_setup.connect 
def add_dynamic_queue(sender, instance, **kwargs): 
    # get the dynamic queue, maybe stored somewhere 
    queue = 'dynamic_queue' 
    instance.app.amqp.queues.select_add(queue) 

, 당신은 또한 사용하여 런타임에 이러한 큐에서 소모 시작 노동자를 명령 할 수있다 : celeryd_after_setup 신호를 사용하여 예를 들어

Adding Consumers.

이 정보가 도움이되기를 바랍니다. 자세한 정보를 얻을 때 질문을 수정하겠습니다.