科技 · 实用指南
Jupyter 或 FastAPI 中 asyncio.run() 失败？修正事件循环所有权，而不是掩盖症状
这个异常在提示所有权冲突：当前线程已有组件运行事件循环。应在该所有者内部 await，或只在真正的同步入口创建一个循环。
Python 会在同一线程启动第二个事件循环前抛出此错误。这是刻意的保护：asyncio.run() 负责循环创建、执行、异步生成器清理、执行器关闭和循环关闭；Notebook 内核或 Web 服务器已经承担这些职责。
安全修复取决于调用者。Notebook 单元或异步路由应直接 await 协程；独立脚本只在进程边界保留一个 asyncio.run()；可复用库应提供异步 API，并让同步包装器在已有循环时明确失败。
修改前先确认循环所有者
记录线程、asyncio.get_running_loop() 的结果和宿主。Notebook 单元、异步处理器、生命周期钩子与 CLI 入口的契约不同。
不要对未创建的循环调用 stop()、close()、run_until_complete() 或 asyncio.run()；错误通常表示边界放错。
在 Notebook 与异步框架内 await
Jupyter 中把 result = asyncio.run(work()) 改成 result = await work()。FastAPI 等框架应由异步调用者在宿主循环中 await。
长期 Task 要绑定宿主生命周期并定义启动、取消和关闭，不能为消除异常而放任后台任务。
独立脚本只保留一个顶层所有者
真正入口可以保留 asyncio.run(main())；需要共享循环和上下文时，可由一个 asyncio.Runner 依次执行。
不要在辅助函数中散布 runner，内部实现应保持可 await。
分离库的异步与同步契约
主要操作实现为 async def fetch_async(...)。同步 fetch(...) 只有在当前线程无运行循环时才调用 asyncio.run()，否则提示 await 异步 API。
在创建协程前检查循环；若已创建未使用协程，应明确关闭，避免第二个警告掩盖所有权错误。
只在真实线程边界跨线程提交
专用循环位于另一 OS 线程时，asyncio.run_coroutine_threadsafe(coro, loop) 可返回 concurrent Future；超时、取消和关闭仍须定义。
在循环线程里阻塞 future.result() 可能死锁，线程身份和循环生命周期必须写入设计。
把循环补丁限制为兼容层
旧工具若必须用嵌套补丁，应限制范围和版本并单独测试，不能成为库的进程级默认行为。
返回值成功不代表循环健康；上下文错误、待处理任务或后续单元失败仍可能存在。
用测试证明边界已修复
在活动循环中测试异步 API，在普通线程测试同步包装器；验证返回值、异常、取消、contextvars、重复调用和 asyncio.all_tasks()。
负面测试应确保活动循环内调用同步包装器立即失败，并明确提示 await 异步 API。
