微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

异步生成器不是迭代器吗?

如何解决异步生成器不是迭代器吗?

因此,正如@bosnjak所说,您可以将async用于:

async for ITEM in A_ITER:
    BLOCK1
else: # optional
    BLOCK2

但是,如果您想手动进行迭代,则只需编写以下代码

it = async_iterator()
await it.__anext__()

但是我不建议这样做。

我认为如果您要调用Iterator的原因是因为它具有完全相同的接口,所以我可以编写异步迭代器并在高度依赖next()调用的框架上使用

不,有点不一样。常规同步迭代器与异步迭代器之间有区别。并没有什么理由:

  1. Python协程内部构建在生成器之上
  2. 根据python的Zen,显式比隐式更好。这样您就可以实际看到可以在何处暂停代码

这就是为什么它是不可能使用iternext异步迭代器。而且,您不能将它们与需要同步迭代器的框架一起使用。因此,如果要使代码异步,则还必须使用异步框架。这里有几个。

另外,我想谈一谈迭代器和生成器。Iterator是具有__iter____next__方法的特殊对象。而generator是包含yield表达式的特殊函数。 。异步迭代器和生成器可以接受相同的东西。是的,由于python 3.6,您可以编写异步生成器!

async def ticker(delay, to):
    for i in range(to):
        yield i
        await asyncio.sleep(delay)

您可以阅读PEP 525了解更多详细信息

解决方法

在Python中,您可以编写一个可迭代的生成器,例如:

def generate(count):
    for x in range(count):
        yield x

# as an iterator you can apply the function next() to get the values.
it = generate(10)
r0 = next(it)
r1 = next(it) ...

尝试使用异步迭代器时,您会收到“异步产生收益”错误。建议的解决方案是实现自己的生成器:

class async_generator:
    def __aiter__(self):
        return self

    async def __anext__(self):
        await asyncio.sleep()
        return random.randint(0,10)

# But when you try to get the next element
it = async_generator(10)
r0 = next(it)

你得到错误 "async_generator" object is not an iterator

我认为,如果要调用Iterator就是因为它具有完全相同的接口,所以我可以编写异步迭代器,并在高度依赖next()调用的框架上使用。如果您需要重写整个代码以使用异步功能,那么任何新的Python功能都是毫无意义的。

我想念什么吗?

谢谢!

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。