Application Real-Time Monitoring Service:ARMS アプリケーションモニタリングでサポートされる Go コンポーネントとフレームワーク

メッセージ

RPC フレームワーク

SQL/NoSQL

ロギング

ジョブスケジューリング

トレース SDK

AI SDK

Alibaba Cloud SDK

その他の SDK

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

詳細については、「Asynq v0.26.0 より前のバージョンでトレースの継続性を維持する方法」をご参照ください。

メッセージフレームワーク使用時にトレースが途切れる原因

特定のメッセージフレームワークの実装詳細により、現在の Go エージェントには、それらをまたいでトレースコンテキストを伝播する際に制限があります。

Redis クライアント使用時にデータベースまたは NoSQL の呼び出しがコンソールに表示されない原因

フレームワークの実装詳細により、Go エージェントは init 関数の前に実行される操作のイベントトラッキングを行うことができません。

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

// 不正なアプローチ
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 を使用
	})
}

カスタム OpenTelemetry 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"] = 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()
        // その他の処理
      }
  }
  
  

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)
              tracer := otel.GetTracerProvider().Tracer("")
              opts := append([]oTrace.SpanStartOption{}, oTrace.WithSpanKind(oTrace.SpanKindConsumer))
              ctx, span := tracer.Start(ctx, "mq", opts...)
              defer span.End()
              // その他の処理
          }
  
      }
  }