“ https://github.com/celery/celery”
celery的GitHub源码文件
Celery是一个异步任务队列,需要python的环境,一般可用于python的web开发框架“食”用,例如Django。
场景
例如在自己开发网站时,写发送短信验证码的部分,往往需引用第三方包,同时这段发送短信的代码会花费较长时间(好几秒、甚至十几秒),点击了“发送短信验证码”并不会立即开始倒计时,而是等了好几秒之后,才开始,这让用户感觉很卡顿,我们在体验腾讯云、阿里云的,往往是一点击就开始倒计时,虽然短信可能得等一小会,但界面却是立即响应的。
这里可以给一段简单的逻辑:
def get(self, request, mobile):
# 1.创建连接Redis对象
... get_redis_connection ...
# 2. 随机生成短信验证码
... ...
# 3.把验证码存入Redis缓存
... setex() ...
... setex() ...
# 4.通过第三方SDK发送短信
XXX().send_ ... # 这一步往往十分耗时(好几秒、甚至十几秒)
# 5.最后响应回前端页面
return Response(...)
也就是说执行到最后Response,有个send步骤太慢,这时候我们就可以使用celery解决这个阻塞问题。(执行完后返回结果,这段时间不用等待,提高系统的吞吐量和响应时间)
配置示例
本节以Django项目为示例:
创建py目录celery_tasks | 在后端项目的一级目录下 |
该目录下创建main的py文件 | (作为celery服务启动的文件) |
该目录下创建config的py文件 | (作为存储配置的文件) |
这就是celery最基本的文件目录情况。目录结构创建完之后,安装celery(pip install celery或者编译器直接导入)。
在celery_tasks目录下创建包,要用什么任务就自行创建什么包。
这里创建xxx的py目录,然后在其下面创建 tasks 的py文件【注意这个名字是固定的】
比如配置发短信,那么在main.py就需①配置celery对象、②加载config配置文件、③注册异步任务和config.py配置Redis服务器位置。使用起来还是比较容易的。