Go OpenTelemetry 高级实战Collector Span Processor Baggage 全攻略上一篇讲了基础本文进阶OTel Collector 部署、Span Processor 二次开发、Baggage 业务传值。一、为何使用 Collector业务 SDK 不直接对接 Jaeger / Tempo而是基于 OTLP 把数据发到 Collector。Collector 做接收 OTLPgRPC/HTTP后端过滤 / 采样 / enrich路由trace / metrics / logsSDK → OTLP → Collector → Jaeger/Tempo/Prometheus二、otel-collector 配置receivers:otlp:protocols:grpc:{endpoint:0.0.0.0:4317}http:{endpoint:0.0.0.0:4318}processors:batch:{}filter:trace:span:-attributes[http.target] /healthzexporters:jaeger:endpoint:jaeger:14250prometheusremotewrite:endpoint:prom:9201service:pipelines:traces:receivers:[otlp]processors:[batch,filter]exporters:[jaeger]三、自定义 SpanProcessorimportsdktracego.opentelemetry.io/otel/sdk/tracetypeFilterProcessorstruct{sdktrace.SpanProcessor}func(p FilterProcessor)OnStart(ctx context.Context,span sdktrace.ReadWriteSpan){ifspan.Name()/healthz{span.SetAttributes(attribute.Bool(drop,true))}}注册bsp:sdktrace.NewBatchSpanProcessor(exp)tp:sdktrace.NewTracerProvider(sdktrace.WithSpanProcessor(FilterProcessor{...}))四、Baggage 实战bag:baggage.New(map[string]string{user_id:42})ctxbaggage.ContextWithBaggage(ctx,bag)span:trace.SpanFromContext(ctx)span.AddEvent(business)下游服务取出b:baggage.FromContext(ctx)for_,m:rangeb.Members(){fmt.Println(m.Key,m.Value)}五、Trace 与 Log 关联slog.With(trace_id,trace.SpanFromContext(ctx).SpanContext().TraceID().String(),).Info(processing)Grafana Loki 自动带 trace ID。六、Trace Metrics 全链路meter:otel.Meter(user-service)requestCounter,_:meter.Int64Counter(user.requests)ctx,span:tracer.Start(ctx,GetUser)deferspan.End()requestCounter.Add(ctx,1,attribute.String(status,ok))七、采样策略sampler:sdktrace.ParentBased(sdktrace.TraceIDRatioBased(0.1))// 完整保留错误请求路径error八、Context 透传importgo.opentelemetry.io/otel/propagationotel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{},propagation.Baggage{},))// serverctxotel.GetTextMapPropagator().Extract(ctx,propagation.HeaderCarrier(r.Header))// clientotel.GetTextMapPropagator().Inject(ctx,propagation.HeaderCarrier(r.Header))九、Receiver / Exporter 拓展packagemainimportgo.opentelemetry.io/collector/extension/zpagesextensionfactory:zpagesextension.NewFactory()十、踩坑清单OTel collector 可能丢 trace配置 batch retry服务报告版本exporter version 必兼容Baggage 不放敏感数据会被任意中间 exporter 看到十一、企业实战全链路统计-- ErrorReporter (sampling) SDK -- OTel ---- TraceExporter - Tempo -- Metric - Prometheus十二、未来Trace AI异常检测 → Root Cause AnalysiseBPF / Pixie 可以不打 SDK 就抓 kernel trace未来统一可观测平台。十三、总结与展望OTel 是一套完整的可观测性工具链。从 SDK 到 Collector从 Span 到 Metric Baggage运筹帷幄。未来云原生化 / AI 化会让它真正成为开发运维一体的中枢。十四、参考文献OpenTelemetry 官方文档otel-collector-contribOTel OperatorK8s