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

Message

Framework RPC

SQL dan NoSQL

Logging

Penjadwalan tugas

Trace SDK

AI SDK

Alibaba Cloud SDK

SDK Lainnya

Mengapa terjadi putus koneksi saat menggunakan framework message?

Karena batasan implementasi pada beberapa framework message, agen Go saat ini memiliki keterbatasan dalam propagasi konteks jejak (trace context). Berikut daftarnya.

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

Agen Go tidak dapat menginstrumentasi aksi yang terjadi sebelum fungsi init dijalankan.

Anda dapat menginisialisasi client Redis atau database lainnya dalam fungsi init.

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

// 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?

1. Di halaman Konfigurasi kustom, di bawah Pengaturan switch agen, pilih opentelemetry-plugin. Kemudian, restart aplikasi Anda.

   

2. Laju pengambilan sampel (sampling rate) default adalah 10%. Dengan volume permintaan rendah, jejak mungkin tidak muncul. Anda dapat meningkatkan laju pengambilan sampel tersebut.

Bagaimana cara menambahkan span kustom untuk RabbitMQ?

Contoh kode berikut 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: saluran deliveries ditutup")
          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?

Kode contoh berikut menunjukkan cara 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
          }
  
      }
  }