情景:
用戶發起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執行


