Pyd*_* UA 3 python django asynchronous django-3.1
从 3.1(目前是测试版)开始,Django 支持异步视图
async def myview(request):
users = User.objects.all()
Run Code Online (Sandbox Code Playgroud)
这个例子不起作用 - 因为 ORM 还没有准备好异步
那么目前的解决方法是什么?
您不能只将 sync_to_async 与 queryset 一起使用 - 因为它们没有被评估:
from asgiref.sync import sync_to_async
async def myview(request):
users = await sync_to_async(User.objects.all)()
Run Code Online (Sandbox Code Playgroud)
所以唯一的方法是在sync_to_async中评估查询集:
async def myview(request):
users = await sync_to_async(lambda: list(User.objects.all()))()
Run Code Online (Sandbox Code Playgroud)
看起来很丑
关于如何让它更好的任何想法?
小智 9
有一个常见的 GOTCHA:Django 查询集是惰性求值的(数据库查询仅在您开始迭代时发生):
所以相反 - 使用评估(带列表):
from asgiref.sync import sync_to_async
async def myview(request):
users = await sync_to_async(list)(User.objects.all())
Run Code Online (Sandbox Code Playgroud)
从Django 4.1开始,async for所有查询集都支持:
async def myview(request):
users = [user async for user in User.objects.all()]
Run Code Online (Sandbox Code Playgroud)
更多信息:链接