news 2026/5/30 17:23:28

Tenacity重试直到成功

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Tenacity重试直到成功

你给出的这段代码:

@tenacity.retry(retry=tenacity.retry_if_result(lambdais_acquired:bool(notis_acquired)),stop=tenacity.stop_after_delay(timeout),before=tries)

Tenacity库中的一个重试装饰器,用于自动重试某个函数,直到满足特定条件为止。


🔍 逐部分解释

1.@tenacity.retry(...)

这是 Tenacity 提供的装饰器,用于包装一个函数,使其在失败时自动重试。


2.retry=tenacity.retry_if_result(lambda is_acquired: bool(not is_acquired))
  • 作用:只有当函数的返回值为False时,才触发重试。
  • retry_if_result(...)是 Tenacity 提供的一个条件重试器。
  • lambda is_acquired: bool(not is_acquired)是一个匿名函数,等价于:
defcheck(is_acquired):returnnotis_acquired# 即如果未获取锁,就重试

总结如果函数返回False,就重试;返回True,就停止重试。


3.stop=tenacity.stop_after_delay(timeout)
  • 作用:设置最大重试时间为timeout秒(由函数参数传入,默认是 300 秒)。
  • 超过这个时间后,即使条件仍不满足,也停止重试。

4.before=tries
  • 作用:每次重试前调用tries对象(是一个RetryState实例),通常用于记录重试次数或日志。
  • 你可以理解为:每次重试前,执行tries(),比如打印日志或更新状态。

🧪 举个例子

假设你有一个函数try_lock(),它尝试获取一个分布式锁,返回True表示成功,False表示失败。

importtenacityimporttimeclassRetryState:def__init__(self):self.tries=0def__call__(self,retry_state):self.tries+=1print(f"[RetryState] 第{self.tries}次尝试...")# 模拟一个锁获取函数,前 4 次失败,第 5 次成功call_count=0deftry_lock():globalcall_count call_count+=1success=call_count>=5print(f"[try_lock] 第{call_count}次调用,结果:{'成功'ifsuccesselse'失败'}")returnsuccess# 使用 tenacity 重试机制@tenacity.retry(retry=tenacity.retry_if_result(lambdax:notx),# 返回 False 就重试stop=tenacity.stop_after_delay(10),# 最多重试 10 秒before=RetryState()# 每次重试前调用)defacquire_lock():returntry_lock()# 调用result=acquire_lock()print("最终结果:",result)

✅ 输出示例:

[RetryState] 第 1 次尝试... [try_lock] 第 1 次调用,结果:失败 [RetryState] 第 2 次尝试... [try_lock] 第 2 次调用,结果:失败 [RetryState] 第 3 次尝试... [try_lock] 第 3 次调用,结果:失败 [RetryState] 第 4 次尝试... [try_lock] 第 4 次调用,结果:失败 [RetryState] 第 5 次尝试... [try_lock] 第 5 次调用,结果:成功 最终结果: True

✅ 总结一句话

这个装饰器的作用是:

每隔一段时间重试一次函数,直到它返回True或超过最大超时时间为止,每次重试前记录状态。


如果你想,我可以帮你画一个流程图或写成伪代码来加深理解。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/5/30 3:39:45

IT68051:支持3D的双端口HDMI 2.0b接收器

IT68051为双端口HDMI 2.0b接收器,支持6.0 Gbps/通道速度,每个端口最高18 Gb/s带宽。它完全兼容HDMI 1.4b/HDMI 2.0b、HDCP 1.4/HDCP 2.2,并且向下兼容DVI 1.0规范。IT68051具备深色(最高36位)功能,确保高质…

作者头像 李华
网站建设 2026/5/30 7:21:10

PyFluent 实战指南:构建Python驱动的CFD工作流

PyFluent 实战指南:构建Python驱动的CFD工作流 【免费下载链接】pyfluent Pythonic interface to Ansys Fluent 项目地址: https://gitcode.com/gh_mirrors/py/pyfluent 在当今工程仿真领域,将Python编程能力与专业CFD工具相结合已成为提升工作效…

作者头像 李华
网站建设 2026/5/28 23:54:38

终极Marlin固件配置指南:从零开始快速上手

终极Marlin固件配置指南:从零开始快速上手 【免费下载链接】Marlin Marlin 是一款针对 RepRap 3D 打印机的优化固件,基于 Arduino 平台。 项目地址: https://gitcode.com/GitHub_Trending/ma/Marlin 还在为3D打印机固件配置头疼吗?每次…

作者头像 李华
网站建设 2026/5/25 16:40:17

图数据库性能卡顿怎么办,MCP DP-420 Agent优化方案全解析

第一章:图数据库性能卡顿的根源分析 图数据库在处理高度关联数据时展现出强大优势,但在实际应用中常出现查询延迟、响应缓慢等性能卡顿问题。其根本原因往往隐藏在数据模型设计、索引策略、硬件资源及查询语句优化等多个层面。 数据模型设计不合理 当节…

作者头像 李华
网站建设 2026/5/29 10:33:56

电子书阅读器翻页动画如何创造沉浸式阅读体验

电子书阅读器翻页动画如何创造沉浸式阅读体验 【免费下载链接】readest Readest is a modern, feature-rich ebook reader designed for avid readers offering seamless cross-platform access, powerful tools, and an intuitive interface to elevate your reading experien…

作者头像 李华