标签: ClickHouse

  • 深入 OpenTelemetry 陷阱排查:全量采样与递归追踪引发的 Collector OOM 与存储 IOPS 雪崩实战

    某次生产环境突发大面积监控盲区故障。链路追踪集群全面崩溃,K8S 上的 otel-collector 疯狂 CrashLoopBackOff,后端 ClickHouse 存储节点 Load Average 飙升至 150+,IOPS 被完全打满。排查发现,业务侧在核心高并发服务(单机 3000+ QPS)中强上了 OpenTelemetry 自动探针,不仅粗暴配置了全量采样(always_on),还触发了经典的“递归追踪”黑洞——探针将上报 Span 的 HTTP 请求本身也打包成了 Span 发送。更可悲的是,付出了打挂存储集群的代价后,业务日志里依然没有注入 trace_id,导致 TB 级的废数据根本无法与日志关联。结论很简单:分布式追踪必须在 Collector 端筑起内存防线(Memory Limiter)并实施尾部采样(Tail-based Sampling),应用端严禁无脑全量采集,且必须滤除 OTLP 自身的出站流量。

    案发现场:指数级暴涨的流量与 OOM

    排查过程始于频繁的 P0 告警:业务侧反馈监控大盘上的 Trace 数据断崖式下跌,且伴随大量核心服务 RT(响应时间)毛刺。

    切到 otel-collector 所在的 K8S 节点,直接敲命令看系统日志:

    dmesg -T | grep -i oom
    # [Mon xxx xx xx:xx:xx 20xx] otelcol invoked oom-killer: gfp_mask=0x100cca(GFP_HIGHUSER_MOVABLE), order=0, oom_score_adj=-998
    # [Mon xxx xx xx:xx:xx 20xx] Memory cgroup out of memory: Killed process 31234 (otelcol) total-vm:4589124kB, anon-rss:2147483kB...
    

    OOMKilled。 Collector 容器的 2GB 内存限制被瞬间击穿。

    再看后端的 ClickHouse 集群,系统盘和数据盘的 IOPS 直接画出了一条垂直向上的直线,达到了底层云盘的吞吐上限。查看 ClickHouse 的 system.query_log,全是在疯狂写入 otel_traces 表。

    为什么流量会突然大到这种地步?我随手抓了一段 Collector Crash 前吐出的残留 Payload,发现了极为荒谬的一幕:

    {
      "name": "HTTP POST",
      "kind": "SPAN_KIND_CLIENT",
      "attributes": [
        { "key": "http.url", "value": "http://otel-collector:4318/v1/traces" },
        { "key": "http.method", "value": "POST" }
      ]
    }
    

    递归追踪黑洞(Recursive Tracing)。

    业务团队在升级某个自定义 HTTP Client 组件时,加上了无差别的全局拦截器。当应用产生业务 Span A,探针通过 HTTP OTLP 将 Span A 发送给 Collector 时,这个 HTTP POST 请求被拦截器捕获,生成了 Span B;接着探针要把 Span B 发送出去,又生成了 Span C…… 相当于在一个对着麦克风的音响面前又放了一个麦克风,伴随着 OTEL_TRACES_SAMPLER=always_on(100% 采样),Span 数量呈指数级核爆,瞬间把 Collector 内存打爆,活下来的那部分流量则顺理成章地打挂了 ClickHouse。

    为什么说这是不可原谅的裸奔?

    这个故障暴露出整个链路追踪工程化落地的三个致命缺陷:

    1. 客户端信任危机与 Collector 零防御 运维架构的第一准则就是“防御性编程”:永远不要信任客户端发来的数据量。otel-collector 原生提供了 memory_limiter,但在出事前的配置文件里,这个核心 Processor 居然是缺失的。没有背压(Backpressure)机制,Collector 就是个毫无防备的漏斗,客户端喂多少它吃多少,直到把自己撑死。

    2. 愚蠢的 Head-Based 100% 采样 在 QPS 动辄上万的微服务集群里开全量采样,除了浪费昂贵的网络带宽和 SSD 寿命,没有任何实际意义。99% 的请求都是状态码 200、RT < 50ms 的正常请求,我们真正需要排查的只有那 1% 的 Error 和 Slow Traces。

    3. 没有 Trace-Log 关联的追踪毫无价值 事后要求业务在正常日志里 grep 一下排查某笔异常交易,结果发现标准输出里根本没有 TraceID。耗费海量资源收集来的 Span,变成了一座无法与业务 Log 互通的数据孤岛,这套系统跟一个极其昂贵的随机数生成器有什么区别?

    架构修复与落地实践

    为了彻底填平这个坑,我们对整个 OTel 链路进行了强制的规范化改造。

    1. 斩断递归链路与注入日志 MDC

    在应用侧探针配置中,强制要求配置环境变量,剔除 OTLP 端口的采集,并开启日志注入:

    # 拒绝采集发往 Collector 的自身流量
    export OTEL_JAVAAGENT_EXCLUDE_CLASSES="org.apache.http.impl.client.OtelCollectorHttpClient"
    # 或者使用标准的压制配置
    export OTEL_INSTRUMENTATION_HTTP_CAPTURE_HEADERS_SERVER_REQUEST=".*" # 视具体探针版本而定
    
    # 极其重要:将 Trace 注入业务日志
    export OTEL_INSTRUMENTATION_LOGBACK_APPENDER_EXPERIMENTAL_LOG_ATTRIBUTES=true
    

    对应的 logback-spring.xml 必须改造 Pattern:

    <!-- 必须包含 %X{trace_id} 和 %X{span_id} -->
    <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} [traceId=%X{trace_id}, spanId=%X{span_id}] - %msg%n</pattern>
    

    2. Collector 端的防御性背压(Backpressure)

    在 otel-collector-config.yaml 中,强制首发启用 memory_limiter 和 batch Processor,构建内存防线:

    processors:
      # 内存硬限:假设 Pod Limit 是 2Gi,这里设置 1.5Gi 开始拒绝接收新数据 (drop/backpressure)
      memory_limiter:
        check_interval: 1s
        limit_mib: 1500
        spike_limit_mib: 300 # 预留给突发流量的缓冲
    
      batch:
        send_batch_size: 10000
        timeout: 5s
    

    3. 落地 Tail-Based Sampling(尾部采样)

    废弃客户端的 always_on,改为 traceidratio (如 1%),并在 Collector 端接管大盘采样逻辑。对于核心链路,使用 tail_sampling 确保异常全量保留,正常请求按比例抽样:

    processors:
      tail_sampling:
        decision_wait: 10s # 等待一个 Trace 的所有 Span 到齐
        num_traces: 50000
        expected_new_traces_per_sec: 5000
        policies:
          [
            {
              name: error-policy,
              type: status_code,
              status_code: {status_codes: [ERROR]} # 错误链路 100% 采样
            },
            {
              name: slow-policy,
              type: latency,
              latency: {threshold_ms: 1000} # 超过 1s 的慢请求 100% 采样
            },
            {
              name: probabilistic-policy,
              type: probabilistic,
              probabilistic: {sampling_percentage: 1} # 正常请求 1% 采样
            }
          ]
    

    注意:尾部采样需要 Collector 集群具备基于 TraceID 的负载均衡(LoadBalancing Exporter)能力,确保同一个 Trace 的所有 Span 落在同一个 Collector 实例上,否则决策会失效。

    排查清单与同类问题速查

    1. Collector 频繁重启 / OOM 检查:立即检查 OTel Collector 的 memory_limiter 配置。未配置此项的 OTel 集群等同于不设防,极易被异常突发流量或重试风暴打挂。

    2. 递归流量黑洞排查:通过 KQL / SQL 快速聚合统计 http.url 属性,排查 Top 10 的请求路径。如果 v1/traces 或 Collector IP 占据榜首,立刻在客户端下发屏蔽规则。

    3. IOPS/存储成本失控检查:核查应用探针的 OTEL_TRACES_SAMPLER 环境变量。生产环境严禁使用 always_on。应推行 Error/Slow 100% 采样 + 正常请求万分之一采样的组合策略。

    4. 日志无法联动检查:如果 Kibana/Loki 中搜不到 TraceID,优先检查应用层日志框架(Logback/Log4j2)的 Layout Pattern 是否包含了 %X{trace_id},并确认探针的日志注入开关(MDC Injection)是否开启。