确保asyncio.create_task()在async with语句块中被调用,以保证它的异步运行。 示例代码如下:
async def my_view(request): async with request.app['db'].acquire() as conn: # 异步执行数据库查询 task = asyncio.create_task(conn.execute('SELECT * FROM my_table')) # 其他异步操作 result = await task # 处理结果 return web.Response(text=result)