Celery定时任务细讲
2024-10-19 23:37:00
Celery定时任务细讲
一.目录结构
任务所在目录
├── 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')
最新文章
- MySQL学习笔记
- CentOS6编译安装PHP7+Nginx
- 学android: android-studio从main开始
- Cookie在IE缓存问题深度研究
- Adding Swagger to Web API project
- Hadoop入门进阶课程6--MapReduce应用案例
- Eclipse设置UTF-8
- Mysql连接测试代码
- VS2008简体中文正式版序列号
- java和php实现RSA加密互通-b
- 转 Web APi之认证(Authentication)两种实现方式【二】(十三)
- OpenCV学习(1) RGB颜色空间
- mysql主从切换步骤
- 初识Celery
- 不错的 HttpHelper类 c#
- Python之路(第三十二篇) 网络编程:udp套接字、简单文件传输
- 第十二节、尺度不变特征(SIFT)
- 环形链表(给定一个链表,返回链表开始入环的第一个节点。 如果链表无环,则返回 null)
- shh和maven项目报错
- ES6 之reduce的高级技巧
热门文章
- 刷题记录:[网鼎杯]Fakebook
- _nl_intern_locale_data: Assertion `cnt <; (sizeof (_nl_value_type_LC_TIME) / sizeof (_nl_value_type_LC_TIME[0]))&#39; failed
- PHP 发送 POST 值到任意 url
- Vue.js实现tab切换效果
- LeetCode:接雨水【42】
- 【Linux开发】【CUDA开发】Ubuntu上安装NVIDIA显卡驱动
- spring cloud集成canal
- idea设置内存大小
- 07 Mybatis的多表查询1----1对多和多对1---@Results注解用法总结
- 完全卸载MySQL服务