Cloud Monitor:Komponen dan framework Go yang didukung oleh Pemantauan Aplikasi ARMS

Messaging

Kerangka kerja RPC

SQL/NoSQL

Logging

Penjadwalan tugas

Trace SDKs

AI SDKs

Alibaba Cloud SDKs

SDK lainnya

Mengapa jejak (trace) terputus saat saya menggunakan framework messaging?

Karena detail implementasi pada beberapa framework messaging, agen Go memiliki keterbatasan dalam menyebarkan konteks jejak (trace context). Keterbatasan tersebut adalah sebagai berikut:

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

Karena implementasi spesifik framework, agen Go tidak dapat melakukan instrumentasi secara efektif terhadap aksi yang dieksekusi sebelum fungsi init.

Inisialisasi client Redis atau client database di dalam fungsi init.

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

// Kode 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 SDK OTel kustom saya?

1. Pada halaman Konfigurasi Kustom, pilih opentelemetry-plugin di bagian Pengaturan sakelar probe. Kemudian, restart aplikasi.

2. Laju sampel default adalah 10%. Jika volume permintaan Anda rendah, Anda mungkin tidak melihat data apa pun. Anda dapat menyesuaikan laju sampel sesuai kebutuhan.

Bagaimana cara menambahkan rentang kustom untuk RabbitMQ?

Contoh kode berikut menunjukkan cara menambahkan rentang kustom:

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  // Buat rentang untuk setiap pesan di penangan pesan.
  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 rentang kustom untuk Kafka?

Contoh kode berikut menunjukkan cara menambahkan rentang 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 rentang untuk setiap pesan di penangan pesan.
  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)
              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
          }
  
      }
  }