async for 要求对象实现 __aiter__ 而非 __iter__;同步生成器无 __aiter__,故不可用;需自定义类分别实现 __iter__(yield)和 __aiter__(返回 async def 函数调用结果),且不可混用 yield 与 await。

async for 要求对象实现 __aiter__,不是 __iter__
同步生成器函数(用 yield)返回的是 generator 对象,它有 __iter__ 但没有 __aiter__,所以不能用于 async for。强行用会报错:TypeError: 'generator' object is not async iterable。关键不是“加个 async 就行”,而是得返回一个真正支持异步迭代协议的对象——即实现了 __aiter__ 且其返回值有 __anext__ 方法的实例。
用类封装:同时实现 __iter__ 和 __aiter__
最稳妥的方式是写一个自定义类,在初始化时接收原始数据或参数,然后在 __iter__ 中用普通 yield,在 __aiter__ 中返回一个异步生成器(async def + yield)。注意:不能让 __aiter__ 直接 return self,除非你同时给它加上 __anext__;更推荐让它返回 async_generator 实例。
示例结构:
class DualIterable:
def __init__(self, items):
self.items = items
def __iter__(self):
for x in self.items:
yield x * 2
def __aiter__(self):
return self._aiter_impl()
async def _aiter_impl(self):
for x in self.items:
await asyncio.sleep(0.01) # 模拟异步开销
yield x * 2⚠️ 注意:_aiter_impl 是 async def,但它本身不能直接被 async for 使用;必须由 __aiter__ 返回一个异步生成器对象,所以上面写法是错的。正确写法是:
def __aiter__(self):
return self._aiter_impl().__aiter__() # 错误!
实际应改为:
def __aiter__(self):
return self._aiter_impl() # ✅ 正确:async def 函数调用后返回 async_generator
避免常见陷阱:不要混用 yield 和 await 在同一个函数里
这是 Python 明确禁止的语法错误:SyntaxError: 'await' outside async function 或 SyntaxError: 'yield' inside async function with 'await'(取决于版本)。也就是说,你不能写这样的函数:
async def bad_mix():
yield 1 # ❌ 不合法
await asyncio.sleep(1)
所以必须拆开:同步路径走普通生成器,异步路径走独立的 async def 生成器。两者共享逻辑时,把核心处理抽成普通函数,再分别包装。
- 同步迭代:用
def+yield,内部调用纯函数 - 异步迭代:用
async def+yield,内部也调用同一纯函数,但允许穿插await - 别试图在类里只靠一个方法兼顾两种协议——协议语义不同,硬塞只会出错
兼容性细节:Python 版本与 asyncio 运行时要求
async for 自 Python 3.5 起可用,但异步生成器(async def + yield)要到 3.6 才正式支持。如果你需要支持 3.5,就得用 asyncio.coroutine + types.AsyncGeneratorType 手动构造,非常麻烦,不建议。
另外,即使对象实现了 __aiter__,如果在非 asyncio 事件循环中运行(比如主线程没调用 asyncio.run()),async for 仍会失败,报 RuntimeError: no running event loop。这不是你的类的问题,而是调用环境缺失。
真正容易被忽略的是:同步调用者可能期望返回的是原生 generator,而你的类实例不是;如果下游用了 isinstance(..., types.GeneratorType) 做判断,就会失效。这时候要么文档注明“非原生生成器”,要么额外提供一个 .to_sync_generator() 工厂方法。










