Application Real-Time Monitoring Service：ARMS應用監控支援的Go組件和架構

訊息

RPC架構

SQL/NOSQL

日誌

任務調度

Trace SDK

AI SDK

阿里雲SDK

其他SDK

為什麼使用訊息架構時存在斷鏈？

受限於訊息架構的具體實現，目前的版本的Go探針對某些訊息架構的Trace上下文傳遞存在一定限制，具體如下：

為什麼使用Redis資料庫的用戶端時控制台看不見資料庫/NoSQL相關調用？

受限於架構的具體實現，Go Agent無法對init函數執行之前的動作進行有效插樁。

請確保已在init函數中執行Redis用戶端或者資料庫用戶端的初始化動作。

// 無效寫法
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // no password set
	DB:       0,  // use default DB
})

// 生效寫法
var rdb *redis.Client

func init() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})
}

為什麼看不到自訂的OTel SDK埋點？

1. 請在自訂配置頁面的探針開關設定地區選中opentelemetry-plugin，然後重啟應用。

   

2. 預設採樣率為10%，請求次數少的情況下可能會看不到，建議調整採樣率。

如何為RabbitMQ增加自訂Span？

增加自訂Span的範例程式碼如下：

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  //在訊息的handle對每個訊息處理時候建立一個span
  func handle(deliveries <-chan amqp.Delivery, done chan error) {
      cleanup := func() {
          Log.Printf("handle: deliveries channel closed")
          done <- nil
      }
  
      defer cleanup()
      for d := range deliveries {
        var headerMap propagation.MapCarrier
        headerMap = make(map[string]string)
        headerMap["traceparent"] = delivery.Headers["traceparent"]
        ctx := otel.GetTextMapPropagator().Extract(context.Background(), headerMap)
        ctx = oTrace.ContextWithSpanContext(context.Background(), oTrace.SpanFromContext(ctx).SpanContext())
        tracer = otel.GetTracerProvider().Tracer("")
        opts := append([]oTrace.SpanStartOption{}, oTrace.WithSpanKind(oTrace.SpanKindConsumer))
        ctx, span := tracer.Start(context.Background(), "mq", opts...)
        defer span.End()
        //other process
      }
  }
  
  

如何為Kafka增加自訂Span？

增加自訂Span的範例程式碼如下：

import (
    kafka "github.com/segmentio/kafka-go"
      "go.opentelemetry.io/otel"
      "go.opentelemetry.io/otel/propagation"
      "go.opentelemetry.io/otel/trace"
      oTrace "go.opentelemetry.io/otel/trace"
  )
  
  //在訊息的handle對每個訊息處理時候建立一個span
  func handle(msg kafka.Message) {
      for _, attr := range msg.Headers {
          if attr.Key == "traceparent" {
              var headerMap propagation.MapCarrier
              headerMap = make(map[string]string)
              headerMap["traceparent"] = string(attr.Value)
              ctx := otel.GetTextMapPropagator().Extract(context.Background(), headerMap)
              tracer := otel.GetTracerProvider().Tracer("")
              opts := append([]oTrace.SpanStartOption{}, oTrace.WithSpanKind(oTrace.SpanKindConsumer))
              ctx, span := tracer.Start(ctx, "mq", opts...)
              defer span.End()
              //other process
          }
  
      }
  }