• 情景：用戶發起request，并等待response返回。在本些views中，可能需要執行一段耗時的程序，那么用戶就會等待很長時間，造成不好的用戶體驗，比如發送郵件、手機驗證碼等
• 使用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文件中創建視圖sayhello

import 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完成异步工具——celery的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。