Django完成异步工具——celery
2017-10-28 11:28
253 查看
情景:用户发起request,并等待response返回。在本些views中,可能需要执行一段耗时的程序,那么用户就会等待很长时间,造成不好的用户体验,比如发送邮件、手机验证码等
使用celery后,情况就不一样了
解决:将耗时的程序放到celery中执行
点击查看celery官方网站
点击查看celery中文文档
celery名词
任务task:就是一个Python函数
队列queue:将需要执行的任务加入到队列中
工人worker:在一个新进程中,负责执行队列中的任务
代理人broker:负责调度,在布置环境中使用redis
安装包
在booktest/urls.py中配置
启动服务器,在浏览器中输入如下网址
在终端中效果如下图,两次输出之间等待一段时间才会返回结果
在test6/settings.py中安装
在test6/settings.py文件中配置代理和任务模块
在booktest/目录下创建task.py文件
打开booktest/views.py文件,修改sayhello视图如下
执行迁移生成celery需要的数据表
生成表如下
启动Redis,如果已经启动则不需要启动
启动worker
启动成功后提示如下图
打开新终端,进入虚拟环境,启动服务器,刷新浏览器
在旧终端中两个输出间仍有时间间隔
运行完成后如下图,注意两个终端中的时间,服务器的响应是立即返回的
打开booktest/task.py文件,修改为发送邮件的代码,就可以实现无阻塞发送邮件
使用celery后,情况就不一样了
解决:将耗时的程序放到celery中执行
点击查看celery官方网站
点击查看celery中文文档
celery名词
任务task:就是一个Python函数
队列queue:将需要执行的任务加入到队列中
工人worker:在一个新进程中,负责执行队列中的任务
代理人broker:负责调度,在布置环境中使用redis
安装包
celery==3.1.25 celery-with-redis==3.0 django-celery==3.1.17
示例
在booktest/views.py文件中创建视图sayhelloimport time ... def sayhello(request): print('hello ...') time.sleep(2) print('world ...') return HttpResponse("hello world")
在booktest/urls.py中配置
url(r'^sayhello$',views.sayhello),
启动服务器,在浏览器中输入如下网址
http://127.0.0.1:8000/sayhello/
在终端中效果如下图,两次输出之间等待一段时间才会返回结果
在test6/settings.py中安装
INSTALLED_APPS = ( ... 'djcelery', }
在test6/settings.py文件中配置代理和任务模块
import djcelery djcelery.setup_loader() BROKER_URL = 'redis://127.0.0.1:6379/2' CELERY_IMPORTS = ('booktest.task')
在booktest/目录下创建task.py文件
import time from celery import task @task def sayhello(): print('hello ...') time.sleep(2) print('world ...')
打开booktest/views.py文件,修改sayhello视图如下
from . import task ... def sayhello(request): # print('hello ...') # time.sleep(2) # print('world ...') task.sayhello.delay() return HttpResponse("hello world")
执行迁移生成celery需要的数据表
python manage.py migrate
生成表如下
启动Redis,如果已经启动则不需要启动
sudo service redis start
启动worker
python manage.py celery worker --loglevel=info
启动成功后提示如下图
打开新终端,进入虚拟环境,启动服务器,刷新浏览器
在旧终端中两个输出间仍有时间间隔
运行完成后如下图,注意两个终端中的时间,服务器的响应是立即返回的
打开booktest/task.py文件,修改为发送邮件的代码,就可以实现无阻塞发送邮件
#coding=utf-8 from django.conf import settings from django.core.mail import send_mail from celery import task @task def sayhello(): msg='<a href="http://www.itcast.cn/subject/pythonzly/index.shtml" target="_blank">点击激活</a>' send_mail('注册激活','',settings.EMAIL_FROM, ['xinlan88@163.com'], html_message=msg)
相关文章推荐
- Django中如何使用django-celery完成异步任务1(转)
- Django中如何使用django-celery完成异步任务
- Django中使用django-celery完成异步任务(1)
- Django中如何使用django-celery完成异步任务 (1)
- Django中如何使用django-celery完成异步任务 (2)
- Django异步工具Celery安装
- Django中使用celery完成异步任务的示例代码
- jango中如何使用django-celery完成异步任务 (1)
- Django中使用celery完成异步任务
- Django中如何使用django-celery完成异步任务2(转)
- django celery异步框架
- 异步任务利器Celery(二)在django项目中使用Celery
- 异步任务队列Celery在Django中的使用
- django下使用celery进行异步任务
- celery异步执行任务在Django中的应用实例
- Django基于celery的异步任务实现
- 使用 django+celery+RabbitMQ 实现异步执行
- 异步任务队列Celery在Django中的使用
- Django使用Celery异步任务队列
- Django使用Celery异步任务队列的使用