python函数调用追踪_Python函数调用追踪实现代码
對(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還有其它需要從上游服務(wù)傳遞到下游服務(wù)的信息。
我實(shí)現(xiàn)了一種簡(jiǎn)單的調(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
# 退出方法中，用來(lái)實(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)的輸出分析。
修過(guò)不能追蹤同級(jí)調(diào)用的問(wèn)題
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
# 退出方法中，用來(lái)實(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")
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持。
總結(jié)
以上是生活随笔為你收集整理的python函数调用追踪_Python函数调用追踪实现代码的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： python mysql异地备份_pyt
- 下一篇： python typeerror con