使用远程父母的跟踪ID和SPAN-ID创建opentelemetry上下文

Question

我拥有支持打开跟踪的微服务，并将跟踪ID和SPAN-ID注入标题。其他微服务支持开放遥测。如何在第二微服务中使用Trace-ID和Span-ID创建父跨度？

谢谢，

Answer 1

您可以使用 w3c跟踪上下文实现这一目标的规格。我们需要发送 traceparent （ex：00-8652a752a752089f33e2659dff289dfff28dff28d6833aa ff-fimnf-ff-fimnf-ff-inf-inf-ff-inf-ff-inf-inf-ff-inf-inf-inf-name ）从生产者通过HTTP头号（或者您可以使用消费者中的Trace-ID和Span-ID创建它）。然后，我们可以提取远程上下文并使用TraceParent创建跨度。

这是消费者控制器。 TextMapgetter用于将跟踪数据映射到上下文。 ExtractModel只是一个自定义类。

  @GetMapping(value = "/second")
  public String sencondTest(@RequestHeader(value = "traceparent") String traceparent){
    try {
      Tracer tracer = openTelemetry.getTracer("cloud.events.second");

      TextMapGetter<ExtractModel> getter = new TextMapGetter<>() {
        @Override
        public String get(ExtractModel carrier, String key) {
          if (carrier.getHeaders().containsKey(key)) {
            return carrier.getHeaders().get(key);
          }
          return null;
        }

        @Override
        public Iterable<String> keys(ExtractModel carrier) {
          return carrier.getHeaders().keySet();
        }
      };

      ExtractModel model = new ExtractModel();
      model.addHeader("traceparent", traceparent);
      Context extractedContext = openTelemetry.getPropagators().getTextMapPropagator()
              .extract(Context.current(), model, getter);

      try (Scope scope = extractedContext.makeCurrent()) {
        // Automatically use the extracted SpanContext as parent.
        Span serverSpan = tracer.spanBuilder("CloudEvents Server")
                .setSpanKind(SpanKind.SERVER)
                .startSpan();
        try {

          Thread.sleep(150);
        } finally {
          serverSpan.end();
        }
      }

    } catch (InterruptedException e) {
      throw new RuntimeException(e);
    }

    return "Server Received!";
  }

然后，当我们配置OpentElemetrysdk时，需要在上下文传播器中设置W3CtraceContextPropagator。

// Use W3C Propagator(to extract span from HTTP headers) since we use the W3C specifications
TextMapPropagator textMapPropagator = W3CTraceContextPropagator.getInstance();

OpenTelemetrySdk openTelemetrySdk = OpenTelemetrySdk.builder()
        .setTracerProvider(tracerProvider)
        .setPropagators(ContextPropagators.create(textMapPropagator))
        .buildAndRegisterGlobal();

这是我的客户extractModel类，

public class ExtractModel {

  private Map<String, String> headers;

  public void addHeader(String key, String value) {
    if (this.headers == null){
      headers = new HashMap<>();
    }
    headers.put(key, value);
  }

  public Map<String, String> getHeaders() {
    return headers;
  }

  public void setHeaders(Map<String, String> headers) {
    this.headers = headers;
  }
}

您可以在。

Answer 2

通常，如果标题中可用，则必须将SPAN-ID和TRACE-ID传播。您在微服务中得到的任何请求，请检查标题是否具有SPAN-ID和TRACE-ID。如果是，请提取它们并将其在您的服务中使用。
如果不存在，则创建一个新的并将其在您的服务中使用，并将其添加到从微服务中删除的请求。