Celery/Django - 作業者の状態をプログラム的に表示する方法

Question

Celeryをインストールしたばかりで、現在の人数と状態を示す簡単なステータスページを作成したいと思います。

これは可能ですか？ウェブ検索から、私が見つけた最高のものはcelery.current_app.control.inspect()

ですが、私が見る限り、それは労働者について何も言及していません。 （私はKombuを使ってバックエンドにSQSを使用しています）

Answer 1

the documentation of celery workersinspectコマンドの出力について説明しています。

デフォルトでは、celery.current_app.control.inspect()を使用すると、実行中のすべてのワーカーの状態を尋ねることができる「インスペクタオブジェクト」が返されます。

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

のようなものを返すことができi.registered()への呼び出し：：結論

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

を、「インスペクタ」たとえば次の2人の実行中の「加算」と「眠る」という名前の労働者で、このコードを実行した場合メソッドregistered、active、scheduledなどは、celery.current_app.control.inspect()が呼び出されたときに選択されたワーカーによって結果が分類された辞書を返します（引数として渡されるワーカーがない場合、すべてのワーカーが暗黙的に選択されます）。