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

发布时间：2020-12-20 11:25:18 所属栏目：Python 来源：网络整理

导读：我有一些非常冗长的任务函数,我想从我的tasks.py模块中分离出来,但仍然能够像myapp.tasks import my_task一样调用.我尝试为每个任务创建子模块,但后来我必须在tasks / __ init__.py中添加一些技巧,这看起来非常h??ackish(并且需要赋予任务与模块相同的名称)

我有一些非常冗长的任务函数,我想从我的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')

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!