Wiadomości rozgłoszeniowe w selerze

Question

Używam selera i chcę wysłać zadanie transmisji do kilku pracowników. Staram się robić to jak jest opisane na http://docs.celeryproject.org/en/latest/userguide/routing.html#broadcast więc stworzyć prostą aplikację z zadania:

@celery.task 
def do_something(value): 
    print value 

iw aplikacji zrobiłem:

from kombu.common import Broadcast 
CELERY_QUEUES = (Broadcast('broadcast_tasks'),) 
CELERY_ROUTES = {'my_app.do_something': {'queue': 'broadcast_tasks'}} 

a potem starałem się wysłać zadanie do pracowników z:

my_app.do_something.apply_async(['222'], queue='broadcast_tasks') 

czyli

my_app.do_something.apply_async(['222']) 

, ale niestety w pierwszym zadaniu zadanie jest wysyłane "normalnie" tylko jednemu pracownikowi w jednym czasie - tak więc jeśli mam dwóch pracowników niż zadanie jest wykonywane raz lub pierwszy i raz na drugi pracownik. Po drugie, nie wiem, gdzie jest wykonywane to zadanie, ponieważ na jakimkolwiek pracowniku nie ma żadnego rezultatu. Może ktoś z Was będzie wiedział, dlaczego to nie działa jak transmisja i co robię źle tutaj. Z góry dziękuję za pomoc.

Answer 1

Jakiego brokera używasz?

jeśli używasz Redis, obecnie nie będzie działać w sposób opisany w tym wątku:

https://groups.google.com/forum/#!searchin/celery-users/broadcast/celery-users/s4v_0ndiLT8/rJSME59TQ4YJ

używam RabbitMQ i działa dobrze.