在Django的View中使用asyncio的方法

更新時(shí)間：2019年07月12日 08:31:47 作者：棲遲於一丘

這篇文章主要介紹了在Django的View中使用asyncio的方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

起步

Django 是個(gè)同步框架，本文并不是讓 Django 變成異步框架。而是對于在一個(gè) view 中需要請求多次 http api 的場景。

一個(gè)簡單的例子

例子來源于 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)在可以對于上面的例子做一個(gè)擴(kuò)充，讓它能更合理被使用。

對于使用 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 對象，因此可以通過 fut.result() 獲得任務(wù)的運(yùn)行結(jié)果。這個(gè)方式也可以處理API請求中的數(shù)據(jù)依賴的先后順序。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: