DDR爱好者之家 Design By 杰米
对于分布式追踪，主要有以下的几个概念：
- 追踪 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")
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
DDR爱好者之家 Design By 杰米
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
DDR爱好者之家 Design By 杰米
暂无评论...
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。
更新日志
2024年11月24日
2024年11月24日
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]