日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

[[413590]]

成都創(chuàng)新互聯(lián)公司網(wǎng)站建設(shè)提供從項目策劃、軟件開發(fā)，軟件安全維護、網(wǎng)站優(yōu)化(SEO)、網(wǎng)站分析、效果評估等整套的建站服務，主營業(yè)務為網(wǎng)站設(shè)計、網(wǎng)站制作，成都App定制開發(fā)以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。成都創(chuàng)新互聯(lián)公司深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

熟悉 Golang 的同學都知道，Golang 里面有一個關(guān)鍵詞叫做defer，它可以實現(xiàn)延遲調(diào)用。

實際上在 Python 里面也有相關(guān)的語法，那就是contextlib.ExitStack。

我們來看這樣一個場景：

我有一個函數(shù)parse，它的作用是從 Redis 中持續(xù)讀入數(shù)據(jù)，并寫入到MongoDB 中。示例代碼如下：

 
 
 
 

  
  
  
  
import json 
  
  
  
  
import redis 
  
  
  
  
import pymongo 
  
  
  
  
 
  
  
  
  
client = redis.Redis() 
  
  
  
  
handler = pymongo.MongoClient().test.data 
  
  
  
  
 
  
  
  
  
def parse(): 
  
  
  
  
    data = client.lpop('test') 
  
  
  
  
    if not data: 
  
  
  
  
        return 
  
  
  
  
    handler.insert_one(json.loads(data)) 
 
 
 
 

但現(xiàn)在我想增加一個需求，當Redis 讀取結(jié)束或者讀取數(shù)據(jù)報錯的時候，能把當前的時間也寫入到MongoDB 中。

那么代碼可能變成下面這樣：

 
 
 
 

  
  
  
  
import json 
  
  
  
  
import redis 
  
  
  
  
import datetime 
  
  
  
  
import pymongo 
  
  
  
  
 
  
  
  
  
client = redis.Redis() 
  
  
  
  
handler = pymongo.MongoClient().test.data 
  
  
  
  
 
  
  
  
  
def parse(): 
  
  
  
  
    while True: 
  
  
  
  
        try: 
  
  
  
  
            data = client.lpop('test') 
  
  
  
  
            if not data: 
  
  
  
  
                handler.insert_one({'finished': True, 'ts': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}) 
  
  
  
  
                return 
  
  
  
  
            handler.insert_one(json.loads(data)) 
  
  
  
  
        except Exception: 
  
  
  
  
            handler.insert_one({'finished': True, 'ts': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'}) 
 
 
 
 

可以看到，代碼變得很難看了。

現(xiàn)在，我們可以使用延遲調(diào)用來讓代碼變得更好看。

要實現(xiàn)這個目的，就可以開始使用ExitStack了。它可以注冊多個回調(diào)函數(shù)，在退出上下文縮進時執(zhí)行。

我們先來看一個簡單的例子：

 
 
 
 

  
  
  
  
import contextlib 
  
  
  
  
 
  
  
  
  
def callback_1(): 
  
  
  
  
    print('我是第一個回調(diào)函數(shù)') 
  
  
  
  
 
  
  
  
  
def callback_2(x): 
  
  
  
  
    print(f'我是第二個回調(diào)函數(shù)，傳入?yún)?shù)：{x}') 
  
  
  
  
 
  
  
  
  
 
  
  
  
  
with contextlib.ExitStack() as stack: 
  
  
  
  
    stack.callback(callback_1) 
  
  
  
  
    stack.callback(callback_2, 100) 
  
  
  
  
    print(12345) 
  
  
  
  
    print('xxxx') 
  
  
  
  
print('退出縮進') 
 
 
 
 

運行效果如下圖所示：

可以看出以下特點：

1. 被添加的回調(diào)函數(shù)進入了一個棧，所以后添加的回調(diào)函數(shù)先調(diào)用
2. 回調(diào)函數(shù)會在結(jié)束縮進的時候被調(diào)用

現(xiàn)在我們來人工構(gòu)造一個異常：

可以看到，即使縮進里面出現(xiàn)了報錯，回調(diào)函數(shù)仍然可以正常運行。等所有回調(diào)函數(shù)運行完成以后，Python 才會退出。

基于以上特點，我們就可以來重構(gòu)最開始的代碼了：

 
 
 
 

  
  
  
  
import json 
  
  
  
  
import redis 
  
  
  
  
import datetime 
  
  
  
  
import pymongo 
  
  
  
  
import contextlib 
  
  
  
  
 
  
  
  
  
client = redis.Redis() 
  
  
  
  
handler = pymongo.MongoClient().test.data 
  
  
  
  
 
  
  
  
  
def add_ts(): 
  
  
  
  
    handler.insert_one({'finished': True, 'ts': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')}) 
  
  
  
  
 
  
  
  
  
def parse(): 
  
  
  
  
    with contextlib.ExitStack() as stack: 
  
  
  
  
        stack.callback(add_ts) 
  
  
  
  
        while True: 
  
  
  
  
            data = client.lpop('test') 
  
  
  
  
            if not data: 
  
  
  
  
                return 
  
  
  
  
            handler.insert_one(json.loads(data)) 
 
 
 
 

 

無論是正常運行結(jié)束還是運行過程中報錯，add_ts函數(shù)都會正常運行，確保始終增加一條日期數(shù)據(jù)。

本文轉(zhuǎn)載自微信公眾號「未聞Code」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系未聞Code公眾號。

 

當前名稱：一日一技：在Python中實現(xiàn)延遲調(diào)用
當前路徑：http://www.dlmjj.cn/article/coeshcc.html