如何使用同一个应用程序处理芹菜中不同包中的任务

Question

假设我有一个包a，它定义了一些芹菜任务：

app = Celery('tasks')

@app.task
def doA():
    return "doA"

我也有一个B包，它可以做同样的事情：

^{pr2}$

然后我有一个包裹了a和B的包裹C：

import package_a
import package_b
#Of course I can call doA and doB asynchronously
package_a.doA.delay()
package_a.doB.delay()

但是在包C中，我如何启动一个worker（定义一个全局app对象），它同时包含包a和包B中的任务？在

Answer 1

在您的软件包中，您可以添加以下芹菜配置：

CELERY_IMPORTS = [
    'package_a',
    'package_b',
  ]

然后工人将从A和B中找到任务