Application Real-Time Monitoring Service:Go components and frameworks supported by ARMS Application Monitoring

Messages

RPC frameworks

SQL/NoSQL

Logs

Job scheduling

Trace SDK

AI SDK

Alibaba Cloud SDKs

Other SDKs

Why do broken traces occur when I use a messaging framework?

Due to the specific implementation of messaging frameworks, the current version of the Go agent has limitations in propagating trace contexts for some frameworks. The details are as follows:

Why can't I see database or NoSQL calls in the console when I use a Redis database client?

Due to the specific implementation of the framework, the Go agent cannot effectively instrument actions that are executed before the init function.

Make sure that you initialize the Redis client or database client in the init function.

// Invalid method
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // no password set
	DB:       0,  // use default DB
})

// Valid method
var rdb *redis.Client

func init() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})
}

Why can't I see my custom OTel SDK instrumentation?

1. On the Custom Configuration page, select opentelemetry-plugin in the Agent Switch Settings section. Then, restart the application.

   

2. The default sample rate is 10 %. If the number of requests is low, the instrumentation might not be visible. Adjust the sample rate.

How do I add a custom span for RabbitMQ?

The following sample code shows how to add a custom span:

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  // Create a span for each message in the message 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()
        // Other processes
      }
  }
  
  

How do I add a custom span for Kafka?

The following sample code shows how to add a custom span:

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"
  )
  
  // Create a span for each message in the message 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()
              // Other processes
          }
  
      }
  }