Celery 检查工作任务并检索任务文档字符串

Posted 2023-02-23

【中文标题】Celery 检查工作任务并检索任务文档字符串

【英文标题】：Celery inspect worker tasks and retrieve the task docstrings

【发布时间】：2014-12-02 08:18:23

【问题描述】：

我正在使用 celery 工作节点并开发 Django Rest API 来处理 celery 任务提交。我可以通过inspect()获取任务列表

     i = app.control.inspect()
     i.registerd()

但需要从工作节点任务中获取文档字符串。这将用于 GET 请求，以向最终用户显示有用的有用信息。 Celery 任务代码未安装在 django rest api 应用程序中。那么如何检查工作人员的任务并返回任务的文档字符串。任何帮助将不胜感激。

【问题讨论】：

为什么不在你的任务中使用__doc__？

我可以使用 __ doc __ 但代码在本地不可用。 Celery 使用与工作节点通信的代理。该应用程序连接到 broker，您可以通过 Celery 检查已注册的任务。问题是我找不到从工作节点中提取文档字符串的方法。

【参考方案1】：

注册的原型是

def registered(self, *taskinfoitems): 
    return self._request('dump_tasks', taskinfoitems=taskinfoitems) 

您可以在 taskinfoitems 参数中指定__doc__