對于分布式追蹤，主要有以下的幾個概念：

追蹤 Trace：就是由分布的微服務協作所支撐的一個事務。一個追蹤，包含為該事務提供服務的各個服務請求。

跨度 Span：Span是事務中的一個工作流，一個Span包含了時間戳，日志和標簽信息。Span之間包含父子關系，或者主從(Followup)關系。

跨度上下文 Span Context：跨度上下文是支撐分布式追蹤的關鍵，它可以在調用的服務之間傳遞，上下文的內容包括諸如：從一個服務傳遞到另一個服務的時間，追蹤的ID，Span的ID還有其它需要從上游服務傳遞到下游服務的信息。

我實現了一種簡單的調用追蹤。

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

# 退出方法中，用來實現善后處理工作

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

# 連續調用

with Recorder('server1') as span:

time.sleep(1)

span.setspantag("test")

#調用server1方法

print("server1")

with Recorder('server2',span) as span1:

time.sleep(2)

# 調用server2方法

print("server2")

with Recorder('server3',span1) as span2:

time.sleep(0.5)

# 調用server3方法

print("server3")

#單獨調用記錄

with Recorder('server4') as span_test1:

time.sleep(1.5)

print("server4")

with Recorder('server5') as span_test2:

time.sleep(2)

print("server5")

運行結果：

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}}

關于下一步，會使用redis存儲其結果，并進行相應的輸出分析。

修過不能追蹤同級調用的問題

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

# 退出方法中，用來實現善后處理工作

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

# 連續調用

with Recorder('server1') as span:

time.sleep(1)

span.setspantag("test")

#調用server1方法

print("server1")

with Recorder('server2',span) as span1:

time.sleep(2)

# 調用server2方法

print("server2")

with Recorder('server3',span1) as span2:

time.sleep(0.5)

# 調用server3方法

print("server3")

# 并級連續調用

# with Recorder('server1') as span1:

# time.sleep(1)

# span1.setspantag("test")

# #調用server1方法

# print("server1")

# with Recorder('server2',span1) as span2:

# time.sleep(2)

# # 調用server2方法

# print("server2")

# with Recorder('server3',span1) as span3:

# time.sleep(0.5)

# # 調用server3方法

# print("server3")

# #單獨調用記錄

# with Recorder('server4') as span_test1:

# time.sleep(1.5)

# print("server4")

#

# with Recorder('server5') as span_test2:

# time.sleep(2)

# print("server5")

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持。

總結

以上是生活随笔為你收集整理的python函数调用追踪_Python函数调用追踪实现代码的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。