Question

I already have a microservice and I want to apply distributed tracing for it. I have written the following code to create a tracing span using jaeger and opentracing , but my problem is that it does not create parrent id and I am not able to see the span graph. It seems it only shows the default operations in UI dashboard. I used docker-compose for config jaeger.

 jaeger:
  container_name: jaeger
  image: jaegertracing/all-in-one:1.39
  restart: always
  ports:
    - 5775:5775/udp
    - 6831:6831/udp
    - 6832:6832/udp
    - 5778:5778
    - 16686:16686
    - 14268:14268
    - 9411:9411
    
  environment:
    - COLLECTOR_OTLP_ENABLED=true
    - OTEL_EXPORTER_OTLP_ENDPOINT="http://localhost:16686"
    - COLLECTOR_ZIPKIN_HTTP_PORT=9411
    - JAEGER_SERVICE_NAME=baran-endpoint
    - JAEGER_AGENT_HOST=jaeger
    - JAEGER_REPORTER_LOG_SPANS=true
    - JAEGER_SAMPLER_TYPE=const
    - JAEGER_SAMPLER_PARAM=1
    - JAEGER_SAMPLER_SERVER_URL=
  networks:
    - network-jaeger

I tried to implement a basic architecture in jaeger component,but it seems that i m missing somthing in between.

var (
  TracingAnalysisEndpoint      = "http://localhost:26855/SaleService.svc"
)
const AgentSwitch = false

func NewJaegerTracer(service string) opentracing.Tracer {
    if AgentSwitch == true {
        return NewJaegerTracerAgent(service)
    }
    return NewJaegerTracerDirect(service)
}

func NewJaegerTracerDirect(service string) opentracing.Tracer {
    sender := transport.NewHTTPTransport(
        TracingAnalysisEndpoint,
    )
    tracer, _ := jaeger.NewTracer(service,
        jaeger.NewConstSampler(true),
        jaeger.NewRemoteReporter(sender, jaeger.ReporterOptions.Logger(jaeger.StdLogger)),
    )
    return tracer
}

func NewJaegerTracerAgent(service string) opentracing.Tracer {
    sender, _ := jaeger.NewUDPTransport("",0)
    tracer, _ := jaeger.NewTracer(service,
        jaeger.NewConstSampler(true),
        jaeger.NewRemoteReporter(sender, jaeger.ReporterOptions.Logger(jaeger.StdLogger)),
    )
    return tracer
}

func StartSpanFromRequest(tracer opentracing.Tracer, r *http.Request, funcDesc string) opentracing.Span {
 spanCtx, _ := Extract(tracer, r)
 return tracer.StartSpan(funcDesc, ext.RPCServerOption(spanCtx))
}

func Inject(span opentracing.Span, request *http.Request) error {
 return span.Tracer().Inject(
  span.Context(),
  opentracing.HTTPHeaders,
  opentracing.HTTPHeadersCarrier(request.Header))
}

func Extract(tracer opentracing.Tracer, r *http.Request) (opentracing.SpanContext, error) {
 return tracer.Extract(
  opentracing.HTTPHeaders,
  opentracing.HTTPHeadersCarrier(r.Header))
}

I created first span on one of my services.

  span:= config.StartSpanFromRequest(config.Tracer,ctx.Request(), "customer method")
  defer span.Finish()   
  span.LogKV(fmt.Sprintf("Customer not found: %s", request.Mobile))

It only shows the default operations in UI dashboard.

我无法准确地确定父母和子女之间的界限。

我想按等级划分。

Answer 1

为了在间隔期之间建立起父母与子女的关系,你需要确保母体的范畴被传至儿童的创造过程。通常通过

因此,修改你的<代码>StartSpanFromRequest,确保职能正确母体从新申请的角度来看待。然后利用这一背景来创造新的期限。

func StartSpanFromRequest(tracer opentracing.Tracer, r *http.Request, operationName string) opentracing.Span {
    parentSpanContext, _ := tracer.Extract(opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(r.Header))
    span := tracer.StartSpan(operationName, ext.RPCServerOption(parentSpanContext))
    return span
}

在向其他服务机构提出请求时,将目前的范围纳入吉大港山区的头目。这使得所谓的服务能够从母体的跨度中提取,并创造儿童的时间。

在向另一家服务机构提出请求时,设立儿童期限的实例:

span := StartSpanFromRequest(tracer, r, "customer method")
defer span.Finish()

// Inject current span context into the headers of the outgoing request
outgoingRequest, _ := http.NewRequest("GET", "http://other-service-url", nil)
Inject(span, outgoingRequest)

// Make the request
//

在所召服务中使用期限的例子:

// In the called service
func SomeHTTPHandler(w http.ResponseWriter, r *http.Request) {
    span := StartSpanFromRequest(tracer, r, "called method")
    defer span.Finish()

    // Business logic
    // 
}

你们需要宣传所有机构间电话的跨度,以保持追踪的连续性。

友情链接