Golang Kubernetes怎么为客户端开启OpenTelemetry追踪-Golang-PHP中文网

因为 client-go 构造 restclient 时会拷贝并封装 config.transport，实际使用内部封装体而非原始 roundtripper；必须在初始化前替换 http.defaulttransport 并保留原有配置（如 tls、超时），否则 opentelemetry 追踪不生效。

golang kubernetes怎么为客户端开启opentelemetry追踪

为什么直接给 `rest.Config` 加 `http.RoundTripper` 不生效？

因为 Kubernetes 官方客户端（k8s.io/client-go）在构造 rest.RESTClient 时，会把传入的 rest.Config.Transport 拷贝一份并封装成内部 transport，后续所有 HTTP 请求走的是这个封装体，而非你原始设置的 RoundTripper。所以即使你给 config.Transport 赋了一个带 OpenTelemetry 的 otelhttp.Transport，它也不会被实际使用。

真正起作用的是 client-go 内部创建的 transport，它默认基于 http.DefaultTransport —— 这就是为什么必须在 client 初始化前，用 http.DefaultTransport 替换为带追踪能力的 transport。

不要改 config.Transport，它会被忽略
必须提前替换 http.DefaultTransport，且需保留原有配置（如 TLS、超时等）
替换时机：在调用 rest.InClusterConfig() 或 clientcmd.BuildConfigFromFlags() 之前

如何用 `otelhttp.NewTransport` 包装默认 transport？

OpenTelemetry Go SDK 提供了 otelhttp.NewTransport，它能将任意 http.RoundTripper 变成自动注入 trace context 的版本。但注意：它不修改底层行为，只做拦截和 span 创建，所以原 transport 的 TLS 设置、代理、重试逻辑全保留。

典型写法：

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

import (
    "net/http"
    "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
    "go.opentelemetry.io/otel"
)

// 在 main() 开头或 client 初始化前执行
originalTransport := http.DefaultTransport.(*http.Transport).Clone()
http.DefaultTransport = otelhttp.NewTransport(originalTransport)

Clone() 是关键：避免污染全局 transport 配置（比如其他库也依赖 DefaultTransport）
如果用了自定义 CA 或 client cert，需手动复制到 originalTransport 的 TLSClientConfig
若启用了 otelhttp.WithFilter，记得过滤掉健康检查路径（如 /readyz），否则会刷爆 spans

怎么让 client-go 的每个请求都带上 traceparent？

仅替换 transport 只能实现「出向请求」自动注入 traceparent header，但 Kubernetes 客户端本身不会为每个 API 调用生成 span —— 它不感知 OpenTelemetry。你需要手动 wrap 每个 client 方法调用，或更实用的做法：用 otelhttp.WithSpanNameFormatter 让 span 名体现资源类型和动词。

例如：

http.DefaultTransport = otelhttp.NewTransport(originalTransport, otelhttp.WithSpanNameFormatter(func(_ string, r *http.Request) string {
    if r.URL == nil {
        return "kubernetes-request"
    }
    path := r.URL.Path
    // /api/v1/namespaces/default/pods → "Pods GET"
    if strings.Contains(path, "/pods") {
        return "Pods " + r.Method
    }
    if strings.Contains(path, "/deployments") {
        return "Deployments " + r.Method
    }
    return r.Method + " " + path
}))

不建议为每个 client.Get()、client.List() 单独 start span：client-go 底层已封装多层 retry、watch、codec，手动埋点易漏或重复
span name 必须可区分：避免全叫 HTTP GET，否则在 Jaeger 里无法下钻定位具体资源操作
如果用了 dynamic client（dynamic.Interface），同样走 HTTP transport，无需额外处理

为什么 Pod 里跑的 client 看不到 trace 数据？

常见原因是 OTLP exporter 没连上 collector，或者 collector 没配好接收 endpoint。Kubernetes Pod 默认 DNS 域是 default.svc.cluster.local，而很多人在代码里写死 localhost:4317 —— 这在容器里根本连不通。

exporter endpoint 必须用 service 名：如 otel-collector.default.svc:4317
确认 collector service 允许该 namespace 的 pod 访问（NetworkPolicy / RBAC）
加一行日志验证 tracer 是否初始化成功：otel.GetTracerProvider().Tracer("k8s-client") 返回非 nil 才算接入成功
如果用的是 jaeger exporter（非 OTLP），注意 jaeger-agent 已废弃，优先用 OTLP over gRPC

最常被跳过的一步：没调用 otel.Tracer("...").Start() 触发 tracer 初始化，导致整个链路静默失效 —— OpenTelemetry Go 是 lazy-init 的，不显式用就不会加载 exporter。