我怎么能将一个大的django-celery tasks.py模块拆分成更小的块？

Question

我有一些非常冗长的任务函数,我想从我的tasks.py模块中突破,但仍然可以调用from myapp.tasks import my_task.我尝试为每个任务创建子模块,但后来我必须插入一些技巧tasks/__init__.py,这看起来非常h​​ackish(并且需要赋予任务与模块相同的名称):

import pkgutil

for module_loader, name, ispkg in pkgutil.iter_modules(__path__):
    __import__('myapp.tasks.%s' % name)
    locals().update({name: getattr(locals()[name], name)})

Answer 1

这个答案是关于管理命令而不是Celery后台任务意义上的任务.

我认为最直接的解决方案是首先将任务写为Django管理命令,然后从tasks.py中调用它们.这样,您可以将每个文件的任务分解为一个任务,并具有能够从命令行任意调用任务的额外好处.

所以,在tasks.py:

from django.core import management

@task()
def my_task():
    management.call_command('my_task')