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

Message

Framework RPC

SQL/NoSQL

Logging

Penjadwalan pekerjaan

Trace SDK

AI SDK

Alibaba Cloud SDK

SDK Lainnya

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

Untuk informasi lebih lanjut, 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 pesan 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 disetel
	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 disetel
		DB:       0,  // gunakan DB default
	})
}

Mengapa saya tidak melihat instrumentasi OpenTelemetry SDK kustom saya?

1. Pada halaman Konfigurasi Kustom, pilih opentelemetry-plugin di bagian Pengaturan Switch Agent, lalu restart aplikasi Anda.

2. Laju sampel 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(ctx, "mq", opts...)
        defer span.End()
        // Logika pemrosesan pesan Anda di sini
      }
  }
  

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()
              // Logika pemrosesan pesan Anda di sini
          }
      }
  }