Sellerie/Django - Wie man Arbeiterstatus programmatisch sieht

Question

Ich habe gerade Sellerie installiert und ich möchte eine einfache Statusseite erstellen, die die aktuelle Anzahl der Arbeiter und ihren Status anzeigt.

Ist das möglich? Von Web-Suchen die beste, die ich fand, war celery.current_app.control.inspect()

Aber soweit ich sehen kann, erwähnt es nichts über Arbeiter. (Ich verwende Kombu mit SQS für das Backend, wenn das wichtig ist)

Answer 1

In the documentation of celery workers wird die Ausgabe der inspect Befehle erklärt.

Standardmäßig wird mit celery.current_app.control.inspect() ein "Inspector-Objekt" zurückgegeben, mit dem Sie nach dem Status aller aktiven Worker fragen können. Zum Beispiel, wenn Sie diesen Code mit zwei Laufe Arbeitern namens ‚Natter‘ und ‚Schläfer‘ ausführen:

i = celery.current_app.control.inspect() 
    i.registered() 

der Aufruf von i.registered() zurückkehren kann so etwas wie:

{ 
     'adder@example.com': ['tasks.add'], 
     'sleeper@example.com': ['tasks.sleeptask'], 
    } 

Im Ergebnis des „Inspektor“ Methoden registered, active, scheduled usw. geben ein Wörterbuch mit den Ergebnissen zurück, die von den ausgewählten Arbeitern beim Aufruf von celery.current_app.control.inspect() klassifiziert wurden (wenn keine Arbeiter als Argumente übergeben werden, werden alle Arbeiter implizit ausgewählt).