Cloud Monitor：Komponen dan framework Go yang didukung oleh ARMS Application Monitoring

Pesan

Kerangka RPC

SQL/NoSQL

Logging

Penjadwalan Tugas

SDK Trace

AI SDKs

Alibaba Cloud SDKs

SDK Lainnya

Mengapa jejak terputus ketika saya menggunakan framework pesan?

Karena detail implementasi di beberapa framework pesan, agen Go memiliki keterbatasan dalam menyebarkan konteks jejak. Keterbatasannya adalah sebagai berikut:

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

Karena implementasi spesifik framework, agen Go tidak dapat secara efektif menginstrumen tindakan yang dieksekusi sebelum fungsi init.

Inisialisasi klien Redis atau klien database dalam fungsi init.

// Kode tidak valid
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // tidak ada kata sandi 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 kata sandi yang disetel
		DB:       0,  // gunakan DB default
	})
}

Mengapa saya tidak bisa melihat instrumen SDK OTel kustom saya?

1. Pada halaman Konfigurasi Kustom, pilih opentelemetry-plugin di bagian Pengaturan Saklar Probe. Kemudian, mulai ulang 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 dalam penangan pesan.
  func handle(deliveries <-chan amqp.Delivery, done chan error) {
      cleanup := func() {
          Log.Printf("handle: saluran pengiriman 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 dalam 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
          }
  
      }
  }