網(wǎng)站首頁 編程語言 正文
1、前言
在我們?nèi)粘5拈_發(fā)工作中,為了代碼的健壯性,我們通常會(huì)對(duì)方法中的業(yè)務(wù)代碼進(jìn)行try-except的包裝,以防止在發(fā)生異常的時(shí)候進(jìn)程被中斷。如果發(fā)生異常,我們?cè)撛趺崔k呢?有同學(xué)可能用自己的方式(循環(huán))去做了重試,那么有沒有一種通用的可靠的重試方式呢?答案是有的,它就是retrying庫,今天我們就一起來看看。
2、快速開始
retrying是一個(gè)極簡(jiǎn)的使用Python編寫的,擁有1.8k??的可以實(shí)現(xiàn)方法異常重試的庫,我們?cè)趯?shí)際使用中直接為我們的方法增加一個(gè)@retry的裝飾器即可。
2.1、安裝retrying
pip install retrying
2.2、模擬無限重試
假設(shè)我們現(xiàn)在有一個(gè)方法demo1,這個(gè)方法中調(diào)用了另一個(gè)接口e1,但是被調(diào)用的這個(gè)e1接口不穩(wěn)定,當(dāng)e1接口返回異常的時(shí)候,我們需要去重試。
from retrying import retry import time ? # 一個(gè)會(huì)返回異常的接口e1 def e1(): ? ?time.sleep(1) ? ?print('err') ? ?# 我們拋出異常模擬接口異常 ? ?raise TypeError ? # 全局計(jì)數(shù)器 a=1 @retry def demo1(n): ? ?# 方法中調(diào)用全局變量,需要global ? ?global a ? ?# 進(jìn)行try-except ? ?try: ? ? ? ?print(f'開始嘗試!{a}') ? ? ? ?a+=1 ? ? ? ?e1() ? ?except Exception as e: ? ? ? ?print(e) ? ? ? ?# 當(dāng)重試完成后還未成功,則返回超時(shí) ? ? ? ?raise TimeoutError if __name__=='__main__': ? ?demo1(0)
代碼執(zhí)行結(jié)果:
你會(huì)發(fā)現(xiàn),我們代碼會(huì)一值被重試,這是為什么呢?
默認(rèn)的retry裝飾器就是無限重試的,直到重試成功為止。因?yàn)槲覀兊慕涌趀1是永遠(yuǎn)返回異常的,所以這個(gè)重試將會(huì)永遠(yuǎn)持續(xù)下去。
我們改造e1方法如下,即可在重試第10次成功:
# 一個(gè)會(huì)返回異常的接口e1 def e1(): ? ?time.sleep(1) ? ?print('err') ? ?# 當(dāng)重試次數(shù)達(dá)到10時(shí),返回True ? ?if a>=10: ? ? ? ?print('ok!') ? ? ? ?return True ? ?# 我們拋出異常模擬接口異常 ? ?raise TypeError
代碼執(zhí)行結(jié)果:
開始嘗試!1
err
開始嘗試!2
err
開始嘗試!3
err
開始嘗試!4
err
開始嘗試!5
err
開始嘗試!6
err
開始嘗試!7
err
開始嘗試!8
err
開始嘗試!9
err
ok!
2.3、模擬最大重試次數(shù)
上面的無限重試明顯在實(shí)際業(yè)務(wù)場(chǎng)景中適用面不是非常廣,當(dāng)我們需要使用重試次數(shù)來限制時(shí),我們就可以使用retry的裝飾器參數(shù)stop_max_attempt_number
來實(shí)現(xiàn)。
# 全局計(jì)數(shù)器 a=1 @retry(stop_max_attempt_number=3) def demo1(n): ? ?# 方法中調(diào)用全局變量,需要global ? ?global a ? ?# 進(jìn)行try-except ? ?try: ? ? ? ?print(f'開始嘗試!{a}') ? ? ? ?a+=1 ? ? ? ?e1() ? ?except Exception as e: ? ? ? ?print(e) ? ? ? ?# 當(dāng)重試完成后還未成功,則返回超時(shí) ? ? ? ?raise TimeoutError
以上代碼表示,我們只重試3次,如果還未成功,則返回超時(shí)異常。
代碼執(zhí)行結(jié)果:
2.4、模擬最大重試時(shí)間
除了可以使用重試次數(shù)限制外,當(dāng)我們對(duì)時(shí)間要求比較明確的時(shí)候,我們就可以使用stop_max_delay
參數(shù)來指定最大重試時(shí)間。這個(gè)參數(shù)的單位是ms。
# 全局計(jì)數(shù)器 a=1 @retry(stop_max_delay=2000) def demo1(n): ? ?# 方法中調(diào)用全局變量,需要global ? ?global a ? ?# 進(jìn)行try-except ? ?try: ? ? ? ?print(f'開始嘗試!{a}') ? ? ? ?a+=1 ? ? ? ?e1() ? ?except Exception as e: ? ? ? ?print(e) ? ? ? ?# 當(dāng)重試完成后還未成功,則返回超時(shí) ? ? ? ?raise TimeoutError
如上代碼表示,當(dāng)重試時(shí)間超過2s就會(huì)拋出超時(shí)異常。因?yàn)樵趀1方法中,每次調(diào)用都會(huì)休眠1s,所以對(duì)于限制兩秒,我們只能在2s內(nèi)重試2次。
代碼執(zhí)行結(jié)果:
2.5、模擬重試間隔時(shí)間
當(dāng)我們不希望重試間隔時(shí)間太長(zhǎng)的時(shí)候,我們可以使用參數(shù)wait_fixed
指定重試的間隔時(shí)間。
# 全局計(jì)數(shù)器 a=1 @retry(stop_max_delay=6000,wait_fixed=1000) def demo1(n): ? ?# 方法中調(diào)用全局變量,需要global ? ?global a ? ?# 進(jìn)行try-except ? ?try: ? ? ? ?print(f'開始嘗試!{a}') ? ? ? ?a+=1 ? ? ? ?e1() ? ?except Exception as e: ? ? ? ?print(e) ? ? ? ?# 當(dāng)重試完成后還未成功,則返回超時(shí) ? ? ? ?raise TimeoutError
如上代碼表示最大重試時(shí)間6秒,重試間隔1秒,但是e1方法中還休眠了1秒,所以在6秒內(nèi),我們理論上只能重試4次(不是3次)。
代碼運(yùn)行結(jié)果:
在此基礎(chǔ)上,retrying還為我們提供了隨機(jī)的重試間隔時(shí)間參數(shù)。
- wait_random_min,重試間隔最小時(shí)間
- wait_random_max,重試間隔最大時(shí)間
一般,這兩個(gè)參數(shù)都是成對(duì)出現(xiàn),用于限制重試間隔時(shí)間的范圍。
2.6、指定重試調(diào)用的方法
retrying允許我們?cè)谥卦嚨耐瑫r(shí)去調(diào)用一個(gè)方法。使用參數(shù)stop_func
來指定這個(gè)方法名。
# attempts, delay這兩個(gè)參數(shù)是必填的 def stop_f(attempts, delay): ? ?print('發(fā)生異常了,正在進(jìn)行重試!') # 全局計(jì)數(shù)器 a=1 @retry(stop_func=stop_f,stop_max_delay=3) def demo1(n): ? ?# 方法中調(diào)用全局變量,需要global ? ?global a ? ?# 進(jìn)行try-except ? ?try: ? ? ? ?print(f'開始嘗試!{a}') ? ? ? ?a+=1 ? ? ? ?e1() ? ?except Exception as e: ? ? ? ?print(e) ? ? ? ?# 當(dāng)重試完成后還未成功,則返回超時(shí) ? ? ? ?raise TimeoutError
代碼運(yùn)行結(jié)果:
但是stop_func存在一個(gè)問題就是和stop_max_delay、stop_max_attempt_number結(jié)合使用的時(shí)候,后面兩者會(huì)失效。
2.7、指定重試的異常類型
當(dāng)我們需要針對(duì)特定的異常才進(jìn)行重試時(shí),就需要用到這個(gè)參數(shù):retry_on_exception
。
2.8、指定重試的特定條件
當(dāng)達(dá)到某個(gè)條件才會(huì)進(jìn)行重試,需要使用參數(shù):retry_on_result
。
原文鏈接:https://juejin.cn/post/7108202816665026573
相關(guān)推薦
- 2022-04-21 python工廠方法模式原理與實(shí)現(xiàn)_python
- 2022-10-26 Android?Framework層獲取及處理按鍵事件流程_Android
- 2022-04-20 .NET?Core使用Worker?Service創(chuàng)建服務(wù)_實(shí)用技巧
- 2022-05-21 React?組件中的state和setState()你知道多少_React
- 2022-08-05 linux安裝部署lua環(huán)境
- 2022-10-04 go?mode?tidy出現(xiàn)報(bào)錯(cuò)go:?warning:?“all“?matched?no?pack
- 2022-06-20 深入淺析C#?11?對(duì)?ref?和?struct?的改進(jìn)_C#教程
- 2022-03-30 jupyter?notebook使用argparse傳入list參數(shù)_python
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運(yùn)行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲(chǔ)小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運(yùn)算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯(cuò)誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實(shí)現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡(jiǎn)單動(dòng)態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對(duì)象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊(duì)列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支