celery介绍架构

# celery :分布式的异步任务框架,主要用来做:
– 异步任务
– 延迟任务
– 定时任务—》如果只想做定时任务,可以不使用celery,有别的选择

# celery 框架,原理
1)可以不依赖任何服务器,通过自身命令,启动服务(内部支持socket)
2)celery服务为为其他项目服务提供异步解决任务需求的
注:会有两个服务同时运行,一个是项目服务,一个是celery服务,项目服务将需要异步处理的任务交给celery服务,celery就会在需要时异步完成项目的需求

人是一个独立运行的服务 | 医院也是一个独立运行的服务
正常情况下,人可以完成所有健康情况的动作,不需要医院的参与;但当人生病时,就会被医院接收,解决人生病问题
人生病的处理方案交给医院来解决,所有人不生病时,医院独立运行,人生病时,医院就来解决人生病的需求

# celery架构
消息中间件(broker):消息队列:可以使用redis,rabbitmq,咱们使用redis
任务执行单元(worker):真正的执行 提交的任务
任务执行结果存储(banckend):可以使用mysql,redis,咱们使用redis

# 安装celery

 pip install Celery

-安装完成会释放出可执行文件:celery,由于 python解释器的script文件夹再环境变量,任意路径下执行celery都能找到

注意:
# celery不支持win,所以想再win上运行,需要额外安装eventlet
windows系统需要eventlet支持:

pip install eventlet