芹菜/ Django - 如何以編程方式查看工人狀態

Question

我剛剛安裝了芹菜，我想創建一個簡單的狀態頁面，顯示當前的工人數量及其狀態。

這可能嗎？從網絡搜索我發現最好的是celery.current_app.control.inspect()

但據我所知，它沒有提到關於工人的任何事情。 （如果有問題，我使用Kombu和SQS作爲後端）

Answer 1

在the documentation of celery workers中說明了inspect命令的輸出。

默認情況下，使用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'], 
    } 

總之，「檢查」例如，如果你有一個名爲「加法」和「臥鋪」兩場倒的工人執行該代碼方法registered,active,scheduled等返回一個字典，其結果是調用celery.current_app.control.inspect()時選擇的工人分類的結果（如果沒有工人作爲參數傳遞，則隱式選擇所有工人）。