您好,登錄后才能下訂單哦!
這篇文章給大家介紹怎么在Python項(xiàng)目中調(diào)用追蹤,內(nèi)容非常詳細(xì),感興趣的小伙伴們可以參考借鑒,希望對(duì)大家能有所幫助。
對(duì)于分布式追蹤,主要有以下的幾個(gè)概念:
追蹤 Trace:就是由分布的微服務(wù)協(xié)作所支撐的一個(gè)事務(wù)。一個(gè)追蹤,包含為該事務(wù)提供服務(wù)的各個(gè)服務(wù)請(qǐng)求。
跨度 Span:Span是事務(wù)中的一個(gè)工作流,一個(gè)Span包含了時(shí)間戳,日志和標(biāo)簽信息。Span之間包含父子關(guān)系,或者主從(Followup)關(guān)系。
跨度上下文 Span Context:跨度上下文是支撐分布式追蹤的關(guān)鍵,它可以在調(diào)用的服務(wù)之間傳遞,上下文的內(nèi)容包括諸如:從一個(gè)服務(wù)傳遞到另一個(gè)服務(wù)的時(shí)間,追蹤的ID,Span的ID還有其它需要從上調(diào)用追蹤。
import uuid import os import time l = [] class Recorder(object): def __init__(self,servername,root_span = None): if root_span == None: self.__span = Span(servername) else: self.__span = Span(servername,root_span) #上下文管理器 def __enter__(self): return self.__span # 退出方法中,用來實(shí)現(xiàn)善后處理工作 def __exit__(self, exc_type, exc_val, exc_tb): self.__span.record() self.__span.record_save(self.__span.span) class Span(object): def __init__(self,servername,root_span = None): self.servername = servername self.span = self.newspan() if root_span != None: root_span.dic['child_span'] = self.span self.span["root_span_flag"] = False def newspan(self): self.dic = { "spanid": uuid.uuid4().int, "servername": self.servername, "location": "", "ip": "", "durationtime": 0, "starttime": time.time(), "endtime":0, "tag": "", "log": "", "root_span_flag":True, "child_span": "" } return self.dic def record_save(self, span): currenttracer = {"id": span["spanid"], "data": span} print(currenttracer) l.append(currenttracer) def record(self): self.span["servername"] = self.servername self.span["location"] = os.getcwd() + "." + self.servername self.span["endtime"] = time.time() self.span["durationtime"] = self.span["endtime"] - self.span["starttime"] def setspantag(self,tag): self.span["tag"] = tag def setspanlog(self,log): self.span["log"] = log # 連續(xù)調(diào)用 with Recorder('server1') as span: time.sleep(1) span.setspantag("test") #調(diào)用server1方法 print("server1") with Recorder('server2',span) as span1: time.sleep(2) # 調(diào)用server2方法 print("server2") with Recorder('server3',span1) as span2: time.sleep(0.5) # 調(diào)用server3方法 print("server3") #單獨(dú)調(diào)用記錄 with Recorder('server4') as span_test1: time.sleep(1.5) print("server4") with Recorder('server5') as span_test2: time.sleep(2) print("server5")
運(yùn)行結(jié)果:
server1 server2 server3 {'id': 224716339449765695394515303164364012192, 'data': {'spanid': 224716339449765695394515303164364012192, 'servername': 'server3', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server3', 'ip': '', 'durationtime': 0.5004403591156006, 'starttime': 1598947338.0551107, 'endtime': 1598947338.555551, 'tag': '', 'log': '', 'root_span_flag': False, 'child_span': None}} {'id': 254736847532758359233387151739984206570, 'data': {'spanid': 254736847532758359233387151739984206570, 'servername': 'server2', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server2', 'ip': '', 'durationtime': 2.501264810562134, 'starttime': 1598947336.0542862, 'endtime': 1598947338.555551, 'tag': '', 'log': '', 'root_span_flag': False, 'child_span': {'spanid': 224716339449765695394515303164364012192, 'servername': 'server3', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server3', 'ip': '', 'durationtime': 0.5004403591156006, 'starttime': 1598947338.0551107, 'endtime': 1598947338.555551, 'tag': '', 'log': '', 'root_span_flag': False, 'child_span': None}}} {'id': 91028031631192607088457781914309166266, 'data': {'spanid': 91028031631192607088457781914309166266, 'servername': 'server1', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server1', 'ip': '', 'durationtime': 3.5021069049835205, 'starttime': 1598947335.0534441, 'endtime': 1598947338.555551, 'tag': 'test', 'log': '', 'root_span_flag': True, 'child_span': {'spanid': 254736847532758359233387151739984206570, 'servername': 'server2', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server2', 'ip': '', 'durationtime': 2.501264810562134, 'starttime': 1598947336.0542862, 'endtime': 1598947338.555551, 'tag': '', 'log': '', 'root_span_flag': False, 'child_span': {'spanid': 224716339449765695394515303164364012192, 'servername': 'server3', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server3', 'ip': '', 'durationtime': 0.5004403591156006, 'starttime': 1598947338.0551107, 'endtime': 1598947338.555551, 'tag': '', 'log': '', 'root_span_flag': False, 'child_span': None}}}} server4 {'id': 103171729522922437998918618387133480096, 'data': {'spanid': 103171729522922437998918618387133480096, 'servername': 'server4', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server4', 'ip': '', 'durationtime': 1.5001769065856934, 'starttime': 1598947338.555551, 'endtime': 1598947340.055728, 'tag': '', 'log': '', 'root_span_flag': True, 'child_span': None}} server5 {'id': 320091321623887285825256878422834254741, 'data': {'spanid': 320091321623887285825256878422834254741, 'servername': 'server5', 'location': 'D:\\python_protest\\protest\\trace\\trace_main.server5', 'ip': '', 'durationtime': 2.0005736351013184, 'starttime': 1598947340.055728, 'endtime': 1598947342.0563016, 'tag': '', 'log': '', 'root_span_flag': True, 'child_span': None}}
關(guān)于下一步,會(huì)使用redis存儲(chǔ)其結(jié)果,并進(jìn)行相應(yīng)的輸出分析。
修過不能追蹤同級(jí)調(diào)用的問題
import uuid import os import time l = [] class Recorder(object): def __init__(self,servername,root_span = None): if root_span == None: self.__span = Span(servername) else: self.__span = Span(servername,root_span) #上下文管理器 def __enter__(self): return self.__span # 退出方法中,用來實(shí)現(xiàn)善后處理工作 def __exit__(self, exc_type, exc_val, exc_tb): self.__span.record() self.__span.record_save(self.__span.span) class Span(object): def __init__(self,servername,root_span = None): self.servername = servername self.span = self.newspan() if root_span != None: root_span.dic['child_span'].append(self.span) self.span["root_span_flag"] = False def newspan(self): self.dic = { "spanid": uuid.uuid4().int, "servername": self.servername, "location": "", "ip": "", "durationtime": 0, "starttime": time.time(), "endtime":0, "tag": "", "log": "", "root_span_flag":True, "child_span": [] } return self.dic def record_save(self, span): currenttracer = {"id": span["spanid"], "data": span} print(currenttracer) l.append(currenttracer) def record(self): self.span["servername"] = self.servername self.span["location"] = os.getcwd() + "." + self.servername self.span["endtime"] = time.time() self.span["durationtime"] = self.span["endtime"] - self.span["starttime"] def setspantag(self,tag): self.span["tag"] = tag def setspanlog(self,log): self.span["log"] = log # 連續(xù)調(diào)用 with Recorder('server1') as span: time.sleep(1) span.setspantag("test") #調(diào)用server1方法 print("server1") with Recorder('server2',span) as span1: time.sleep(2) # 調(diào)用server2方法 print("server2") with Recorder('server3',span1) as span2: time.sleep(0.5) # 調(diào)用server3方法 print("server3") # 并級(jí)連續(xù)調(diào)用 # with Recorder('server1') as span1: # time.sleep(1) # span1.setspantag("test") # #調(diào)用server1方法 # print("server1") # with Recorder('server2',span1) as span2: # time.sleep(2) # # 調(diào)用server2方法 # print("server2") # with Recorder('server3',span1) as span3: # time.sleep(0.5) # # 調(diào)用server3方法 # print("server3") # #單獨(dú)調(diào)用記錄 # with Recorder('server4') as span_test1: # time.sleep(1.5) # print("server4") # # with Recorder('server5') as span_test2: # time.sleep(2) # print("server5")
關(guān)于怎么在Python項(xiàng)目中調(diào)用追蹤就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。