午夜剧场伦理_日本一道高清_国产又黄又硬_91黄色网战_女同久久另类69精品国产_妹妹的朋友在线

您的位置:首頁(yè)技術(shù)文章
文章詳情頁(yè)

Python 中@lazyprop 裝飾器的用法

瀏覽:28日期:2022-06-18 13:51:52
安裝

pip install lazyprop例子1

from lazyprop import lazypropclass Foo(object): def __init__(self):self.load_count = 0 @lazyprop def lazy(self):self.load_count += 1f = Foo()f.lazyf.lazyf.lazyprint(f.load_count)

輸出:

1

例子2

from lazyprop import lazypropclass Foo(object): def __init__(self):self.load_count = 0 # @lazyprop def lazy(self):self.load_count += 1f = Foo()f.lazyf.lazyf.lazyprint(f.load_count)

輸出:

0

補(bǔ)充:python語(yǔ)言中的AOP利器:裝飾器

一、前言

面向切面編程(AOP)是一種編程思想,與OOP并不矛盾,只是它們的關(guān)注點(diǎn)相同。面向?qū)ο蟮哪康脑谟诔橄蠛凸芾恚嫦蚯忻娴哪康脑谟诮怦詈蛷?fù)用。

舉兩個(gè)大家都接觸過(guò)的AOP的例子:

1)java中mybatis的@Transactional注解,大家知道被這個(gè)注解注釋的函數(shù)立即就能獲得DB的事務(wù)能力。

2)python中的with threading.Lock(),大家知道,被這個(gè)with代碼塊包裹的部分立即獲得同步的鎖機(jī)制。

這樣我們把事務(wù)和加鎖這兩種與業(yè)務(wù)無(wú)關(guān)的邏輯抽象出來(lái),在邏輯上解耦,并且可以輕松的做到代碼復(fù)用。

二、上下文管理器contextlib

當(dāng)然你可以使用with上下文管理器實(shí)現(xiàn)一些AOP的思想,這里有個(gè)模塊叫contextlib可以幫助你簡(jiǎn)易的實(shí)現(xiàn)上下文管理器。

上下文管理最常見(jiàn)的例子是with open(’file’) as fh,回收打開(kāi)句柄的例子。

這種方式還是比較麻煩的,下面我們看一下python中的裝飾器怎么樣實(shí)現(xiàn)AOP編程。

三、裝飾器:AOP的語(yǔ)法糖

python中的裝飾器就是設(shè)計(jì)來(lái)實(shí)現(xiàn)切面注入功能的。下面給出幾個(gè)例子,這幾個(gè)例子都是在生產(chǎn)環(huán)境驗(yàn)證過(guò)的。

其中的任務(wù)管理機(jī)是偽代碼,需要自己實(shí)現(xiàn)寫(xiě)數(shù)據(jù)庫(kù)的邏輯。

1、重試邏輯

只要do函數(shù)被@retry_exp裝飾,便可以獲得指數(shù)退避的重試能力。

@retry_exp(max_retries=10)def do(): # do whatever pass

那retry_exp是如何實(shí)現(xiàn)的呢?

def retry_exp(max_retries=3, max_wait_interval=10, period=1, rand=False): def _retry(func):def __retry(*args, **kwargs): MAX_RETRIES = max_retries MAX_WAIT_INTERVAL = max_wait_interval PERIOD = period RAND = rand retries = 0 error = None ok = False while retries < MAX_RETRIES:try: ret = func(*args, **kwargs) ok = True return retexcept Exception, ex: error = exfinally: if not ok:sleep_time = min(2 ** retries * PERIOD if not RAND else randint(0, 2 ** retries) * PERIOD, MAX_WAIT_INTERVAL)time.sleep(sleep_time)retries += 1 if retries == MAX_RETRIES:if error: raise errorelse: raise Exception('unknown')return __retry return _retry2、降級(jí)開(kāi)關(guān)

只要do函數(shù)被@degrade裝飾,就會(huì)安裝app名稱校驗(yàn)redis里的開(kāi)關(guān),一旦發(fā)現(xiàn)開(kāi)關(guān)關(guān)閉,則do函數(shù)不被執(zhí)行,也就是降級(jí)。

@degradedef do(app): # do whatever pass

那么degrade是怎樣實(shí)現(xiàn)的呢?

def degrade(app): def _wrapper(function):def __wrapper(*args, **kwargs): value = None try:redis = codis_pool.get_connection()value = redis.get('dmonitor:degrade:%s' % app) except Exception, _:logger.info(traceback.format_exc()) if not value or int(value) != 1:function()logger.info('[degrade] is_on: %s' % app) else:logger.info('[degrade] is_off: %s' % app)return __wrapper return _wrapper3、任務(wù)狀態(tài)機(jī)

這個(gè)是最常用的,我們需要跟蹤落盤(pán)DB一個(gè)任務(wù)的執(zhí)行狀態(tài)(等待調(diào)度,執(zhí)行中,執(zhí)行成功,執(zhí)行失敗)

一旦do方法被@tasks_decorator裝飾,就獲得了這樣的能力。對(duì)item_param(是個(gè)json)中task_id指明的任務(wù)進(jìn)行狀態(tài)管理。

@tasks_decoratordef do(item_param): # do whatever pass

tasks_decorator是怎樣實(shí)現(xiàn)的呢?

def tasks_decorator(function): def _wrap(*args, **kwargs):param_dict = kwargs.get(’item_param’)task_id = param_dict.get(’task_id’)try: param_dict.update({’status’: TaskStatus.Waiting, ’start_time’: datetime.now().strftime(’%Y-%m-%d %H:%M:%S’)}) try:manager_dao.save_task(param_dict) except Exception, ex:pass _update_task_status(task_id, TaskStatus.Doing) function(*args, **kwargs) _update_task_status(task_id, TaskStatus.Done)except Exception as e: time.sleep(0.5) _update_task_status(task_id, TaskStatus.Fail, unicode(e.message)) raise return _wrap4、全局唯一性

在分布式+異步環(huán)境中,如果想保證exactly once是需要額外的邏輯的,其實(shí)主要是實(shí)現(xiàn)唯一鍵,一旦唯一鍵實(shí)現(xiàn)了,就可以使用公共緩存redis進(jìn)行唯一鍵判定了。

do函數(shù)被unique裝飾,那么對(duì)于task_id對(duì)應(yīng)的任務(wù),全局只會(huì)執(zhí)行一次。

@uniquedef do(task_id): # do whatever pass

unique是怎樣實(shí)現(xiàn)的呢?

def unique(function): def _wrap(*args, **kwargs):task_id = kwargs.get(’task_id’)try: redis = codis_pool.get_connection() key = 'unique:%s' % task_id if not redis.setnx(key):redis.expire(key, 24*60*60)function(*args, **kwargs)except Exception as e: logger.error(traceback.format_exc()) raise return _wrap四、總結(jié)

AOP在少量增加代碼復(fù)雜度的前提下,顯著的獲得以下優(yōu)點(diǎn):

1、使得功能邏輯和業(yè)務(wù)邏輯解耦,功能和業(yè)務(wù)的修改完全獨(dú)立,代碼結(jié)構(gòu)清晰,開(kāi)發(fā)方便

2、一鍵注入,代碼復(fù)用程度高,擴(kuò)展方便

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 欧美精品国产动漫 | 初体验3在线观看 | 欧美在线一二三 | h片视频| 欧洲av在线 | 国产激情在线 | 日本伊人影院 | 超级碰在线视频 | 人人看av| 中文字幕亚洲精品在线 | 婷婷网址 | 国产日 | 天天操天天干天天操天天干 | 91免费视频网站 | 激情五月婷婷色 | 午夜激情免费视频 | 国产a级免费 | 亚洲免费中文字幕 | 中文一二三区 | 成人在线手机视频 | 极品颜值美女露脸啪啪 | 91成人黄色 | 91亚洲国产成人精品一区二三 | 久久久精品免费 | 日韩在线视频看看 | 美女久久久久久久久 | 久久精品视频中文字幕 | 欧美大片91| 日韩精品第一页 | 另类一区二区 | 丰满肥臀噗嗤啊x99av | 国产精品一线 | 国产资源网站 | 国产美女永久免费无遮挡 | 亚洲精品在线视频观看 | 一区二区三区日韩视频 | www.日日日 | 依依激情网 | 99国产视频 | 操老女人逼视频 | 国偷自拍第113页 |