Django異步任務(wù)之Celery的基本使用
Celery
許多Django應(yīng)用需要執(zhí)行異步任務(wù), 以便不耽誤http request的執(zhí)行. 我們也可以選擇許多方法來完成異步任務(wù), 使用Celery是一個(gè)比較好的選擇, 因?yàn)镃elery有著大量的社區(qū)支持, 能夠完美的擴(kuò)展, 和Django結(jié)合的也很好. Celery不僅能在Django中使用, 還能在其他地方被大量的使用. 因此一旦學(xué)會使用Celery, 我們可以很方便的在其他項(xiàng)目中使用它.
celery 是一個(gè)用于實(shí)現(xiàn)異步任務(wù)的庫, 在很多項(xiàng)目中都使用它, 它和 django 融合使用很完美. 使用 celery 可以在實(shí)現(xiàn) http request請求返回 view 前做一些我們想做的而且耗時(shí)的事情而不會讓用戶等待太久
環(huán)境
django 版本 == 1.11.6
celery 版本 == 3.1.25
安裝
pip install django-celery pip install celery
首先需要將 celery 添加到 django 項(xiàng)目的 settings 里， celery 任務(wù)和 django 需要一個(gè) 中間人(broker),，這里使用的是 django 自帶的 broker， 但在生產(chǎn)中一般使用 rabbitmq， Redis 等，在 INSTALLED_APP 中需要添加 djcelery 和 kombu.transport.django, 還有 app 應(yīng)用。
- project/project/ settings.py：
import djcelery djcelery.setup_loader() BROKER_URL = 'django://' INSTALLED_APP = ( ... 'app' 'djcelery', 'kombu.transport.django', )
新建 celery.py 創(chuàng)建一個(gè) celery 應(yīng)用，并添加以下內(nèi)容
- project/project/ celery.py：
# 相對路徑導(dǎo)入, 防止導(dǎo)入 celery 時(shí)沖突
from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings
# 讓 celery 能找到 django 項(xiàng)目
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
# 創(chuàng)建一個(gè) celery 應(yīng)用
app = Celery('project')
# 導(dǎo)入配置
app.config_from_object('django.conf:settings')
# 自動發(fā)現(xiàn) task
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
- project/project/ __init__.py：
from __future__ import absolute_import # This will make sure the app is always imported when # Django starts so that shared_task will use this app. from .celery import app as celery_app
在 django app 中添加任務(wù)，文件名必須是 tasks.py， 在普通 python 函數(shù)前加一個(gè) @task() 裝飾器就變成了 celery task
-project/app/ tasks.py：
from celery.task import task from time import sleep @task() def helloWorld(): print 'helloWorld' sleep(10) print 'helloWorld' return 'helloCelery'
這樣，一個(gè)任務(wù)就創(chuàng)建成功了，只剩下在 view 中調(diào)用了
-project/app view.py：
from tasks.py import helloWorld
def home():
helloWorld.delay()
return HttpResponse('helloCelery')
最后
python manage.py migrate
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對腳本之家的支持。
相關(guān)文章
Python3實(shí)現(xiàn)將文件歸檔到zip文件及從zip文件中讀取數(shù)據(jù)的方法
這篇文章主要介紹了Python3實(shí)現(xiàn)將文件歸檔到zip文件及從zip文件中讀取數(shù)據(jù)的方法,涉及Python針對zip文件操作的相關(guān)技巧,需要的朋友可以參考下2015-05-05
opencv+python識別七段數(shù)碼顯示器的數(shù)字(數(shù)字識別)
本文主要介紹了opencv+python識別七段數(shù)碼顯示器的數(shù)字(數(shù)字識別)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
python通過wxPython打開一個(gè)音頻文件并播放的方法
這篇文章主要介紹了python通過wxPython打開一個(gè)音頻文件并播放的方法,實(shí)例分析了wxPython操作音頻文件的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03
Python imutils 填充圖片周邊為黑色的實(shí)現(xiàn)
今天小編就為大家分享一篇Python imutils 填充圖片周邊為黑色的實(shí)現(xiàn)，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-01-01
這篇文章主要介紹了python3如何使用Requests測試帶簽名的接口，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-02-02
Python進(jìn)行指數(shù)和對數(shù)曲線擬合詳解
曲線擬合是構(gòu)造曲線或數(shù)學(xué)函數(shù)的過程,其具有對一系列數(shù)據(jù)點(diǎn)的最佳擬合,可能受到約束,本文主要介紹了如何使用Python實(shí)現(xiàn)指數(shù)和對數(shù)曲線擬合,需要的可以參考下2024-04-04
HTTPX是Python3的功能齊全的HTTP客戶端，它提供同步和異步API，本文主要介紹了python-httpx的具體使用，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
python簡單實(shí)現(xiàn)旋轉(zhuǎn)圖片的方法
這篇文章主要介紹了python簡單實(shí)現(xiàn)旋轉(zhuǎn)圖片的方法,涉及Python中image模塊使用技巧,需要的朋友可以參考下2015-05-05
Python實(shí)現(xiàn)基于標(biāo)記的分水嶺分割算法
分水嶺技術(shù)是一種眾所周知的分割算法，特別適用于提取圖片中的相鄰或重疊對象。本文將用Python實(shí)現(xiàn)基于標(biāo)記的分水嶺分割算法，感興趣的可以了解一下2022-07-07
Python 是一種流行的編程語言,具有豐富的第三方庫和強(qiáng)大的自動化能力,適用于許多不同的領(lǐng)域,許多運(yùn)維工程師會使用 Python 腳本來自動化運(yùn)維任務(wù),所以本文為大家整理了5個(gè)Python自動化運(yùn)維腳本,有需要的可以參考下2023-08-08