终极套娃 2.0｜云原生 PaaS 平台的可观测性实践分享

某个周一上午，小涛像往常一样泡上一杯热咖啡 ☕️，准备打开项目协同开始新一天的工作，突然隔壁的小文喊道：“快看，用户支持群里炸锅了 …”

用户 A：“Git 服务有点问题，代码提交失败了！”

用户 B：“帮忙看一下，执行流水线报错……”

用户 C：“我们的系统今天要上线，现在部署页面都打不开了，都要急坏了！”

用户 D：……

小涛只得先放下手中的咖啡，屏幕切换到堡垒机，登录到服务器上一套行云流水的操作，“哦，原来是上周末上线的代码漏了一个参数验证造成 panic 了”，小涛指着屏幕上一段容器的日志对小文说到。

十分钟后，小文使用修复后的安装包更新了线上的系统，用户的问题也得到了解决。

虽然故障修复了，但是小涛也陷入了沉思，“为什么我们没有在用户之前感知到系统的异常呢？现在排查问题还需要登录到堡垒机上看容器的日志，有没有更快捷的方式和更短的时间里排查到线上故障发生的原因？”

这时，坐在对面的小 L 说道：“我们都在给用户讲帮助他们实现系统的可观测性，是时候 Erda 也需要被观测了。”

小涛：“那要怎么做呢…？”且听我们娓娓道来～

通常情况下，我们会搭建独立的分布式追踪、监控和日志系统来协助开发团队解决微服务系统中的诊断和观测问题。但同时 Erda 本身也提供了功能齐全的服务观测能力，而且在社区也有一些追踪系统（比如 Apache SkyWalking 和 Jaeger）都提供了自身的可观测性，给我们提供了使用平台能力观测自身的另一种思路。

最终，我们选择了在 Erda 平台上实现 Erda 自身的可观测，使用该方案的考虑如下：

平台已经提供了服务观测能力，再引入外部平台造成重复建设，对平台使用的资源成本也有增加
开发团队日常使用自己的平台来排查故障和性能问题，吃自己的狗粮对产品的提升也有一定的帮助
对于可观测性系统的核心组件比如 Kafka 和数据计算组件，我们通过 SRE 团队的巡检工具来旁路覆盖，并在出问题时触发报警消息

Erda 微服务观测平台提供了 APM、用户体验监控、链路追踪、日志分析等不同视角的观测和诊断工具，本着物尽其用的原则，我们也把 Erda 产生的不同观测数据分别进行了处理，具体的实现细节且继续往下看。

OpenTelemetry 数据接入

在之前的文章里我们介绍了如何在 Erda 上接入 Jaeger Trace ，首先我们想到的也是使用 Jaeger Go SDK 作为链路追踪的实现，但 Jaeger 作为主要实现的 OpenTracing 已经停止维护，因此我们把目光放到了新一代的可观测性标准 OpenTelemetry 上面。

OpenTelemetry 是 CNCF 的一个可观测性项目，由 OpenTracing 和 OpenCensus 合并而来，旨在提供可观测性领域的标准化方案，解决观测数据的数据模型、采集、处理、导出等的标准化问题，提供与三方 vendor 无关的服务。

如下图所示，在 Erda 可观测性平台接入 OpenTelemetry 的 Trace 数据，我们需求在 gateway 组件实现 otlp 协议的 receiver，并且在数据消费端实现一个新的 span analysis组件把 otlp 的数据分析为 Erda APM 的可观测性数据模型。

其中，gateway 组件使用 Golang 轻量级实现，核心的逻辑是解析 otlp 的 proto 数据，并且添加对租户数据的鉴权和限流。

关键代码参考 receivers/opentelemetry

span_analysis 组件基于 Flink 实现，通过 DynamicGap 时间窗口，把 opentelemetry 的 span 数据聚合分析后产生如下的 Metrics：

service_node 描述服务的节点和实例
servicecall* 描述服务和接口的调用指标，包括 HTTP、RPC、DB 和 Cache
servicecall*_error 描述服务的异常调用，包括 HTTP、RPC、DB 和 Cache
service_relation 描述服务之间的调用关系

同时 span_analysis 也会把 otlp 的 span 转换为 Erda 的 span 标准模型，将上面的 metrics 和转换后的 span 数据流转到 kafka ，再被 Erda 可观测性平台的现有数据消费组件消费和存储。

关键代码参考 analyzer/tracing

通过上面的方式，我们就完成了 Erda 对 OpenTelemetry Trace 数据的接入和处理。

接下来，我们再来看一下 Erda 自身的服务是如何对接 OpenTelemetry。

Golang 无侵入的调用拦截

Erda 作为一款云原生 PaaS 平台，也理所当然的使用云原生领域最流行的 Golang 进行开发实现，但在 Erda 早期的时候，我们并没有在任何平台的逻辑中预置追踪的埋点。所以即使在 OpenTelemetry 提供了开箱即用的 Go SDK 的情况下，我们只在核心逻辑中进行手动的 Span 接入都是一个需要投入巨大成本的工作。

在我之前的 Java 和 .NET Core 项目经验中，都会使用 AOP 的方式来实现性能和调用链路埋点这类非业务相关的逻辑。虽然 Golang 语言并没有提供类似 Java Agent 的机制允许我们在程序运行中修改代码逻辑，但我们仍从 monkey 项目中受到了启发，并在对 monkey 、pinpoint-apm/go-aop-agent 和 gohook 进行充分的对比和测试后，我们选择了使用 gohook 作为 Erda 的 AOP 实现思路，最终在 erda-infra 中提供了自动追踪埋点的实现。

关于 monkey 的原理可以参考 monkey-patching-in-go

以 http-server 的自动追踪为例，我们的核心实现如下：

代码语言：go

复制

//go:linkname serverHandler net/http.serverHandler
type serverHandler struct {
  srv *http.Server
}
//go:linkname serveHTTP net/http.serverHandler.ServeHTTP

//go:noinline

func serveHTTP(s *serverHandler, rw http.ResponseWriter, req *http.Request)
//go:noinline

func originalServeHTTP(s *serverHandler, rw http.ResponseWriter, req *http.Request) {}
var tracedServerHandler = otelhttp.NewHandler(http.HandlerFunc(func(rw http.ResponseWriter, r *http.Request) {

injectcontext.SetContext(r.Context())

defer injectcontext.ClearContext()

s := getServerHandler(r.Context())

originalServeHTTP(s, rw, r)

}), "", otelhttp.WithSpanNameFormatter(func(operation string, r *http.Request) string {

u := *r.URL

u.RawQuery = ""

u.ForceQuery = false

return r.Method + " " + u.String()

}))
type _serverHandlerKey int8
const serverHandlerKey _serverHandlerKey = 0
func withServerHandler(ctx context.Context, s *serverHandler) context.Context {

return context.WithValue(ctx, serverHandlerKey, s)

}
func getServerHandler(ctx context.Context) *serverHandler {

return ctx.Value(serverHandlerKey).(*serverHandler)

}
//go:noinline

func wrappedHTTPHandler(s *serverHandler, rw http.ResponseWriter, req *http.Request) {

req = req.WithContext(withServerHandler(req.Context(), s))

tracedServerHandler.ServeHTTP(rw, req)

}
func init() {

hook.Hook(serveHTTP, wrappedHTTPHandler, originalServeHTTP)

}

在解决了 Golang 的自动埋点后，我们还遇到的一个棘手问题是在异步的场景中，因为上下文的切换导致 TraceContext 无法传递到下一个 Goroutine 中。同样在参考了 Java 的 Future 和 C# 的 Task 两种异步编程模型后，我们也实现了自动传递 Trace 上下文的异步 API：

代码语言：go

复制

future1 := parallel.Go(ctx, func(ctx context.Context) (interface{}, error) {

req, err := http.NewRequestWithContext(ctx, http.MethodGet, "http://www.baidu.com/api_1", nil)

if err != nil {

return nil, err

}

resp, err := http.DefaultClient.Do(req)

if err != nil {

return nil, err

}

defer resp.Body.Close()

byts, err := ioutil.ReadAll(resp.Body)

if err != nil {

return nil, err

}

return string(byts), nil

})
future2 := parallel.Go(ctx, func(ctx context.Context) (interface{}, error) {

req, err := http.NewRequestWithContext(ctx, http.MethodGet, "http://www.baidu.com/api_2", nil)

if err != nil {

return nil, err

}

resp, err := http.DefaultClient.Do(req)

if err != nil {

return nil, err

}

defer resp.Body.Close()

byts, err := ioutil.ReadAll(resp.Body)

if err != nil {

return nil, err

}

return string(byts), nil

}, parallel.WithTimeout(10*time.Second))
body1, err := future1.Get()

if err != nil {

return nil, err

}
body2, err := future2.Get()

if err != nil {

return nil, err

}
return &pb.HelloResponse{

Success: true,

Data:    body1.(string) + body2.(string),

}, nil