在Django的View中使用asyncio的方法
起步
Django 是個(gè)同步框架,本文并不是 讓 Django 變成異步框架。而是對(duì)于在一個(gè) view 中需要請(qǐng)求多次 http api 的場(chǎng)景。
一個(gè)簡(jiǎn)單的例子
例子來源于 https://stackoverflow.com/questions/44667242/python-asyncio-in-django-view :
def djangoview(request, language1, language2): async def main(language1, language2): loop = asyncio.get_event_loop() r = sr.Recognizer() with sr.AudioFile(path.join(os.getcwd(), "audio.wav")) as source: audio = r.record(source) def reco_ibm(lang): return(r.recognize_ibm(audio, key, secret language=lang, show_all=True)) future1 = loop.run_in_executor(None, reco_ibm, str(language1)) future2 = loop.run_in_executor(None, reco_ibm, str(language2)) response1 = await future1 response2 = await future2 loop = asyncio.new_event_loop() asyncio.set_event_loop(loop) loop = asyncio.get_event_loop() loop.run_until_complete(main(language1, language2)) loop.close() return(HttpResponse)
這個(gè)例子中,把兩個(gè)任務(wù)放到 asyncio 的 loop 運(yùn)行,等到兩個(gè)任務(wù)都完成了再返回 HttpResponse 。
在 Django 的 View 中使用 asyncio
現(xiàn)在可以對(duì)于上面的例子做一個(gè)擴(kuò)充,讓它能更合理被使用。
對(duì)于使用 asyncio ,我們通常會(huì)創(chuàng)建個(gè)子線程專門處理異步任務(wù)。
在 wsgi.py 中創(chuàng)建一個(gè)單獨(dú)線程并運(yùn)行事件循環(huán):
import asyncio import threading ... application = get_wsgi_application() # 創(chuàng)建子線程并等待 thread_loop = asyncio.new_event_loop() def start_loop(loop): asyncio.set_event_loop(loop) loop.run_forever() t = threading.Thread(target=start_loop, args=(thread_loop,), daemon=True) t.start()
然后就是在 view 中動(dòng)態(tài)向里面添加任務(wù)了:
async def fetch(url): async with aiohttp.ClientSession() as session: async with session.get(url) as response: text = await response.text() return text def hello(request): from yeezy_bot.wsgi import thread_loop fut1 = asyncio.run_coroutine_threadsafe(fetch(url1), thread_loop) fut2 = asyncio.run_coroutine_threadsafe(fetch(url2), thread_loop) ret1 = fut1.result() ret2 = fut2.result() return HttpResponse('')
asyncio.run_coroutine_threadsafe() 返回是 Future 對(duì)象,因此可以通過 fut.result() 獲得任務(wù)的運(yùn)行結(jié)果。 這個(gè)方式也可以處理API請(qǐng)求中的數(shù)據(jù)依賴的先后順序。
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 詳解多線程Django程序耗盡數(shù)據(jù)庫(kù)連接的問題
- Django生成數(shù)據(jù)庫(kù)及添加用戶報(bào)錯(cuò)解決方案
- python自動(dòng)化測(cè)試三部曲之request+django實(shí)現(xiàn)接口測(cè)試
- 社區(qū)版pycharm創(chuàng)建django項(xiàng)目的方法(pycharm的newproject左側(cè)沒有項(xiàng)目選項(xiàng))
- Django連接本地mysql數(shù)據(jù)庫(kù)(pycharm)的步驟
- 記一次Django響應(yīng)超慢的解決過程
- Django實(shí)現(xiàn)文章詳情頁(yè)面跳轉(zhuǎn)代碼實(shí)例
- Django如何使用asyncio協(xié)程和ThreadPoolExecutor多線程
相關(guān)文章
Python畫柱狀統(tǒng)計(jì)圖操作示例【基于matplotlib庫(kù)】
這篇文章主要介紹了Python畫柱狀統(tǒng)計(jì)圖操作,結(jié)合實(shí)例形式分析了Python基于matplotlib庫(kù)實(shí)現(xiàn)圖形繪制的相關(guān)操作技巧,需要的朋友可以參考下2018-07-07Python 數(shù)據(jù)分析之Beautiful Soup 提取頁(yè)面信息
Beautiful Soup 提供一些簡(jiǎn)單的、python 式的函數(shù)用來處理導(dǎo)航、搜索、修改分析樹等功能。它是一個(gè)工具箱,通過解析文檔為用戶提供需要抓取的數(shù)據(jù),因?yàn)楹?jiǎn)單,所以不需要多少代碼就可以寫出一個(gè)完整的應(yīng)用程序2021-10-10基于python3 的百度圖片下載器的實(shí)現(xiàn)代碼
這篇文章主要介紹了基于python3 的百度圖片下載器的實(shí)現(xiàn)代碼,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-11-11Python動(dòng)態(tài)賦值的陷阱知識(shí)點(diǎn)總結(jié)
在本文中我們給大家整理了關(guān)于Python動(dòng)態(tài)賦值的陷阱的相關(guān)知識(shí)點(diǎn)內(nèi)容,需要的朋友們學(xué)習(xí)下。2019-03-03pytorch geometric的GNN、GCN的節(jié)點(diǎn)分類方式
這篇文章主要介紹了pytorch geometric的GNN、GCN的節(jié)點(diǎn)分類方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-12-12Python測(cè)試WebService接口的實(shí)現(xiàn)示例
webService接口是走soap協(xié)議通過http傳輸,請(qǐng)求報(bào)文和返回報(bào)文都是xml格式的,本文主要介紹了Python測(cè)試WebService接口,具有一定的參考價(jià)值,感興趣的可以了解一下2024-03-03Keras使用tensorboard顯示訓(xùn)練過程的實(shí)例
今天小編就為大家分享一篇Keras使用tensorboard顯示訓(xùn)練過程的實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-02-02分享15?個(gè)python中的?Scikit-Learn?技能
這篇文章主要介紹了分享15?個(gè)python中的?Scikit-Learn?技能,Scikit-Learn?是一個(gè)非常棒的?python?庫(kù),用于實(shí)現(xiàn)機(jī)器學(xué)習(xí)模型和統(tǒng)計(jì)建模,有降維、特征選擇、特征提取、集成技術(shù)等特征,下文相關(guān)內(nèi)容需要的朋友可以參考一下2022-03-03