Python-在特定类的非异步初始化中等待异步IO任务

Question

我正在用一个\uuuu init\uuu函数和另一个函数创建一个python类，比如说f。\uuuu init\uuu函数不是异步的，但另一个函数是异步的。现在，我正在尝试执行\uuuu init\uuuu中的另一个函数。

我调查过的事情：

• 我发现一些代码带有get\u event\u loop/get\u running\u loop并一直运行到\u完成，但这会导致运行时错误，即事件循环已经在运行。
• 我看过关于nest_asyncio的评论，但它似乎有点脏。
• 此外，我还使用create_task、gather和wait尝试了几种方法。但在这种情况下，代码不会等待任务完全执行。
• 我可以先调用构造函数，然后用wait调用第二个函数来拆分它，但是我希望在构造函数中调用第二个函数

请注意，这在Azure Function应用程序上下文中。

一些示例代码：

import asyncio
class myClass(object):
    def __init__(self, arg1, arg2):
        self.arg1 = arg1
        self.arg2 = arg2
        #asyncio.create_task(self.f('abc'))
        self.loop = asyncio.get_event_loop()
        self.loop.run_until_complete(self.f('abc'))
    
    async def f(self, x):
        await asyncio.sleep(1)
        self.x = x
        
if __name__ == '__main__':
    cl = myClass(1,2)
    print(cl.x)

这在这个简单的上下文中运行良好，但在更复杂的上下文中就不行了，例如在Azure Functions中，我试图在函数中使用myClass，然后希望使用其"x"属性。

Answer 1

\uuuu init\uuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuu。

在\uuuu init\uuuu中启动一些异步任务，并提供第二种方法来等待它们：

import asyncio
class myClass(object):
    """ must await on obj.finish_init() before the object can be used """
    def __init__(self, arg1, arg2):
        self.arg1 = arg1
        self.arg2 = arg2
        self._finish_init_promise = asyncio.create_task(self.f('abc'))
        #self.loop = asyncio.get_event_loop()
        #self.loop.run_until_complete(self.f('abc'))
    async def finish_init(self):
        await self._finish_init_promise
        return self
    
    async def f(self, x):
        await asyncio.sleep(1)
        self.x = x
async def main():
    cl = await myClass(1,2).finish_init()
    print(cl.x)
if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(main())

但是，构造一个不完整的对象可能是不可取的（您可能需要一个布尔值来指示它是否准备就绪），因此另一种方法是提供一个异步classmethod来准备数据，然后将该数据传递给构造函数：

import asyncio
class myClass(object):
    def __init__(self, arg1, arg2, x):
        self.arg1 = arg1
        self.arg2 = arg2
        self.x = x
    @classmethod
    async def make(cls, arg1, arg2):
        x = cls.obvious_example_will_be_replaced_with_real_use_case('abc')
        return cls(arg1, arg2, x)
    @staticmethod
    async def obvious_example_will_be_replaced_with_real_use_case(x):
        await asyncio.sleep(1)
        return x
async def main():
    cl = await myClass.make(1,2)
    print(cl.x)
if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(main())