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

メッセージ

RPC フレームワーク

SQL/NoSQL

ロギング

ジョブスケジューリング

トレース SDK

AI SDK

Alibaba Cloud SDK

その他の SDK

Asynq v0.26.0 より前のバージョンでトレースの継続性を維持するにはどうすればよいですか？

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

メッセージフレームワークの使用時にトレースが途切れるのはなぜですか？

一部のメッセージフレームワークでは実装上の都合により、現在の 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. [Custom Configuration] ページの [Agent Switch Settings] セクションで [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"].(string)
        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(ctx, "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()
              // ここにメッセージ処理ロジックを記述します。
          }
      }
  }