如何在Django中跨应用程序/项目注册芹菜任务？

Question

如何从项目级调用芹菜（app）任务，反之亦然。

我有这样一个Django目录结构：

- proj 
    |_ celery.py 
    |_ settings.py 
- app 
    |_ tasks.py 
    |_ views.py 

在settings.py我有CELERYBEAT_SCHEDULE变种，其指的是在shared_task app/tasks。此任务未在celery inspect registered中列出。

无论是apps/views.py任务其中是注册表中列出因为他们在proj/celery.py被定义，通过函数调用。

我按照芹菜网站上的说明操作。

Answer 1

shared_task装饰器中的函数必须在应用程序AppConfig中列出。

在app/apps.py导入你的任务，像这样：

from .tasks import add 

在app/tasks.py进口shared_task像这样：

from proj.celery import shared_task 

在proj/celery.py进口shared_task像这样：

import celery 
from celery import shared_task 

Pycharm会抱怨关于未使用的进口，ho无论他们是用什么，只是不在文件pycharm解析。

现在，当我开始芹菜工作者，如：

python manage.py celeryd --loglevel=DEBUG & 

而不是

celery -A pears worker --loglevel=info & 

我在app/tasks.py任务是注册和调用。