(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210691815.3 (22)申请日 2022.06.17 (71)申请人 中国电信股份有限公司 地址 100033 北京市西城区金融大街31号 (72)发明人 郑永坤　陈康　陈翀　付华峥　 韦登荣　 (74)专利代理 机构 北京律智知识产权代理有限 公司 11438 专利代理师 孙宝海 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/2458(2019.01) (54)发明名称 分布式调用链的处理方法及装置、 存储介 质、 电子设备 (57)摘要 本公开是关于一种分布式调用链的处理方 法及装置、 存储介质、 电子设备， 涉及计算机技术 领域， 该方法包括： 拦截原始日志数据， 并对所述 原始日志数据进行解析， 得到所述原始日志数据 中包括的具有第一数据格式的分布式调用链； 对 所述具有第一数据格式的分布式调用链进行格 式转换， 得到具有第二数据格式的分布式调用 链； 基于预设的压缩算法对所述具有第二数据格 式的分布式调用链进行数据压缩， 得到压缩后的 分布式调用链； 将所述压缩后的分布式调用链发 送至Kafka集群， 以使得所述Kafka集群对所述压 缩后的分布式调用链进行存储。 本公开提高了数 据的完整性。 权利要求书2页 说明书14页 附图6页 CN 115017218 A 2022.09.06 CN 115017218 A 1.一种分布式调用链的处 理方法， 其特 征在于， 包括： 拦截原始日志数据， 并对所述原始日志数据进行解析， 得到所述原始日志数据中包括 的具有第一数据格式的分布式调用链； 对所述具有第 一数据格式的分布式调用链进行格式转换， 得到具有第 二数据格式的分 布式调用链； 基于预设的压缩算法对所述具有第 二数据格式的分布式调用链进行数据压缩， 得到压 缩后的分布式调用链； 将所述压缩后的分布式调用链发送至Kafk a集群， 以使得所述Kafka集群对所述压缩后 的分布式调用链进行存 储。 2.根据权利要求1所述的分布式调用链的处理方法， 其特征在于， 所述第 一数据格 式为 以键值对形式呈现的对象结构数据格式， 所述第二数据格式为标准的JSON字符串格式； 其中， 对所述具有第一数据格式的分布式调用链进行格式转换， 得到具有第二数据格 式的分布式调用链， 包括： 将以键值对形式呈现的对象结构数据格 式的分布式调用链， 转换为标准的JSON字符串 格式的分布式调用链。 3.根据权利要求1所述的分布式调用链的处理方法， 其特征在于， 所述预设的压缩算法 包括GZIP压缩算法； 其中， 基于预设的压缩算法对所述具有第二数据格式的分布式调用链进行数据压缩， 得到压缩后的分布式调用链， 包括： 构建GZIP格式文件的文件头以及GZIP格式文件的文件尾， 并对所述具有第二数据格 式 的分布式调用链进行解析， 得到所述具有第二数据格式的分布式调用链中包括的原文、 匹 配长度以及偏移 距离； 对原文、 匹配长度以及偏移距离进行霍夫曼编码， 得到具有Deflate格式的数据块， 并 对所述文件头、 文件尾以及具有Deflate格式的数据块进 行封装， 得到压缩后的分布式调用 链。 4.根据权利要求3所述的分布式调用链的处理方法， 其特征在于， 构建GZIP格 式文件的 文件头， 包括： 将所述文件头中的GZIP格式校验码的第一字节设置为第一预设值， 并将所述GZIP格 式 校验码的第二字节设置为第二预设值； 将所述文件头 中的压缩算法标识符设置为第 三预设值， 并将所述文件头 中的标志位的 各比特位设置为 零； 将所述文件头 中的源文件时间戳设置为当前时间， 并将所述文件头 中的附加标志以及 操作系统标志均设置为第四预设值。 5.根据权利要求1所述的分布式调用链的处理方法， 其特征在于， 拦截原始日志数据， 并对所述原始日志数据进 行解析， 得到所述原始日志数据中包括的具有第一数据格式的分 布式调用链， 包括： 在应用性 能管理工具中对日志数据采集程序的源码进行修改， 得到具有数据拦截功能 的数据拦截程序； 对源码修改后的应用性 能管理工具进行编译部署， 并基于编译部署后的应用性 能管理权　利　要　求　书 1/2 页 2 CN 115017218 A 2工具中的数据拦截程序拦截所述原 始日志数据； 对拦截到的原始日志数据进行内部转换， 得到所述原始日志数据中包括的具有第 一数 据格式的分布式调用链。 6.根据权利要求1 ‑5任一项所述的分布式调用链的处理方法， 其特征在于， 所述分布式 调用链中包括应用名、 事务ID、 当前跨度信息的ID、 上游 跨度信息的ID、 应用启动时间、 应用 响应时间、 应用所调用的接口名称以及所述应用耗时中的多种。 7.根据权利要求6 中所述的分布式调用链的处理方法， 其特征在于， 所述分布式调用链 的处理方法还 包括： 从所述Kafka存储集群中获取压缩后的分布式调用链， 并对所述压缩后的分布式调用 链进行解压缩， 得到所述分布式调用链中包括的应用名、 事务ID、 当前跨度信息的ID、 上游 跨度信息的ID、 应用启动时间、 应用响应时间、 应用所调用的接口名称以及所述应用耗时； 根据所述应用名、 事务ID、 当前跨度信息的ID、 上游跨度信息的ID、 应用启动时间、 应用 响应时间、 应用所调用的接口名称以及所述应用耗时生成软硬件知识图谱； 根据所述事务ID获取原始日志数据以及所述原始日志数据中包括的原始指标数据， 并 基于预设的时序神经网络模型对所述原 始日志数据以及原 始指标数据的异常进行 预测； 若预测结果为所述原始日志数据以及原始指标数据存在异常， 则根据 所述软硬件知识 图谱对异常根因进行定位， 并基于 定位结果进行异常告警。 8.一种分布式调用链的处 理装置， 其特 征在于， 包括： 日志数据拦截模块， 用于拦截原始日志数据， 并对所述原始日志数据进行解析， 得到所 述原始日志数据中包括的具有第一数据格式的分布式调用链； 格式转换模块， 用于对所述具有第一数据格式的分布式调用链进行格式转换， 得到具 有第二数据格式的分布式调用链； 数据压缩模块， 用于基于预设的压缩算法对所述具有第 二数据格式的分布式调用链进 行数据压缩， 得到 压缩后的分布式调用链； 分布式调用链存储模块， 用于将所述压缩后的分布式调用链发送至Kafka集群， 以使得 所述Kafka集群对所述压缩后的分布式调用链进行存 储。 9.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序被 处理器执行时实现权利要求1 ‑7任一项所述的分布式调用链的处 理方法。 10.一种电子设备， 其特 征在于， 包括： 处理器； 以及 存储器， 用于存 储所述处 理器的可 执行指令； 其中， 所述处理器配置为经由执行所述可执行指令来执行权利要求1 ‑7任一项所述的 分布式调用链的处 理方法。权　利　要　求　书 2/2 页 3 CN 115017218 A 3