Django中celery配置總結


情景:

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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM