Python类非异步__init__如何调用async方法 适配Azure Function环境
问题核心原因
Python 原生不支持异步 __init__ 方法,Azure Function 运行时本身已持有一个正在运行的事件循环处理请求,你之前尝试的方案存在以下问题:
- 调用
run_until_complete:无法在已运行的事件循环上执行,直接触发RuntimeError - 提交
create_task/gather等任务:同步的__init__不会等待异步任务执行完成,返回实例时属性还未赋值 nest_asyncio属于猴子补丁,会修改 asyncio 原生逻辑,确实不符合生产环境规范,不建议在 Azure Function 这类托管环境使用- 拆分构造+手动 await 异步初始化的方案本身逻辑成立,但是可以封装为更易用的形式避免漏调用
推荐方案:异步工厂方法(最规范,适配 Azure Function 环境)
这是 Python 生态处理异步初始化的标准实践,完全规避在同步 __init__ 中调用异步逻辑的问题,既保证异步初始化逻辑在实例返回前执行完成,也不会和 Azure Function 已有事件循环冲突。
import asyncio class myClass(object): def __init__(self, arg1, arg2): self.arg1 = arg1 self.arg2 = arg2 async def __async_init__(self): # 所有异步初始化逻辑都放在这里 await self.f('abc') async def f(self, x): await asyncio.sleep(1) self.x = x @classmethod async def create(cls, arg1, arg2): # 先完成同步实例化 instance = cls(arg1, arg2) # 等待异步初始化全部执行完成再返回实例 await instance.__async_init__() return instance # Azure Function 本身是异步运行环境,直接 await 即可获取完成初始化的实例 async def demo_call(): cl = await myClass.create(1,2) print(cl.x) # 可以正常获取到x属性 if __name__ == '__main__': asyncio.run(demo_call())
内容的提问来源于stack exchange,提问作者c4-wv
相关产品推荐
相关产品推荐

