定义一个任务,和异步任务一样:
from apps import app
@app.task()
def beat_test(x,y):
time.sleep(4)
print(x+y)
return 'hello celery beat'
配置定时任务:
CELERYBEAT_SCHEDULE = {
'my_beat':{//任务名
'task':'apps.beat_task.beat_test',
#'schedule':timedelta(seconds=5),
'schedule':crontab(minute=0,hour='*/1'),
'args':(20,30)
}
}