情景:
用戶發起request,並等待response返回。在本些views中,可能需要執行一段耗時的程序,那么用戶就會等待很長時間,
造成不好的用戶體驗,比如發送郵件、手機驗證碼等。
使用celery后,情況就不一樣了。解決:將耗時的程序放到celery中執行。
celery官方網站http://www.celeryproject.org/
celery中文文檔http://docs.jinkan.org/docs/celery/
celery名詞:
- 任務task:就是一個Python函數。
- 隊列queue:將需要執行的任務加入到隊列中。
- 工人worker:在一個新進程中,負責執行隊列中的任務。
- 代理人broker:負責調度,在布置環境中使用redis。
celery解決的問題:
當瀏覽器訪問的頁面當中有耗時的操作時,訪問的客戶體驗不好使用celery可以將耗時的操作創建一個新的進程處理
執行流程:
產生任務task會放到queue隊列中,代理人broker會通知空閑的worker工人隊列中有任務,worker工人就會去隊列中把任務task取出來執行。
每一個worker就是一個工作的進程。
配置流程:
安裝包:
celery==3.1.25 celery-with-redis==3.0 django-celery==3.1.17
1.在test6/settings.py中安裝。
INSTALLED_APPS = ( ... 'djcelery', }
2.在test6/settings.py文件中配置代理和任務模塊。
# 配置celery import djcelery djcelery.setup_loader() # 傳遞消息時使用的redis 的ip 端口 數據庫名 BROKER_URL = 'redis://127.0.0.1:6379/2' # 在booktest文件夾里面的task模塊的內容--所以需要創建模塊 CELERY_IMPORTS = ('booktest.task')
3.在booktest/目錄下創建task.py文件。
import time from django.core.mail import send_mail from celery import task from django.conf import settings @task def sayhello(): print('hello ...') time.sleep(2) print('world ...')
4.打開booktest/views.py文件,修改sayhello視圖如下:
from booktest import task def sayhello(request): """""" # print('hello') # time.sleep(5) # print('work') task.sayhello.delay() # 將任務教給celery執行 return HttpResponse('ok')
5.執行遷移生成celery需要的數據表。
python manage.py migrate
6.啟動Redis,如果已經啟動則不需要啟動。
sudo service redis start
11)啟動worker。
python manage.py celery worker --loglevel=info
12)通過瀏覽器訪問sayhello視圖函數即可
總結:
將一個認為函數操作的功能定義到模塊tast當中,然后在視圖函數當中執行:tast.tast當中的函數名.delay()即可啟動celery執行