Cloud Monitor:ARMS Application Monitoring がサポートする Go コンポーネントとフレームワーク

メッセージング

RPC フレームワーク

SQL/NoSQL

ロギング

タスクスケジューリング

トレース SDK

AI SDK

Alibaba Cloud SDKs

その他の SDK

Asynq v0.26.0 未満のバージョンで継続的なトレースを実現する方法

v0.26.0 より前の Asynq バージョンでトレースの継続性を維持する

メッセージングフレームワークを使用するとトレースが途切れる理由

一部のメッセージングフレームワークの実装上の詳細により、Go エージェントにはトレースコンテキストの伝播時に制限があります。 制限は次のとおりです。

Redis クライアントを使用する際にコンソールでデータベース/NoSQL 呼び出しが表示されない理由

フレームワーク固有の実装のため、Go エージェントは init 関数の前に実行されるアクションを効果的にインストルメンテーションできません。

init 関数で Redis クライアントまたはデータベースクライアントを初期化してください。

// 無効なコード
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // パスワードが設定されていません
	DB:       0,  // デフォルトの DB を使用
})

// 有効なコード
var rdb *redis.Client

func init() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // パスワードが設定されていません
		DB:       0,  // デフォルトの DB を使用
	})
}

カスタム OTel SDK インストルメンテーションが表示されない理由

1. [カスタム設定] ページで、[プローブスイッチ設定] セクションの [opentelemetry-plugin] を選択します。 その後、アプリケーションを再起動します。

2. デフォルトのサンプリングレートは 10% です。 リクエストの量が少ない場合、データが表示されないことがあります。 必要に応じてサンプリングレートを調整できます。

RabbitMQ にカスタムスパンを追加する方法

次のコードサンプルは、カスタムスパンを追加する方法を示しています。

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  // メッセージハンドラでメッセージごとにスパンを作成します。
  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"] = d.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()
        // その他のプロセス
      }
  }
  
  

Kafka にカスタムスパンを追加する方法

次のコードサンプルは、カスタムスパンを追加する方法を示しています。

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"
  )
  
  // メッセージハンドラでメッセージごとにスパンを作成します。
  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)
              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()
              // その他のプロセス
          }
  
      }
  }