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

Posted 2022-10-17 danhuangpai

一 简介: 今天来聊聊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点执行