从异步生成器中获取可迭代生成器

Question

我有一个异步生成器，我试图将它传递到keras fit_generator中，但是异步生成器返回一个对象，而不是生成器。

我试过谷歌搜索，但我还没有找到解决方案。这似乎是一个非常具体的问题。

Answer 1

asyncio的意图是将异步生成器从规则生成器中分离出来，读取应答这里。

但是，如果您决定不在其他地方并发运行异步生成器，并且您唯一的目的是避免RAM溢出，则可以将异步生成器转换为常规的一个手动迭代异步生成器，并等待每个新项：

import asyncio


async def my_gen():
    for i in range(10):
        yield i
        await asyncio.sleep(0.5)


def to_sync_generator(ait):
    loop = asyncio.get_event_loop()
    try:
        while True:
            try:
                coro = ait.__anext__()
                res = loop.run_until_complete(coro)
            except StopAsyncIteration:
                return
            else:
                yield res
    finally:
        coro = loop.shutdown_asyncgens()
        loop.run_until_complete(coro)


# Check:

if __name__ == '__main__':
    for i in to_sync_generator(my_gen()):
        print(i)

P.S.没有对代码进行太多的测试。