当前位置: 首页 > 工具软件 > OpenTelemetry > 使用案例 >

Opentelemetry 采样最佳实践

郝池暝
2023-12-01

全链路数据确实能够很好的帮助相关人员及时、准确的发现业务问题。但企业业务发生问题的概率一般都很低,全链路采样有着自身的优缺点。

优点

  • 链路数据健全

缺点

  • 资源浪费。由于数据健全导致数据存储资源成本大大提高,对于异常链路数据检索成本提高

基于全链路数据采集的采样,OpenTelemetry 支持两种类型的采样器

1、概率采样器(probabilisticsamplerprocessor)

2、尾部采样器(tailsamplingprocessor)

概率采样处理器

顾名思义,概率采样器,是按照某种概率进行采样。同样OpenTelemetry 支持两种概率采样

1、sampling.priority OpenTracing 定义的语义约定

2、TraceId hash

sampling.priority语义约定优先于 TraceId hash。顾名思义,TraceId hash 采样基于由TraceId 确定的 hash 值。为了使 TraceId hash 起作用,给定层的所有收集器(例如,在同一负载均衡器后面)必须具有相同的hash_seed. 也可以利用hash_seed不同收集器层的不同来支持额外的采样要求。有关配置规范,请参阅 config.go

可以修改以下配置选项:

  • hash_seed(无默认值):用于计算哈希算法的整数。请注意,给定层的所有收集器(例如,在同一个负载均衡器后面)应该具有相同的 hash_seed。

    在使用多层采集器实现所需采样率的情况下,这一点很重要,例如:第一层为10%,第二层为10%,总体采样率为1%(10%x 10%)。

    如果所有层使用相同的种子,则通过一层的所有数据也将通过下一层,与配置的采样率无关。在不同的层中有不同的种子可以确保每层中的采样率按预期工作。

  • sampling_percentage(默认值 = 0):对 trace 进行采样的百分比;>= 100 表示采集所有的 trace。

配置概率采样器

processors:
  # 概率采样器
  probabilistic_sampler:
    hash_seed: 22
    sampling_percentage: 15.3

启用概率采样器

service:
  extensions: [pprof, zpages, health_check]
  pipelines:
    traces:
      receivers: [otlp]
      processors: [batch,probabilistic_sampler]
      exporters: [otlp]
    metrics:
      receivers: [otlp]
      processors: [batch]
      exporters: [otlp]

尾部采样器

尾部采样处理器根据一组定义的策略对 trace 进行采样。目前,该处理器仅适用于 collector 的单个实例。从技术上讲,traceId 感知负载平衡可用于支持多个 collector 实例,但此配置尚未经过测试。有关配置规范,请参阅 config.go

需要以下配置选项:

  • policies(无默认值):用于做出抽样决策的策略

目前支持多种策略。这些包括:

  • always_sample:采样所有的 traces
  • latency:基于 trace 持续时间的采样。持续时间是通过查看最早的开始时间和最晚的结束时间来确定的,而不考虑两者之间发生的事情。
  • numeric_attribute: 基于数字属性的采样
  • probabilistic:采样一定百分比的 trace 。
  • status_code: 基于状态码的示例 ( OK,ERRORUNSET)。很多人当做是response body json的 code(现在很多项目都这么定义),其实是不对的。
  • string_attribute:基于字符串属性值匹配的采样,支持精确匹配和正则表达式值匹配
  • rate_limiting: 基于速率的采样
  • and:基于多个策略的采样,创建一个 AND 策略
  • composite:基于上述采样器组合的采样,每个采样器具有排序和速率分配。费率分配为每个保单订单分配一定百分比的跨度。例如,如果我们将 max_total_spans_per_second 设置为 100,那么我们可以将 rate_allocation 设置如下
    1. test-composite-policy-1 = max_total_spans_per_second 的 50 % = 50 spans_per_second
    2. test-composite-policy-2 = max_total_spans_per_second 的 25 % = 25 spans_per_second
    3. 为确保剩余容量被填满,请使用 always_sample 作为策略之一

还可以修改以下配置选项:

  • decision_wait(默认 = 30 秒):在做出采样决定之前,从 trace 的第一个跨度开始的等待时间
  • num_traces(默认值 = 50000):内存中保存的 trace 数
  • expected_new_traces_per_sec(默认 = 0):预期的新 trace 数(有助于分配数据结构)

例子:

processors:
  tail_sampling:
    decision_wait: 10s
    num_traces: 100
    expected_new_traces_per_sec: 10
    policies:      [
          {
            name: test-policy-1,
            type: always_sample
          },
          {
            name: test-policy-2,
            type: latency,
            latency: {threshold_ms: 5000}
          },
          {
            name: test-policy-3,
            type: numeric_attribute,
            numeric_attribute: {key: key1, min_value: 50, max_value: 100}
          },
          {
            name: test-policy-4,
            type: probabilistic,
            probabilistic: {sampling_percentage: 10}
          },
          {
            name: test-policy-5,
            type: status_code,
            status_code: {status_codes: [ERROR, UNSET]}
          },
          {
            name: test-policy-6,
            type: string_attribute,
            string_attribute: {key: key2, values: [value1, value2]}
          },
          {
            name: test-policy-7,
            type: string_attribute,
            string_attribute: {key: key2, values: [value1, val*], enabled_regex_matching: true, cache_max_size: 10}
          },
          {
            name: test-policy-8,
            type: rate_limiting,
            rate_limiting: {spans_per_second: 35}
         },
         {
            name: test-policy-9,
            type: string_attribute,
            string_attribute: {key: http.url, values: [\/health, \/metrics], enabled_regex_matching: true, invert_match: true}
         },
         {
            name: and-policy-1,
            type: and,
            and: {
              and_sub_policy:               [
                {
                  name: test-and-policy-1,
                  type: numeric_attribute,
                  numeric_attribute: { key: key1, min_value: 50, max_value: 100 }
                },
                {
                    name: test-and-policy-2,
                    type: string_attribute,
                    string_attribute: { key: key2, values: [ value1, value2 ] }
                },
              ]
            }
         },
         {
            name: composite-policy-1,
            type: composite,
            composite:              {
                max_total_spans_per_second: 1000,
                policy_order: [test-composite-policy-1, test-composite-policy-2, test-composite-policy-3],
                composite_sub_policy:                  [
                    {
                      name: test-composite-policy-1,
                      type: numeric_attribute,
                      numeric_attribute: {key: key1, min_value: 50, max_value: 100}
                    },
                    {
                      name: test-composite-policy-2,
                      type: string_attribute,
                      string_attribute: {key: key2, values: [value1, value2]}
                    },
                    {
                      name: test-composite-policy-3,
                      type: always_sample
                    }
                  ],
                rate_allocation:                  [
                    {
                      policy: test-composite-policy-1,
                      percent: 50
                    },
                    {
                      policy: test-composite-policy-2,
                      percent: 25
                    }
                  ]
              }
          },
        ]

有关使用处理器的详细示例,请参阅tail_sampling_config.yaml

演示 demo

本 demo 主要是将 OpenTelemetry 数据推送至 观测云

准备工作

1、下载源码:https://github.com/lrwh/observable-demo/tree/main/opentelemetry-collector-sampling

2、确保已经安装了 DataKit

服务名称端口描述
otel-collectorotel/opentelemetry-collector-contrib:0.51.0
springboot_server8080:8080opentelemetry-agent 版本 1.13.1, 源码地址:https://github.com/lrwh/observable-demo/tree/main/springboot-server

3、Datakit 开启 OpenTelemetry 采集,参照最佳实践OpenTelemetry 链路数据接入最佳实践

启动服务

docker-compose up -d

以下示例主要以尾部采样策略为测试场景。

配置尾部采样器

processors:
  # 尾部采样器
  tail_sampling:
    decision_wait: 10s
    num_traces: 100
    expected_new_traces_per_sec: 100
    policies:
      [
        {
          name: policy-1,
          type: status_code,
          status_code: {status_codes: [ERROR]}
        },
        {
          name: policy-2,
          type: probabilistic,
          probabilistic: {sampling_percentage: 20}
        }
      ]

以上规则是的关系,表示policy-1policy-2 任意一个成立则进行采样。

启用尾部采样器

service:
  extensions: [pprof, zpages, health_check]
  pipelines:
    traces:
      receivers: [otlp]
      processors: [batch,tail_sampling]
      exporters: [otlp]
    metrics:
      receivers: [otlp]
      processors: [batch]
      exporters: [otlp]

场景一

1、访问服务API gateway 5 次,每次均为正常返回

curl http://localhost:8080/gateway

2、前往观测云查看trace信息,按照采样规则,最多采样一次trace数据。

场景二

1、设置启动客户端

curl http://localhost:8080/setClient?c=true

当前演示demo并没有启动客户端服务,所以后续调用 gateway 接口会有异常产生。

2、访问 5 次gateway服务,返回 {"msg":"client 调用失败","code":500}

3、前往观测云查看trace信息,按照采样规则,如果发生异常,则异常全采。

概率采样处理器与采用概率策略的尾部采样处理器相比

概率采样处理器和概率尾采样处理器策略的工作方式非常相似:基于可配置的采样百分比,它们将对接收到的 trace 进行固定比率的采样。但根据整体处理管道,您应该更喜欢使用其中一个。

根据经验,如果您想添加概率采样和…

…您还没有使用尾部采样处理器:使用概率采样处理器。运行概率采样处理器比尾部采样处理器更有效。概率抽样策略根据 traceId 做出决定,因此等待更多跨度到达不会影响其决定。

…您已经在使用尾部采样处理器:添加概率采样策略。您已经承担了运行尾部采样处理器的成本,添加概率策略将可以忽略不计。此外,在尾部采样处理器中使用该策略将确保不会丢弃由其他策略采样的 trace 。

 类似资料: