python 关于celery的定时任务队列的基本使用（celery+redis）【采用配置文件设置】

时间 2019-11-06

标签 python 关于 celery 定时任务队列基本使用 celery+redis redis 采用配置文件设置栏目 Python 繁體版

原文原文链接

工程结构沿用http://www.javashuo.com/article/p-hdgjvkul-a.html，只需修改celeryconfig.py文件便可；html

一、更新celeyconfig.py文件，添加定时任务队列： python

# -*- coding: utf-8 -*-

'''
Created on 2019年8月28日

@author: lenovo
'''
BROKER_URL='redis://localhost:6379/1'

CELERY_RESULT_BACKEND='redis://localhost:6379/2'

CELERY_TIMEZONE='Asia/Shanghai'#不指定时区的话默认采用UTC

#导入指定的任务模块
CELERY_IMPORTS=(
    'celerywithconfig.task1',
    'celerywithconfig.task2',
    )


from datetime import timedelta from celery.schedules import crontab #设置定时任务:配置说明官网文档请参考http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#beat-entries
CELERYBEAT_SCHEDULE={ 'task1':{ 'task':'celerywithconfig.task1.add', 'schedule':timedelta(seconds=10), 'args':(2,8) }, 'task2':{ 'task':'celerywithconfig.task2.multiply', 'schedule':crontab(hour=14,minute=23), 'args':(4,5) } }

二、启动beat和worker：redis

启动beat命令：python -m celery -A celerywithconfig beat --loglevel=infoapp

启动worker命令：python -m celery -A celerywithconfig worker --loglevel=infoide

三、beat日志查看定时任务触发状况：从日志中能够看出每隔10s发送一次任务task1，而且在14:23发送了任务task2。ui

四、worker日志查看任务执行状况：每隔10s接收消费来自beat发送的定时任务task1，并在14:23接收消费beat发送的定时任务task2.spa