django celery做定时任务

1
6,655

A+

所属分类：python

每次修改了定时任务的代码，需要重启定时任务以及celery任务

提前做好异步操作（安装等）：https://www.iyunw.cn/archives/django-zhong-shi-yong-celery-yi-bu-zhi-xing-hao-shi-zhang-de-ren-wu/

安装celery后migrate做好后默认admin后台自带了 Djcelery 管理的模板

setting.py需要声明

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
完整的配置：
INSTALLED_APPS = [
.........
'djcelery',
]
import djcelery
djcelery.setup_loader()
BROKER_URL = 'redis://192.168.3.67:6379/1'
CELERY_IMPORTS = ('cmdb.celery_task')
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

完整的配置：

INSTALLED_APPS = [

.........

'djcelery',

]

import djcelery

djcelery.setup_loader()

BROKER_URL = 'redis://192.168.3.67:6379/1'

CELERY_IMPORTS = ('cmdb.celery_task')

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

启动worker：

python manage.py celery worker --loglevel=info

1	python manage.py celery worker --loglevel=info

启动定时任务：

python manage.py celery beat --max-interval=10 --loglevel=INFO
--max-interval=10 ：每十秒侦测一次任务 --loglevel=INFO：日志等级是INFO

1 2	python manage.py celery beat --max-interval=10 --loglevel=INFO --max-interval=10 ：每十秒侦测一次任务 --loglevel=INFO：日志等级是INFO