芹菜/ 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()时选择的工人分类的结果（如果没有工人作为参数传递，则隐式选择所有工人）。