定义一个任务,和异步任务一样:

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)
    }
}