django celery 实现定时任务
首先介绍定时任务,跟crontab类似,celery的定时任务可以很灵活的设置执行的时间频率,定时任务需要启用django,celery,beat三个应用。
实现一个定时任务只需要三步就可以搞定。
第一步: 在需要执行定时任务的函数加上task装饰器,表示这个函数由celery接管
-
from celery import task
-
-
@task
-
def func():
-
pass
第二步: 在celery配置文件中加入定时任务配置,主要配置就是对时间频率的设置,在哪个时间点运行任务,
以及运行的频率,配置文件为celery.py(跟settings相同目录)
-
app.conf.update(
-
celerybeat_schedule={
-
'do-task-everyday-func': {
-
'task': 'func',
-
'schedule': crontab(minute='30', hour='10', day_of_week='*',
-
day_of_month='*', month_of_year='*')
-
}
-
}) 表示每天的10:30运行func任务,task定位运行函数,schedule定位运行日程
第三步: 运行celery
-
运行django应用 python manage.py runserver 0.0.0.0:8000
-
运行celery(用来执行任务的守护线程) celery -a $appname worker -l info
-
celery会显示由celery监管的函数[tasks]
-
-
运行beat进行(用来监控定时任务是否需要执行) celery -a $appname beat
-
-
-
显示捕捉到的定时任务函数
阅读(133392) | 评论(0) | 转发(0) |