异步生成器中yield前需先await完成异步操作，如await asyncio.sleep(0.1); yield 42；并发控制用asyncio.Semaphore(3)配合async with，速率限制需基于time.monotonic()动态计算delay并置于yield前。
async def 里不能直接用 yield + asyncio.sleep 怎么办
异步生成器必须用 async def 定义，且内部 yield 后不能直接 await（比如 await asyncio.sleep(1)），否则会报 SyntaxError: 'await' outside async function——因为 yield 本身不构成 awaitable 上下文。正确做法是把耗时逻辑封装进协程，再用 await 调用它，然后 yield 结果。
- 错误写法：
async def gen(): yield 42; await asyncio.sleep(0.1)（语法错误） - 正确写法：
async def gen(): await asyncio.sleep(0.1); yield 42（yield可以出现在await之后） - 更实用的模式：先
await fetch_data()，再yield result，确保每次产出前都完成异步等待
用 asyncio.Semaphore 控制并发请求数量
如果生成器每次 yield 都触发一个 HTTP 请求或数据库查询，不加限制会导致瞬间打爆服务端。用 asyncio.Semaphore 是最轻量、最直接的并发数控制方式——它不干预执行顺序，只卡住同时进入临界区的协程数量。
-
sem = asyncio.Semaphore(3)表示最多 3 个请求并发执行 - 每个
yield前加async with sem:，自动 acquire/release - 注意不要在
async for外层用同一个Semaphore实例共享给多个生成器实例，否则会意外串扰 - 若需动态调整上限，得自己封装一层（
Semaphore的_value是私有属性，不建议直接改）
rate limit 按时间窗口实现要小心 asyncio.sleep 累积误差
单纯靠 await asyncio.sleep(1.0) 实现“每秒一个”是错的：如果某次处理耗时 0.8s，再睡 1.0s，实际间隔就变成 1.8s；连续多次延迟会让节奏越来越慢。真正稳定的速率限制得基于绝对时间戳对齐。
python-docx Skill功能概述python-docx Skill是一项面向实际任务的技能，主要用于本Skill提供使用python-docx生成专业Word文档的标准方法和最佳实践；生成安全服务方案文档；核心要点生成技术架构设计文档；生成任何需要专业排版的Word文档；核心库 : python-docx；使用与执行辅助库 : docx.shared , docx.enum , docx.oxml.ns；标准代码模板；1. 文档初始化；2. 字体设置（必须！它将相关步骤、工具调用和结果整理方式集
- 记录上一次产出时间
self._last_yield = time.time() - 每次循环计算应等待时长：
delay = max(0, 1.0 - (time.time() - self._last_yield)) - 再
await asyncio.sleep(delay)，然后更新_last_yield - 这个逻辑必须放在
yield之前，否则第一次产出没延迟，后续才开始控速 - 若用
time.monotonic()替代time.time()，可避免系统时间回拨导致负 delay
组合并发限制与速率限制时别漏掉“最大并发数优先”原则
当既要限流（如每秒最多 5 个），又要限并发（如最多 3 个同时跑），二者不是简单叠加。真实瓶颈是并发数——哪怕你每秒只发 1 个请求，但开了 100 个协程一起等 sleep 结束，内存和事件循环调度压力依然很大。所以语义上应是：“最多 3 个在跑，且它们的产出间隔平均不小于 200ms”。
立即学习“Python免费学习笔记（深入）”；
- 推荐结构：外层用
Semaphore(3)控制并发数，内层用时间戳做平滑 delay - 不要反过来：先 sleep 再 acquire semaphore，否则 sleep 期间仍占用事件循环资源，且无法防止突发并发
- 测试时可用
asyncio.create_task()启动多个生成器消费协程，观察len(asyncio.all_tasks())是否稳定在预期范围内 - 生产环境建议加上超时：
await asyncio.wait_for(sem.acquire(), timeout=30)，防止单点阻塞拖垮整个生成流程
实际最难调的是 delay 计算时机和 Semaphore 生命周期绑定——yield 前没等够时间，或 acquire 失败后没 clean up，都会让下游拿到乱序/重复/缺失的数据。
