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

2022-03-25 00:00:00 python python-asyncio

问题描述

在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功能都是毫无意义的。

我是否遗漏了什么?

谢谢!


解决方案

所以,正如@Bosnjak所说,您可以将异步用于:

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

但是如果您想手动迭代,您可以简单地写成:

it = async_iterator()
await it.__anext__()

但我不建议这样做。

我认为如果您要将某个东西称为Iterator,那是因为它具有完全相同的接口,所以我可以只编写异步迭代器,并在严重依赖Next()调用的框架上使用

不,实际上是不一样的。常规同步迭代器和异步迭代器是不同的。原因很少:

  1. Python协程在内部构建在生成器之上
  2. 根据Python禅宗的说法,显式要好于隐式。这样您就可以实际看到代码可以挂起的位置。

这就是不能将iternext与异步迭代器一起使用的原因。而且您不能在需要同步迭代器的框架中使用它们。因此,如果要使代码异步,还必须使用异步框架。Here为数不多。

此外,我还想说几句关于迭代器和生成器的内容。迭代器是具有__iter____next__方法的特殊对象。而生成器是包含yield表达式的特殊函数。每个生成器都是迭代器,但反之亦然。异步迭代器和生成器也可以接受同样的情况。是的,从python3.6开始,您就可以编写异步生成器了!

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

有关更多详细信息,请阅读PEP 525

相关文章