django-Celery分布式队列简单使用

Posted 2022-02-11 wendj

 

介绍：

Celery 是一个简单、灵活且可靠的，处理大量消息的分布式系统，并且提供维护这样一个系统的必需工具。

它是一个专注于实时处理的任务队列，同时也支持任务调度。

worker:是一个独立的进程，任务执行单元，它持续监视队列中的任务

broder:消息传输中间件，任务调度队列，接收生产者发出的消息，将任务存放到队列，负责协调客户端和worker的沟通。客户端向队列添加消息，borker负责把消息派发给worker

backend:任务结果存储任务执行结果，同消息中间件一样，需要由其它存储系统提供支持。

推荐学习网站：http://docs.jinkan.org/docs/celery/

 

第一步：在项目环境中安装celery

pip install celery

　　

 

第二步：在项目中创建celery_task文件夹内容如下：

注意：一定要在项目根目录中创建

 

 第三步：创建发送短信的任务逻辑目录

 

 第四步：调用任务

 

 第五步：在Linux系统中进入项目根目录中可以看到celery_task文件进行启动

celery -A celery_task.main worker -l info

　　

 

 第六步：测试异步发送验证码

 

 

 

拓展：在后台运行。

celery -A celery_task.main worker -l info &

　　

 

 查看后台进程：jobs