【发布时间】:2017-09-28 00:45:51
【问题描述】:
问题:当我从自定义文件导入数据时,@shared_task 装饰器不起作用。我的意思是,当我启动 celery 时,@shared_task 下的所有任务都不会出现在任务列表中。
例如,在这种情况下,@shared_task 装饰器不起作用:
from __future__ import absolute_import, unicode_literals
from celery import shared_task
from .models import foo
@shared_task
def my_foo_backup(id):
my_foo = foo(....)
...
...
这是一个例子,当@shared_task 工作时:
from __future__ import absolute_import, unicode_literals
from celery import shared_task
@shared_task
def my_foo_backup(id):
my_foo = foo(....)
...
...
为什么?!?
【问题讨论】:
-
这段代码是你在“tasks.py”中写的吗?当然,Celery 只将“tasks.py”识别为一个任务。另见docs.celeryproject.org/en/latest/reference/…
-
是的,当然。在我的第二个示例中,它不会将@shared_task 添加到任务列表中。
-
第一个例子,可以导入models.foo吗?
-
告诉k,试过了。这也行不通
标签: django celery celery-task cookiecutter-django