格拉法納雲

在上一篇文章中，我在 Grafana Cloud 中拍攝、保存和查看了 Opentelemetry 資料

如果您使用免費版本的 Grafana Cloud，您每月可以獲得約 50GB 的日誌和追蹤。如果是因為使用者不多所以不累積痕跡（或不記錄日誌）的服務，直接使用就可以了，但是如果小範圍引入的話，恐怕會累積太多的日誌而無法使用。爆炸。

抽樣類型

採樣大致可分為頭部採樣和尾部採樣。

頭部採樣

JavaScript

預設提供TraceIdRatioBasedSampler。

從'@opentelemetry/sdk-trace-node'導入{TraceIdRatioBasedSampler}； 常量樣本百分比 = 0.1; const sdk = 新 NodeSDK({ // 其他SDK設定參數放這裡 取樣器：新的 TraceIdRatioBasedSampler(samplePercentage); });

import { TraceIdRatioBasedSampler } from '@opentelemetry/sdk-trace-node';

const samplePercentage = 0.1;

const sdk = new NodeSDK({
  // Other SDK configuration parameters go here
  sampler: new TraceIdRatioBasedSampler(samplePercentage),
});

尾部取樣

從後面採樣。此時，由於可用資訊較多，您可以根據想要的邏輯進行過濾。
例如，始終對錯誤追蹤進行採樣。
通常，在從收集器收到所有追蹤後執行採樣。
劣勢

實施可能會很困難。當系統改變、條件改變時，它總是需要改變

• 。

很難執行，因為必須維護狀態狀態才能進行取樣。
Tail Sampler 可能是特定於供應商的。
頭像

讓我們透過實作自訂跨度處理器來實現尾部採樣

SamplingSpanProcessor 實現

建立sampling-span-processor.ts檔案

從“@opentelemetry/api”導入{Context}； 進口 { 跨度處理器， 可讀跨度， 跨度， 來自“@opentelemetry/sdk-trace-node”； /** * 採樣跨度處理器（包括所有誤差跨度和其他跨度的比率） */ 導出類別 SamplingSpanProcessor 實作 SpanProcessor { 構造函數（ 私有_spanProcessor：SpanProcessor； 私人比：數字 ）{} /** * 強制導出所有完成的跨度 */ ForceFlush(): Promise { 返回 this._spanProcessor.forceFlush(); } onStart(span: Span, ParentContext: Context): void { this._spanProcessor.onStart(span,parentContext); } shouldSample(traceId: string): 布林值 { 令累積= 0； for (令 idx = 0; idx { 返回 this._spanProcessor.shutdown(); } }

import { Context } from "@opentelemetry/api";
import {
  SpanProcessor,
  ReadableSpan,
  Span,
} from "@opentelemetry/sdk-trace-node";

/**
 * Sampling span processor (including all error span and ratio of other spans)
 */
export class SamplingSpanProcessor implements SpanProcessor {
  constructor(
    private _spanProcessor: SpanProcessor,
    private _ratio: number
  ) {}

  /**
   * Forces to export all finished spans
   */
  forceFlush(): Promise {
    return this._spanProcessor.forceFlush();
  }

  onStart(span: Span, parentContext: Context): void {
    this._spanProcessor.onStart(span, parentContext);
  }

  shouldSample(traceId: string): boolean {
    let accumulation = 0;
    for (let idx = 0; idx  {
    return this._spanProcessor.shutdown();
  }
}

OtelSDK更新

更新 main.ts 中的 spanProcessors。

跨度處理器：[ 新的取樣跨度處理器（ 新的 BatchSpanProcessor(traceExporter); 樣本百分比 ), ],

  spanProcessors: [
    new SamplingSpanProcessor(
      new BatchSpanProcessor(traceExporter),
      samplePercentage
    ),
  ],