mehrere Mitarbeiter und mehrere Warteschlangen auf Sellerie django-daemon
Ich bin mit Sellerie-django-Warteschlange-Aufgaben auf meiner Website backend.
Ich bin versucht, erstellen Sie eine setup wo ich zwei queues mit dem Namen "low" und "high" und zwei Arbeiter W1 und W2.
Ich will, dass Sie verbrauchen die tasks aus der Warteschlange in der folgenden Weise:
W1 <-- tief -, hoch -
W2 <-- hoch
Normalerweise ist es getan werden kann, wie dies.
Öffnen Sie das terminal und geben Sie 1
$celery worker -n W1 -Q low,high
Öffnen Sie das terminal 2 und geben Sie
$celery worker -n W2 -Q high
Aber ich bin versucht, das gleiche zu tun über celeryd daemon.
Verfolge ich die Schritte in dem link: http://celery.readthedocs.org/en/latest/tutorials/daemonizing.html#example-configuration
Aber die verfügbaren Optionen scheinen nicht genug, um der Anforderung.
Bitte helfen Sie mir mit einigen configs, ich bin bewusst, die könnte machen es möglich. Ich würde es vorziehen, nicht zu laufen, mehrere Dämonen oder der Einsatz zusätzlicher tools wie supervisord, es sei denn wirklich notwendig ist (Vielleicht könnten Sie mir Ratschläge auf dieser auch).
Du musst angemeldet sein, um einen Kommentar abzugeben.
Können Sie
CELERYD_OPTS
option übergeben -Q-parameter ähnlich denen Beispiele aus Sellerie Referenz:CELERYD_NODES="w1 w2 w3 w4 w5"
anstatt-c 4
kann ich noch mit der syntax von-Q:1-3
?Können Sie mehrere Knoten in CELERY_NODES und pass-node-Namen zu CELERYD_OPTS Argumente, zum Beispiel: