1、编写celery的配置文件

from datetime import timedelta

CELERYBEAT_SCHEDULE = {
    # 给任务定义名字
    'add': {
        'task': 'celerytasks.add',  # 反射查找到该函数执行
        'schedule': timedelta(seconds=3),  # 这里使用3秒执行一次
        'args': (16, 16)  # 给add函数,传入两个参数
    }
}
celeryconfig.py

相关文章: