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

我有一些非常冗长的任务函数,我想从我的tasks.py模块中分离出来,但仍然能够像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)})

解决方法:

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

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

所以,在tasks.py中：

from django.core import management

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

标签：python,django,django-celery
来源： https://codeday.me/bug/20190729/1569224.html