StopAsyncIteration是异步迭代器唯一的结束信号,其他异常均导致循环终止;需在__anext__中精准抛出,调用方须显式捕获非StopAsyncIteration异常。

异步迭代器结束时抛出 StopAsyncIteration 是协议行为,不是错误;但若在 __anext__ 中提前或意外抛出其他异常(比如 ValueError、ConnectionError),就必须显式捕获——否则会中断整个 async for 循环并向上冒泡。
async for 里别指望自动吞掉异常
async for 只处理 StopAsyncIteration,其余所有异常都会立刻终止循环,并原样抛出。它不会像同步 for 那样“跳过”单次迭代失败。
- 错误写法:
async for item in broken_aiter(): process(item)—— 一旦某次__anext__抛出TimeoutError,循环直接退出,后续项全丢 - 正确做法:把单次迭代包进
try/except,自行决定是跳过、记录还是中断 - 注意:
async for底层调用的是await anext(aiter),所以异常来源就是__anext__的返回或抛出
anext() 的两种安全调用方式
手动驱动异步迭代器时,anext() 是核心入口。它默认抛出 StopAsyncIteration,但你可以控制是否让它变成普通值。
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac,无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启:辅助功能 + 屏幕录制权限
- 用默认值避免异常:
value = await anext(aiter, None)—— 返回None表示结束,适合你愿意用哨兵值判断的场景 - 显式捕获更清晰:
try: value = await anext(aiter) except StopAsyncIteration: break—— 明确区分“结束”和“其他错误” - 别用
asyncio.wait_for(anext(...), timeout=...)直接包 ——anext本身不接受timeout参数,会报TypeError
自定义 __anext__ 里抛异常的边界
如果你自己实现异步迭代器,__anext__ 方法里什么时候该 raise、什么时候该 return,直接影响调用方能否区分“数据结束”和“运行失败”。
立即学习“Python免费学习笔记(深入)”;
- 只在确认无更多数据时 raise
StopAsyncIteration—— 过早 raise 会让async for提前退出,过晚则导致死循环 - 网络超时、解析失败等应 raise 其他异常(如
ConnectionError、JSONDecodeError),由上层决定重试或告警 - 不要在
__anext__里吞掉异常再 return None —— 这会让调用方误以为“迭代结束了”,掩盖真实问题
最易被忽略的一点:StopAsyncIteration 是唯一被 async for 和 anext() 协议认可的“结束信号”,其他任何异常都代表非正常终止。别把它当成普通业务错误去 catch 后继续循环——那通常意味着你的迭代器状态已经不可靠了。

















