Come utilizzare Supervisor + Django + Celery con più code e lavoratori?

Question

Sto usando Celery + Django + Supervisord e sto cercando di impostare una "priorità" creando 3 code diverse (come suggerito allo https://stackoverflow.com/a/15827160/54872).

C'è un modo per avviare il ritmo del sedano e gli operatori per ogni coda in un comando per supervisore? Oppure devo creare diversi file conf supervisor per ogni pool di code/worker e uno per il ritmo del sedano?

Answer 1

È possibile creare program sezioni per ogni coda e combinarle in una sezione group:

[program:worker1] 
command=celery worker --queues=queue1 

[program:worker2] 
command=celery worker --queues=queue2 

[group:workers] 
programs=worker1,worker2