Tips: 中间记录了解决问题的过程,如不感兴趣可直接跳至结尾
-
首先去es里查询skywalking trace的元数据
可以拿到一串base64加密后的data_binary
(直接解密不能用,会有乱码,可参考https://github.com/apache/skywalking/issues/7423) -
对
data_binary
进行base64解密
skywalking提供了一个java的sdk可以直接分析这串内容,代码如下所示:
String dataBinary= "xxxxxx"
byte[]decode = Base64.getDecoder().decode(dataBinary);
SegmentObject segmentObject = SegmentObject.parseFrom(decode);
System.out.println(JSON.toJSONString(segmentObject));
segmentObject
内有我们所有需要的数据,但golang并未找到类似的函数,所以我们需要用golang实现类似parseFrom()
的逻辑,我们先看一下java的源码
public static SegmentObject parseFrom(byte[] data) throws InvalidProtocolBufferException {
return (SegmentObject)PARSER.parseFrom(data);
}
它的本质就是调用com.google.protobuf
提供的parseFrom()
函数,所以我们只需要用golang版本的proto去反序列化base64解密后的byte即可
- 反序列化
我先尝试了将java版本的SegmentObject转成json,再转成proto文件,然后生成pb.go,用这里生成的SegmentObject
去进行反序列化,发现并不可行文章来源:https://www.toymoban.com/news/detail-757199.html
最后是通过skywalking-go版本agent的源码,找到了对应的pb文件
然后使用里面已经编译好的SegmentObject
对象即可文章来源地址https://www.toymoban.com/news/detail-757199.html
import (
"encoding/base64"
"fmt"
"google.golang.org/protobuf/proto"
"testing"
agent "skywalking.apache.org/repo/goapi/collect/language/agent/v3"
)
func TestSkyWalking(t *testing.T) {
dataBinary := "xxx"
by, err := base64.StdEncoding.DecodeString(dataBinary)
if err != nil {
t.Error(err)
}
segmentObject := &agent.SegmentObject{}
err = proto.Unmarshal(by, segmentObject)
fmt.Printf("%v", segmentObject)
}
到了这里,关于Golang版本处理Skywalking Trace上报数据的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!