情景:
用戶發起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文件中配置代理和任務模塊。
import djcelerydjcelery.setup_loader()BROKER_URL = 'redis://127.0.0.1:6379/2'CELERY_IMPORTS = ('booktest.task')
3.在booktest/目錄下創建task.py文件。
import timefrom django.core.mail import send_mailfrom celery import taskfrom django.conf import settings@taskdef sayhello():print('hello ...')time.sleep(2)print('world ...')
4.打開booktest/views.py文件,修改sayhello視圖如下:
from booktest import taskdef sayhello(request):task.sayhello.delay()return HttpResponse('ok')
5.執行遷移生成celery需要的數據表。
6.啟動Redis,如果已經啟動則不需要啟動。
啟動worker。python manage.py celery worker --loglevel=info通過瀏覽器訪問sayhello視圖函數即可
總結:將一個認為函數操作的功能定義到模塊tast當中,然后在視圖函數當中執行:tast.tast當中的函數名.delay()即可啟動celery執行