Django Celery异步任务队列

“ 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项目为示例：

这就是celery最基本的文件目录情况。目录结构创建完之后，安装celery（pip install celery或者编译器直接导入）。

    在celery_tasks目录下创建包，要用什么任务就自行创建什么包。

    这里创建xxx的py目录，然后在其下面创建 tasks 的py文件【注意这个名字是固定的】

       比如配置发短信，那么在main.py就需①配置celery对象、②加载config配置文件、③注册异步任务和config.py配置Redis服务器位置。使用起来还是比较容易的。