在Python的异步编程场景中，我们经常需要处理逐个产生的异步结果，比如异步读取文件流、异步获取网络请求的批量数据等，这时候就需要用到异步生成器来实现异步迭代。
异步生成器的基础概念
普通生成器是通过yield关键字来逐个返回结果，但是无法处理异步操作。异步生成器则是在普通生成器的基础上，结合异步语法，使用async def定义函数，在函数内部用await处理异步操作，再用yield返回结果，这样就能实现异步场景下的迭代功能。
异步生成器的核心特点是：定义时使用async def，内部可以同时存在await和yield关键字，返回的是一个异步迭代器对象，需要通过异步循环来遍历结果。
异步生成器的定义方式
定义异步生成器的语法和普通异步函数类似，只是函数内部会包含yield语句，下面是一个最简单的异步生成器示例：
import asyncio
# 定义异步生成器函数
async def async_generator_demo():
for i in range(3):
# 模拟异步操作，比如等待IO完成
await asyncio.sleep(1)
# 用yield返回结果
yield i
上面的代码中，async_generator_demo就是一个异步生成器函数，调用它不会立即执行函数内容，而是返回一个异步生成器对象。
异步迭代的使用方法
要遍历异步生成器返回的结果，需要使用async for语法，这是Python专门为异步迭代设计的语法结构，不能在普通循环中使用。下面是遍历上面定义的异步生成器的示例：
import asyncio
async def async_generator_demo():
for i in range(3):
await asyncio.sleep(1)
yield i
# 定义异步主函数
async def main():
# 使用async for遍历异步生成器
async for value in async_generator_demo():
print(f"获取到异步结果：{value}")
# 运行异步程序
if __name__ == "__main__":
asyncio.run(main())
运行上面的代码，会每隔1秒打印一个结果，输出内容如下：
获取到异步结果：0 获取到异步结果：1 获取到异步结果：2
异步生成器的实际应用场景
异步生成器非常适合处理需要逐个获取异步结果的场景，比如异步读取大文件、异步批量请求接口等。下面是一个异步读取文件内容的示例，每次读取一行内容并返回：
import asyncio
# 模拟异步读取文件的操作
async def async_read_file(file_path):
# 模拟打开文件的异步操作
await asyncio.sleep(0.5)
# 假设文件内容按行存储，这里用列表模拟
lines = ["第一行内容", "第二行内容", "第三行内容"]
for line in lines:
# 模拟读取每一行的异步耗时
await asyncio.sleep(0.3)
yield line
async def process_file():
async for line in async_read_file("test.txt"):
print(f"处理文件行：{line}")
if __name__ == "__main__":
asyncio.run(process_file())
异步生成器的注意事项
- 异步生成器函数必须使用
async def定义，不能用普通def定义，否则内部的await语法会报错。 - 遍历异步生成器必须使用
async for，不能用普通的for循环，否则会提示对象不是可迭代对象。 - 异步生成器内部可以正常使用
return语句，但是return的值不会作为迭代结果返回，而是会在迭代结束时抛出StopAsyncIteration异常，一般不建议在异步生成器中随意使用return。 - 异步生成器返回的对象是异步迭代器，支持
__anext__方法，也可以手动调用这个方法获取下一个结果，但是一般更推荐使用async for语法。
异步生成器和普通生成器的区别
为了更清晰地理解两者的差异，我们可以通过下面的表格对比：
| 对比项 | 普通生成器 | 异步生成器 |
|---|---|---|
| 定义方式 | 使用def定义，内部用yield | 使用async def定义，内部用await和yield |
| 迭代方式 | 使用普通for循环遍历 | 使用async for循环遍历 |
| 适用场景 | 同步场景下的逐个结果返回 | 异步场景下的逐个结果返回 |
| 返回值类型 | 同步迭代器 | 异步迭代器 |
总结
通过上面的内容我们可以知道，用生成器函数实现异步迭代的核心是定义异步生成器，也就是用async def定义函数，在函数内部结合await处理异步操作，再用yield返回结果。遍历的时候使用async for语法即可逐个获取异步结果。这种方式可以很好地处理异步场景下的流式数据、批量异步结果等需求，是Python异步编程中非常实用的技巧。