Application Real-Time Monitoring Service：Komponen dan framework Go yang didukung oleh Pemantauan Aplikasi ARMS

Message

RPC frameworks

SQL/NoSQL

Logging

Job scheduling

Trace SDK

AI SDK

Alibaba Cloud SDK

Other SDKs

Bagaimana cara mempertahankan kontinuitas jejak untuk versi Asynq sebelum v0.26.0?

Untuk informasi selengkapnya, lihat Bagaimana cara mempertahankan kontinuitas jejak untuk versi Asynq sebelum v0.26.0?.

Mengapa terjadi diskontinuitas jejak saat menggunakan framework message?

Karena detail implementasi pada framework message tertentu, agen Go saat ini memiliki keterbatasan dalam menyebarkan konteks jejak (trace context) melalui framework tersebut.

Mengapa saya tidak melihat panggilan database atau NoSQL di Konsol saat menggunakan klien Redis?

Karena detail implementasi framework, agen Go tidak dapat menginstrumentasi aksi yang dijalankan sebelum fungsi init.

Pastikan Anda menginisialisasi klien Redis atau database di dalam fungsi init.

// Pendekatan yang tidak valid
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // tidak ada password yang diatur
	DB:       0,  // gunakan DB default
})

// Pendekatan yang valid
var rdb *redis.Client

func init() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // tidak ada password yang diatur
		DB:       0,  // gunakan DB default
	})
}

Mengapa saya tidak melihat instrumentasi OpenTelemetry SDK kustom saya?

1. Di halaman Custom Configuration, pilih opentelemetry-plugin di bagian Agent Switch Settings, lalu restart aplikasi Anda.

   

2. Laju sampel (sample rate) default adalah 10%. Anda mungkin tidak melihat jejak jika jumlah permintaan sedikit. Anda dapat menyesuaikan laju sampel sesuai kebutuhan.

Bagaimana cara menambahkan span kustom untuk RabbitMQ?

Gunakan contoh kode berikut untuk menambahkan span kustom:

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  // Buat span untuk setiap pesan di handler
  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()
        // proses lainnya
      }
  }
  
  

Bagaimana cara menambahkan span kustom untuk Kafka?

Gunakan contoh kode berikut untuk menambahkan span kustom:

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"
  )
  
  // Buat span untuk setiap pesan di handler
  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()
              // proses lainnya
          }
  
      }
  }