平台项目~celery 异步之定时任务功能

一 简介: 今天来聊聊celery的定时任务功能

二 标准流程:

1 配置config.py

from celery.schedules import crontab

CELERYBEAT_SCHEDULE = {
       ‘ celery_test.tasks.test_run‘: {
        ‘task‘: ‘celery_test.tasks.test_run‘,
        ‘schedule‘: crontab(minute=‘*/2‘)
         }
        }

2  启动woker进程

3  启动crontab 进程

celery -A  celery_demo.celery beat -l info -f log

4  查看日志信息

[2019-09-12 10:38:00,011: INFO/MainProcess] Scheduler: Sending due task celery_test.tasks.test_run (celery_test.tasks.test_run)
       [2019-09-12 10:38:00,036: DEBUG/MainProcess] celery_test.tasks.test_run sent. id->d16b6bd8-15c6-4d65-b46d-a215602776c0

5  crontab设置

参数 minute hour day_of_week

例子 ‘schedule‘: crontab(minute=0, hour=8, day_of_week=[1, 2, 3, 4, 5])  每周1-5 早上8点执行

原文地址：https://www.cnblogs.com/danhuangpai/p/11511078.html