Сельдерей/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() (если ни один из работников не передан в качестве аргументов, все работники неявно выбраны).