Celery + Django 将task按照包进行管理

背景

最近写 Django 时遇到个问题,就是要使用 Celery 进行定时任务触发。在配置任务函数时老是无法自动发现注册过的任务。最终花了点心思,研究了下源码才解决。在这里记录下注意点

在使用 Celery 提供的 autodiscover_tasks 方法来自动发现任务时,默认是发现在 settings 模块里注册过的应用下的 tasks 模块中包含的被 Celerytask() 装饰器装饰过的任务函数。

而我想将这些任务函数分开放在不同的模块下,按照包的方式进行管理。这里就存在三个坑,需要注意下。

注意点

  1. 为了尽量减少对 Celery 默认逻辑的修改,包名应该为 tasks
  2. 存在 __init__ 模块的目录才是 Python 包。记得创建一个空的 __init__.py 文件。
  3. 包中定义的任务,都需要在 __init__ 模块中进行导入,最好将这些被导入的任务函数包含在 __all__ 列表中,来避免被 flake8 扫出警告。
评论 1
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值