正常情况下,人可以完成所有健康情况的动作,不需要医院的参与;但当人生病时,就会被医院接收,解决人生病问题
人生病的处理方案交给医院来解决,所有人不生病时,医院独立运行,人生病时,医院就来解决人生病的需求
消息中间件
celery本身不提供消息服务,但是可以与第三方提供的消息中间件组成,包括RabbitMQ,Redis等等
任务执行单元
worker是celery提供的任务执行单元,worker并发的运行在分布式的系统节点中
任务结果存储
task result store用来存储worker执行的任务的结果,celery支持以不同的方式存储任务的结果,包括AMQP, redis等
异步执行:解决耗时任务,视频同步
延迟执行:解决延迟任务,定时发送邮件
定时执行:解决周期或者间隔任务,定时更新
pip install celery
1、celery对象:Celery(...)是放在一个模块下
1. 终端切换到文件夹所对应的位置
2.执行启动worker的命名:celery worker -A 模块名 -l info -P eventlet
注:windows系统需要eventlet支持,Linux与MacOS直接执行:celery worker -A 模块名 -l info
2、如果celery对象:Celery(...)是放在一个包下
1.必须在包下建一个celery.py文件,将Celery(...)产生对象的语句放在该文件中
2.执行启动worker的命名:celery worker -A 包名 -l info -P eventlet
注:windows系统需要eventlet支持,Linux与MacOS直接执行:celery worker -A 包名 -l info
注:包名随意
1、创建app + 任务tasks
celery.py
tasks.py
2、启动celery服务:终端切换到包的文件夹
3、添加任务:手动添加,要自定义添加任务的脚本,右键run执行脚本
add_task.py
4、获取结果:手动获取,要自定义获取任务的脚本,右键run执行脚本
get_result.py
1、在celery中配置好beat_schedule的配置
2、执行命令启动定时添加任务服务:celery beat -A 包名|模块名 -l info
不用使用 -P eventlet
重点:由于采用了django的反射机制,使用celery.py所在的celery_task包必须放置项目的根目录下
如果不想把celery_task包放在项目根目录,必须添加如下几句,将项目根目录要添加到环境变量中,
1、celery.py中加载django配置环境
2、创建Celery框架对象app,配置broker和backend,得到的app就是worker
3、完成提供的任务的定时配置app.conf.beat_schedule
4、切换到项目根目录下启动celery服务,运行worker,执行任务
celery worker -A celery_task -l info -P eventlet
5、切换到项目根目录下启动beat服务,运行beat,添加任务
celery beat -A celery_task -l info
由于最新的celery4.2不支持windows系统,因此按照网上的建议安装了3.1.25版。按照官网的说明使用
- 1. 问题是:开启worker和beat进程后发现周期性任务没有被执行?
- 花了不少时间查了查,最终发现,解决办法:
celery4中才引入了beat_schedule这些小写变量,以前都是大写变量。即:Version 4.0 introduced new lower case settings and setting organization. 具体见说明。
因此,我就把变量名改回了大写CELERYBEAT_SCHEDULE。果然成功了。