Celery / Django - 如何以编程方式查看工人的状态

Question

我刚刚安装了 Celery，我想创建一个简单的状态页面，显示当前的工人数量和他们的状态。

这可能吗？从网络搜索中我找到的最好的是celery.current_app.control.inspect()

但据我所知，它没有提到任何关于工人的事情。 （如果这很重要，我会使用带有 SQS 的 Kombu 作为后端）

Answer 1

在the documentation of celery workers 中解释了inspect 命令的输出。

默认情况下，使用celery.current_app.control.inspect() 返回一个“检查器对象”，允许您询问所有正在运行的工作人员的状态。例如，如果您使用名为“adder”和“sleeper”的两个正在运行的工作人员执行此代码：

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