Google Cloud Trace Opentelemetry Java 示例代码未显示在 Google Cloud Trace 仪表板上

Posted 2023-02-16

【中文标题】Google Cloud Trace Opentelemetry Java 示例代码未显示在 Google Cloud Trace 仪表板上

【英文标题】：Google Cloud Trace Opentelemetry Java example code not showing up on Google Cloud Trace Dashboard

【发布时间】：2021-10-26 18:32:06

【问题描述】：

我按照 Google Cloud 的 Java 和 OpenTelemetry 站点 (https://cloud.google.com/trace/docs/setup/java-ot) 上的步骤在本地制作了一个简单的 hello world Java 应用程序，并尝试使用他们的跟踪导出器让我的跟踪显示在 Google Cloud Trace 上。

所有设置代码相同，程序编译运行成功。但是，我在 Trace 仪表板上看不到任何内容。我知道这不是 IAM 或我的服务帐号密钥的问题，因为我运行了 Python 示例，它在 Cloud Trace 仪表板中显示得很好。

有人对 Java 版本为什么会默默失败有任何指导吗？

谢谢

 package hello;
 import org.joda.time.LocalTime;
 import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.Tracer;
 import io.opentelemetry.context.Scope;
 import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.api.common.AttributeKey;
 import io.opentelemetry.api.common.Attributes;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.StatusCode;
 import io.opentelemetry.api.trace.Tracer;
 import io.opentelemetry.context.Scope;
 import io.opentelemetry.sdk.OpenTelemetrySdk;
 import io.opentelemetry.sdk.trace.SdkTracerProvider;
 import io.opentelemetry.sdk.trace.export.BatchSpanProcessor;
 import io.opentelemetry.exporter.logging.LoggingSpanExporter;
 import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
 import io.opentelemetry.context.Context;
 import io.opentelemetry.context.propagation.ContextPropagators;
 import io.opentelemetry.api.metrics.LongCounter;
 import io.opentelemetry.api.metrics.Meter;
 import io.opentelemetry.sdk.metrics.SdkMeterProvider;
 import io.opentelemetry.sdk.metrics.export.IntervalMetricReader;
 import java.io.IOException;
 import java.util.Random;
 import com.google.cloud.opentelemetry.trace.TraceConfiguration;
 import com.google.cloud.opentelemetry.trace.TraceExporter;
 import java.util.Collections;
 import static java.util.Collections.singleton;
 import java.time.Duration;

 public class HelloWorld 
   private static final Random random = new Random();
   private static OpenTelemetry setupTraceExporter() 
     try 
       
       TraceExporter traceExporter = TraceExporter.createWithConfiguration(
               TraceConfiguration.builder().setProjectId("my-test-id").build());
       // Register the TraceExporter with OpenTelemetry
       return OpenTelemetrySdk.builder()
               .setTracerProvider(
                       SdkTracerProvider.builder()
                               .addSpanProcessor(BatchSpanProcessor.builder(traceExporter).build())
                               .build())
               .buildAndRegisterGlobal();
      catch (IOException e) 
       System.out.println("Uncaught Exception");
       System.out.println(e);
       return null;
     
   
   public static void main(String[] args) 
     System.out.println("Starting the example application");
     /* SET UP */
     OpenTelemetry otel = setupTraceExporter();
     /* Creating tracer */
     Tracer tracer =
             otel.getTracer("java foo");
     Span span = tracer.spanBuilder("my span").startSpan();
     // put the span into the current Context
     try (Scope scope = span.makeCurrent()) 
       System.out.println("Hello");
       Thread.sleep(4000);
      catch (Throwable t) 
       span.setStatus(StatusCode.ERROR, "error");
       System.out.println(t);
      finally 
       span.end(); 
     
     System.out.println("Closing");
     //otel.getSdkTracerProvider().shutdown();
   
 

【参考方案1】：

经过一番调试，我想出了答案。

在这个简单的例子中，BatchSpanProcessor 不是一个好主意，因为只有一个跨度被跟踪。

SimpleSpanProcessor 无论如何都会直接将 span 转发到 Cloud Trace，而BatchSpanProcessor 会等到有足够的数据后再推送到 Cloud Trace。因此，为什么我在 Cloud Trace 中看不到任何内容，因为 BatchSpanProcessor 没有注册足够的 span，无法将其实际上传到 Google Cloud。

Span Processors Documentation

更改以下几行

      return OpenTelemetrySdk.builder()
          .setTracerProvider(
                  SdkTracerProvider.builder()
                          .addSpanProcessor(SimpleSpanProcessor.create(traceExporter))
                          .build())
          .buildAndRegisterGlobal();

希望这对其他人有所帮助！