用tenacity实现异步重试最可靠，其@retry装饰器原生支持async def函数，内置wait_exponential()自动处理指数退避、jitter、最大等待时间与重试次数，避免手动实现漏异常过滤、忽略取消信号或重复await协程等错误。
asyncio + tenacity 实现带指数退避的异步重试
直接上结论：别手写重试逻辑，用 tenacity —— 它原生支持 async def 函数，且内置 wait_exponential()，能自动处理 jitter、最大等待时间、重试次数等细节。
常见错误是试图在 asyncio.sleep() 外套 while 循环手动退避，结果漏掉异常类型过滤、没处理 cancel 信号、或在重试中意外 await 同一个协程多次（导致 RuntimeError: cannot reuse already awaited coroutine）。
- 安装：
pip install tenacity - 必须用
@retry(wait=wait_exponential(multiplier=1, min=1, max=10), stop=stop_after_attempt(3))装饰异步函数 -
multiplier控制起始间隔（单位秒），min/max防止退避过长或过短；max=10是硬上限，避免单次重试卡住太久 - 默认只重试
Exception，如只需重试网络类错误，显式加retry=retry_if_exception_type((aiohttp.ClientError, asyncio.TimeoutError))
为什么不能用 time.sleep() 或普通 retry 库
time.sleep() 在协程里会阻塞整个事件循环，等同于把异步变同步；而像 retrying 这类老库根本不认识 await，调用时直接报 TypeError: object ... can't be used in 'await' expression。
真实场景中，比如调用下游 HTTP 接口失败，你希望：第一次 1s 后重试，第二次 2s，第三次 4s，第四次 8s……但实际网络抖动不是严格幂级增长，所以 tenacity 默认开启 jitter（随机偏移），避免大量请求在同一时刻涌向下游。
立即学习“Python免费学习笔记（深入）”；
快速生成专业的 Python 脚本和应用代码。一键创建完整项目结构，支持CLI、API、爬虫、Bot、Django等多种项目类型，包含完整的项目结构、配置文件、依赖管理、测试、README和文档。
- 错误写法：
await asyncio.sleep(2 ** attempt)—— 没 jitter，易引发雪崩 - 正确做法：
wait_exponential(multiplier=1, min=1, max=10, jitter=True)（jitter 默认开启） - 注意：
min和max是 jitter 后的最终值上下限，不是指数计算前的原始值
重试过程中如何传递上下文或动态调整参数
有时你需要根据失败原因动态改重试策略，比如超时就多等会儿，连接拒绝就快速失败。这时候不能靠装饰器静态配置，得用 Retrying 实例手动控制流程。
典型坑是：在重试回调里修改变量，但没传进下一次 retry 的作用域；或者误把 asyncio.create_task() 当作可重试协程传给 tenacity，结果重试的是 task 对象而非协程本身。
- 用
retrier = Retrying(wait=..., stop=...)实例，再调用await retrier.astart(your_coro, *args, **kwargs) - 可在
before_sleep回调里打印日志、上报监控，甚至修改下次调用的kwargs（需配合闭包或类属性） - 务必确保被重试的目标是
async def函数，不是已 await 过的coroutine object
并发任务重试时的资源竞争与取消安全
当多个异步任务共享同一个连接池（如 aiohttp.TCPConnector）并同时触发重试，容易因连接耗尽返回 ClientOSError，进而被误判为需重试的业务错误——形成恶性循环。
更隐蔽的问题是：用户主动取消某个任务（asyncio.CancelledError），但重试逻辑没捕获它，导致任务看似“还在重试”，实则已被 cancel 却没释放资源。
- 在
retry_if_exception_type中排除asyncio.CancelledError和concurrent.futures.CancelledError - HTTP 客户端务必设
limit和limit_per_host，例如TCPConnector(limit=100, limit_per_host=20) - 如果重试逻辑里用了锁（
asyncio.Lock），记得在before_sleep或 finally 块中确保释放，否则可能死锁
最常被忽略的一点：重试不是万能解药。如果下游服务已熔断、认证 token 过期、或请求体本身非法，重试只会放大错误。务必先做前置校验，再决定是否进重试流程。
