日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Django中celery配置总结

發布時間:2023/12/20 编程问答 31 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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文件中配置代理和任務模塊。

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執行

總結

以上是生活随笔為你收集整理的Django中celery配置总结的全部內容,希望文章能夠幫你解決所遇到的問題。

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