有这样一个协程
async def function(**kwargs): session = aiohttp.ClientSession() response = await session.request(**kwargs) pass 如果使用 asyncio.run(function(arg=bala))和 new_event_loop 会出现
RuntimeError: Timeout context manager should be used inside a task 使用
loop = asyncio.get_event_loop() loop.run_until_complete(function(arg=bala)) loop.close() 不会出现上下文管理的问题 这两者的区别在哪里,翻了半天官方文档和 csdn 的转载文实在无法理解 TAT
asyncio.run:
This function cannot be called when another asyncio event loop is running in the same thread.
你这个是旧版的 aiohttp 吧，新版的 async_timeout 不会出现这个问题。
看样子应该是 session 在类实例化时在普通函数中创建的产生的问题，一个包含异步函数的对象在只能在 async 函数中创建，包括自己封装的类
def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
raise RuntimeError(
“Timeout context manager should be used ” “inside a task”
)
老问题了, 所以我现在用到 aiohttp 尽量不用 asyncio.run, 因为它一定新建一个 loop, 然而 Session 的默认 Timeout 对象却是在协程外面初始化的, 导致两个循环不一致, 见下面源码
https://github.com/aio-libs/aiohttp/blob/742a8b6d09b2623670ddede838c913d2a8a4d89e/aiohttp/client.py#L161
据说 aiohttp 4.0 以后会好, 但是 4.0 一直发不出来
想解决的话, 简单的就是暂时别用 asyncio.run. 或者在协程函数里 import 它, 或者手动指定 Timeout 试试
解决办法就是让整个程序的入口是一个 async 函数，在 async 函数中配置程序，新建各种实例，启动应用。在__main__里面 asyncio.run(entrypoint())就行。然后在任何其他地方都不要 new_event_loop 或者 asyncio.run
如果要执行一个 coroutine 但是不等待结束，可以 asyncio.ensure_future 或者 3.7 以上的新 API asyncio.create_task，这两个函数都是在 get_event_loop()返回的 loop 上执行对应的函数，会返回一个 Task
如果要在一个 coroutine 中执行一个 coroutine 并且等待结束，那就直接 await 。
如果要执行一个同步过程，可以用 run_in_executor，返回一个 Future
你要做的是, 首先保证整个程序只留有一个事件循环(因为多个也没有意义, await 不是阻塞, 是等待), 然后在里面传递 session 对象就是合法的了
然后你说的阻塞, 协程实际上是非阻塞的设计, 你的阻塞可能是 await 关键词, 那个是等待不算阻塞. 所以你如果想并发开始多个任务, 可以把 “协程函数” (async def 声明的)执行获得的 “协程对象” 创建为 Task, 它就会开始执行但是又不会阻塞, 创建 Task 的方式有 asyncio.ensure_future(some_coro) 或者 asyncio.create_task(coro), 后者是 3.7 以后新增的