一. 目录结构
任务所在目录
├── celery_task # celery 包 如果 celery_task 只是建了普通文件夹__init__可以没有, 如果是包一定要有
│ ├── __init__.py # 包文件 看情况要不要存在
│ ├── celery.py # celery 连接和配置相关文件, 且名字必须交 celery.py, 其实也不是必须的不然你指令可能要修改
│ └── tasks.py # 所有任务函数
二. 配置
celery.py
- from celery import Celery
- # 创建一个 Celery 对象
- broker = 'redis://127.0.0.1:6379/2' #任务放在用 Redis://ip: 端口 / 第几个数据库
- backend = 'redis://127.0.0.1:6379/3' #任务结果放在
- include = ['celery_task.tasks',] #任务所在目录
- App = Celery(broker=broker, backend=backend, include=include)
- App.conf.timezone = 'Asia/Shanghai' #配置时区
- App.conf.enable_utc = False # 是否使用 UTC
- from datetime import timedelta
- from celery.schedules import crontab
- App.conf.beat_schedule = {
- #任务名称自定义可随意
- 'get_banner-task': {
- 'task': 'celery_task.tasks.get_baidu_info',# 任务所在路径且指定哪个任务
- 'schedule': crontab(hour=3,minute=0), #定时任务相关
- },
- }
celery.py
- from .celery import App
- import requests
- @App.task #一定要加装饰器
- def get_baidu_info():
- response = requests.get(https://www.baidu.com/')
- return response.text
三. 配置参数
配置参数的方式
方式一
App.conf. 参数名称 = 参数值
方法二
App.conf.update(
参数名称 = 参数值,
参数名称 = 参数值
)
方法三
导入配置文件
App.config_from_object('配置文件路径')
配置文件
参数名称 = 参数值
参数名称 = 参数值
一. 时区配置
常用中国
- App.conf.timezone = 'Asia/Shanghai'
- App.conf.enable_utc = False
- # 也可以直接设置
- App.conf.timezone = 'Asia/Shanghai'
国际时间
- App.conf.enable_utc = True
- App.conf.timezone = 'Europe/London'
- # 也可以直接设置
- App.conf.timezone = 'Europe/London'
二. beat_schedule
task: 指定任务的名字
schedule : 设定任务的调度方式, 可以是一个表示秒的整数, 也可以是一个 timedelta 对象, 或者是一个 crontab 对象 (后面介绍), 总之就是设定任务如何重复执行
args: 任务的位置参数以列表的形式
kwargs: 任务的关键字参数, 以字典的形式
options: 所有 apply_async 所支持的参数
timedelta 对象
- from datetime import timedelta
- 'schedule': timedelta(seconds=3), #每三秒 执行一次 其他想想就知道啦
- #具体有啥参数我也不想列举了你 ctrl + 左键进入 timedelta 源码自己看就知道啦
crontab 对象
- #schedule 配置举例
- from celery.schedules import crontab
- # 每分钟执行一次
- crontab()
- # 每天凌晨十二点执行
- crontab(minute=0, hour=0)
- # 每十五分钟执行一次
- crontab(minute='*/15')
- # 每周日的每一分钟执行一次
- crontab(minute='*',hour='*', day_of_week='sun')
- # 每周三, 五的三点, 七点和二十二点没十分钟执行一次
- crontab(minute='*/10',hour='3,17,22', day_of_week='thu,fri')
来源: http://www.bubuko.com/infodetail-3237753.html