起步
Django 是个同步框架，本文并不是 让 Django 变成异步框架。而是对于在一个 view 中需要请求多次 http api 的场景。
一个简单的例子
例子来源于 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)
这个例子中，把两个任务放到 asyncio 的 loop 运行，等到两个任务都完成了再返回 HttpResponse 。
在 Django 的 View 中使用 asyncio
现在可以对于上面的例子做一个扩充，让它能更合理被使用。
对于使用 asyncio ，我们通常会创建个子线程专门处理异步任务。
在 wsgi.py 中创建一个单独线程并运行事件循环：
import asyncio import threading ... application = get_wsgi_application() # 创建子线程并等待 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 中动态向里面添加任务了：
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() 获得任务的运行结果。 这个方式也可以处理API请求中的数据依赖的先后顺序。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。