Messaggi broadcast in sedano

Question

Uso il sedano e desidero inviare un'attività di trasmissione a un paio di lavoratori. Sto cercando di farlo come è descritta a http://docs.celeryproject.org/en/latest/userguide/routing.html#broadcast così creo semplice applicazione con compito:

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

e app che ho fatto:

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

e poi ho cercato di inviare compito di lavoratori con:

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

o:

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

ma sfortunatamente nel primo modo il compito è inviare "normalmente" solo a un lavoratore in una volta - quindi se ho due lavoratori che il compito è fatto una volta o prima e una volta su un secondo lavoratore. In secondo luogo, non so dove viene svolto questo compito, perché su qualsiasi lavoratore non ne risulta alcun risultato. Forse qualcuno di voi saprà perché non funziona come trasmissione e cosa sto facendo male qui. Grazie in anticipo per l'aiuto.

Answer 1

Che broker stai utilizzando?

se si sta utilizzando Redis, attualmente non funzionerà, come spiegato in questa discussione:

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

sto usando RabbitMQ e funziona benissimo.