Celery定时任务细讲

一.目录结构

1任务所在目录
2    ├── celery_task # celery包 如果celery_task只是建了普通文件夹__init__可以没有,如果是包一定要有
3    │   ├── __init__.py # 包文件 看情况要不要存在
4    │   ├── celery.py   # celery连接和配置相关文件，且名字必须交celery.py,其实也不是必须的不然你指令可能要修改
5    │   └── tasks.py    # 所有任务函数

二.配置

celery.py

1from celery import Celery
2
3
4#创建一个Celery对象
5broker = 'redis://127.0.0.1:6379/2'  #任务放在用redis://ip:端口/第几个数据库
6backend = 'redis://127.0.0.1:6379/3' #任务结果放在
7include = ['celery_task.tasks',]    #任务所在目录
8app = Celery(broker=broker, backend=backend, include=include)
9
10app.conf.timezone = 'Asia/Shanghai'  #配置时区
11app.conf.enable_utc = False      # 是否使用UTC
12
13from datetime import timedelta
14from celery.schedules import crontab
15app.conf.beat_schedule = {
16    #任务名称自定义可随意
17    'get_banner-task': { 
18        'task': 'celery_task.tasks.get_baidu_info',#任务所在路径且指定哪个任务
19        'schedule': crontab(hour=3,minute=0),  #定时任务相关
20    },
21}
22

celery.py

1from .celery import app
2import requests
3@app.task  #一定要加装饰器
4def get_baidu_info():
5    response = requests.get(https://www.baidu.com/')
6    return response.text

三.配置参数

配置参数的方式

方式一

app.conf.参数名称=参数值

方法二

1app.conf.update(
2    参数名称=参数值,
3    参数名称=参数值
4)

方法三

导入配置文件

app.config_from_object('配置文件路径')

配置文件

1参数名称=参数值
2参数名称=参数值

一.时区配置

常用中国

1app.conf.timezone = 'Asia/Shanghai' 
2app.conf.enable_utc = False 
3#也可以直接设置
4app.conf.timezone = 'Asia/Shanghai' 

国际时间

1app.conf.enable_utc = True
2app.conf.timezone = 'Europe/London'
3#也可以直接设置
4app.conf.timezone = 'Europe/London'

二.beat_schedule

• task： 指定任务的名字
• schedule : 设定任务的调度方式，可以是一个表示秒的整数，也可以是一个 timedelta 对象，或者是一个 crontab 对象（后面介绍），总之就是设定任务如何重复执行
• args： 任务的位置参数以列表的形式
• kwargs：任务的关键字参数,以字典的形式
• options：所有 apply_async 所支持的参数

timedelta 对象

1from datetime import timedelta
2
3 'schedule': timedelta(seconds=3), #每三秒 执行一次 其他想想就知道啦
4  #具体有啥参数我也不想列举了你ctrl+左键进入timedelta源码自己看就知道啦

crontab 对象

1#schedule配置举例
2from celery.schedules import crontab
3# 每分钟执行一次
4crontab()
5
6# 每天凌晨十二点执行
7crontab(minute=0, hour=0)
8
9# 每十五分钟执行一次
10crontab(minute='*/15')
11
12# 每周日的每一分钟执行一次
13crontab(minute='*',hour='*', day_of_week='sun')
14
15# 每周三，五的三点，七点和二十二点没十分钟执行一次
16crontab(minute='*/10',hour='3,17,22', day_of_week='thu,fri')

本文分享 CNBlog - 加载时间中.....。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。