Minor tracing samples improvements (Azure#36226)

* tracing samples - flush otel, remove deprecated jaeger, use autoconfigure

Author: Liudmila Molkova

.vscode/cspell.json

@@ -127,6 +127,7 @@
     "sdk/core/azure-xml/**",
     "sdk/cosmos/azure-cosmos-dotnet-benchmark/**",
     "sdk/core/azure-core-tracing-opentelemetry/**",
+    "sdk/core/azure-core-tracing-opentelemetry-samples/**",
     "sdk/cosmos/azure-cosmos-benchmark/**",
     "sdk/core/azure-json-gson/**",
     "sdk/cosmos/azure-cosmos-spark_3-1_2-12/**",
@@ -339,6 +340,7 @@
     "odata",
     "ODBC",
     "okhttp",
+    "OTLP",
     "OLTP",
     "onboarded",
     "Onco",

eng/versioning/external_dependencies.txt

@@ -200,7 +200,6 @@ io.opentelemetry:opentelemetry-sdk;1.28.0
 io.opentelemetry:opentelemetry-sdk-metrics;1.28.0
 io.opentelemetry:opentelemetry-sdk-logs;1.28.0
 io.opentelemetry:opentelemetry-exporter-logging;1.28.0
-io.opentelemetry:opentelemetry-exporter-jaeger;1.28.0
 io.opentelemetry:opentelemetry-exporter-otlp;1.28.0
 io.opentelemetry:opentelemetry-api-logs;1.26.0-alpha
 io.opentelemetry:opentelemetry-sdk-testing;1.28.0

sdk/core/azure-core-metrics-opentelemetry/README.md

@@ -81,9 +81,10 @@ SdkMeterProvider meterProvider = SdkMeterProvider.builder()
     .registerMetricReader(PeriodicMetricReader.builder(OtlpGrpcMetricExporter.builder().build()).build())
     .build();
 
+OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder().setMeterProvider(meterProvider).build();
 // Pass OpenTelemetry instance to MetricsOptions.
 MetricsOptions customMetricsOptions = new OpenTelemetryMetricsOptions()
-    .setOpenTelemetry(OpenTelemetrySdk.builder().setMeterProvider(meterProvider).build());
+    .setOpenTelemetry(openTelemetry);
 
 // configure Azure Client to use customMetricsOptions - it will use meterProvider
 // to create meters and instruments

sdk/core/azure-core-metrics-opentelemetry/pom.xml

@@ -141,7 +141,6 @@
                 <include>io.opentelemetry:opentelemetry-sdk-testing:[1.28.0]</include> <!-- {x-include-update;io.opentelemetry:opentelemetry-sdk-testing;external_dependency} -->
                 <include>io.opentelemetry:opentelemetry-exporter-logging:[1.28.0]</include> <!-- {x-include-update;io.opentelemetry:opentelemetry-exporter-logging;external_dependency} -->
                 <include>io.opentelemetry:opentelemetry-exporter-otlp:[1.28.0]</include> <!-- {x-include-update;io.opentelemetry:opentelemetry-exporter-otlp;external_dependency} -->
-                <include>io.opentelemetry:opentelemetry-exporter-jaeger:[1.28.0]</include> <!-- {x-include-update;io.opentelemetry:opentelemetry-exporter-jaeger;external_dependency} -->
               </includes>
             </bannedDependencies>
           </rules>

sdk/core/azure-core-metrics-opentelemetry/src/main/java/com/azure/core/metrics/opentelemetry/OpenTelemetryMeterProvider.java

@@ -68,7 +68,7 @@ public OpenTelemetryMeterProvider() {
      *     .registerMetricReader(PeriodicMetricReader.builder(OtlpGrpcMetricExporter.builder().build()).build())
      *     .build();
      *
-     * OpenTelemetry openTelemetry = OpenTelemetrySdk.builder()
+     * OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder()
      *     .setTracerProvider(tracerProvider)
      *     .setMeterProvider(meterProvider)
      *     .setPropagators(ContextPropagators.create(W3CTraceContextPropagator.getInstance()))

sdk/core/azure-core-metrics-opentelemetry/src/samples/java/com/azure/core/metrics/opentelemetry/MetricsJavaDocCodeSnippets.java

@@ -11,7 +11,6 @@
 import com.azure.core.util.metrics.Meter;
 import com.azure.core.util.metrics.MeterProvider;
 import io.opentelemetry.api.GlobalOpenTelemetry;
-import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.Tracer;
 import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator;
@@ -93,9 +92,10 @@ public void readmeSampleCustomSdkConfiguration() {
             .registerMetricReader(PeriodicMetricReader.builder(OtlpGrpcMetricExporter.builder().build()).build())
             .build();
 
+        OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder().setMeterProvider(meterProvider).build();
         // Pass OpenTelemetry instance to MetricsOptions.
         MetricsOptions customMetricsOptions = new OpenTelemetryMetricsOptions()
-            .setOpenTelemetry(OpenTelemetrySdk.builder().setMeterProvider(meterProvider).build());
+            .setOpenTelemetry(openTelemetry);
 
         // configure Azure Client to use customMetricsOptions - it will use meterProvider
         // to create meters and instruments
@@ -108,6 +108,7 @@ public void readmeSampleCustomSdkConfiguration() {
         sampleClient.methodCall("get items");
 
         // END: readme-sample-customConfiguration
+        openTelemetry.close();
     }
 
     /**
@@ -125,7 +126,7 @@ public void configureClientLibraryToUseCustomMeter() {
             .registerMetricReader(PeriodicMetricReader.builder(OtlpGrpcMetricExporter.builder().build()).build())
             .build();
 
-        OpenTelemetry openTelemetry = OpenTelemetrySdk.builder()
+        OpenTelemetrySdk openTelemetry = OpenTelemetrySdk.builder()
             .setTracerProvider(tracerProvider)
             .setMeterProvider(meterProvider)
             .setPropagators(ContextPropagators.create(W3CTraceContextPropagator.getInstance()))
@@ -157,6 +158,7 @@ public void configureClientLibraryToUseCustomMeter() {
         span.end();
 
         // END: com.azure.core.util.metrics.OpenTelemetryMeterProvider.createMeter#custom
+        openTelemetry.close();
     }
 
     /**

sdk/core/azure-core-tracing-opentelemetry-samples/pom.xml

@@ -59,8 +59,8 @@
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
-      <artifactId>opentelemetry-exporter-jaeger</artifactId>
-      <version>1.28.0</version> <!-- {x-version-update;io.opentelemetry:opentelemetry-exporter-jaeger;external_dependency} -->
+      <artifactId>opentelemetry-sdk-extension-autoconfigure</artifactId>
+      <version>1.28.0</version> <!-- {x-version-update;io.opentelemetry:opentelemetry-sdk-extension-autoconfigure;external_dependency} -->
       <scope>test</scope>
     </dependency>
     <dependency>

sdk/core/azure-core-tracing-opentelemetry-samples/src/samples/java/com/azure/core/tracing/opentelemetry/samples/CreateConfigurationSettingLoggingExporterSample.java

@@ -3,6 +3,9 @@
 
 package com.azure.core.tracing.opentelemetry.samples;
 
+import com.azure.core.tracing.opentelemetry.OpenTelemetryTracingOptions;
+import com.azure.core.util.ClientOptions;
+import com.azure.core.util.TracingOptions;
 import com.azure.data.appconfiguration.ConfigurationClient;
 import com.azure.data.appconfiguration.ConfigurationClientBuilder;
 import io.opentelemetry.api.trace.Span;
@@ -18,54 +21,52 @@
  * in App Configuration through the {@link ConfigurationClient}.
  */
 public class CreateConfigurationSettingLoggingExporterSample {
-    private static final Tracer TRACER = configureLoggingExporter();
     private static final String CONNECTION_STRING = "<YOUR_CONNECTION_STRING>";
 
     /**
      * The main method to run the application.
      *
      * @param args Ignored args.
      */
+    @SuppressWarnings("try")
     public static void main(String[] args) {
-        configureLoggingExporter();
+        OpenTelemetrySdk openTelemetry = configureTracing();
+
+        // In this sample we configured OpenTelemetry without registering global instance, so we need to pass it explicitly to the Azure SDK.
+        // If we used ApplicationInsights or OpenTelemetry agent, or registered global instance, we would not need to pass it explicitly.
+        TracingOptions tracingOptions = new OpenTelemetryTracingOptions().setOpenTelemetry(openTelemetry);
 
         ConfigurationClient client = new ConfigurationClientBuilder()
             .connectionString(CONNECTION_STRING)
+            .clientOptions(new ClientOptions().setTracingOptions(tracingOptions))
             .buildClient();
 
-        doClientWork(client);
+        Tracer tracer = openTelemetry.getTracer("sample");
+
+        Span span = tracer.spanBuilder("my-span").startSpan();
+        try (Scope s = span.makeCurrent()) {
+            // current span propagates into synchronous calls automatically. ApplicationInsights or OpenTelemetry agent
+            // also propagate context through async reactor calls.
+            client.setConfigurationSetting("hello", "text", "World");
+        } finally {
+            span.end();
+        }
+
+        openTelemetry.close();
     }
 
     /**
-     * Configure the OpenTelemetry {@link LoggingSpanExporter} to enable tracing.
-     *
-     * @return The OpenTelemetry {@link Tracer} instance.
+     * Configure the OpenTelemetry to print traces with {@link LoggingSpanExporter}.
      */
-    private static Tracer configureLoggingExporter() {
+    private static OpenTelemetrySdk configureTracing() {
+        // configure OpenTelemetry explicitly or with io.opentelemetry:opentelemetry-sdk-extension-autoconfigure package
         SdkTracerProvider tracerProvider =
             SdkTracerProvider.builder()
                 .addSpanProcessor(BatchSpanProcessor.builder(LoggingSpanExporter.create()).build())
                 .build();
 
         return OpenTelemetrySdk.builder()
             .setTracerProvider(tracerProvider)
-            .buildAndRegisterGlobal()
-            .getTracer("AppConfig-Sample");
-    }
-
-    /**
-     * Creates the {@link ConfigurationClient} and creates a configuration in Azure App Configuration with distributed
-     * tracing enabled and using the Logging exporter to export telemetry events.
-     */
-    @SuppressWarnings("try")
-    private static void doClientWork(ConfigurationClient client) {
-        Span span = TRACER.spanBuilder("my-span").startSpan();
-        try (Scope s = span.makeCurrent()) {
-            // current span propagates into synchronous calls automatically. ApplicationInsights or OpenTelemetry agent
-            // also propagate context through async reactor calls.
-            client.setConfigurationSetting("hello", "text", "World");
-        } finally {
-            span.end();
-        }
+            .build();
     }
 }

sdk/core/azure-core-tracing-opentelemetry-samples/src/samples/java/com/azure/core/tracing/opentelemetry/samples/ListKeyVaultSecretsAutoConfigurationSample.java

@@ -8,11 +8,11 @@
 import com.azure.security.keyvault.secrets.SecretClient;
 import com.azure.security.keyvault.secrets.SecretClientBuilder;
 import com.azure.security.keyvault.secrets.models.KeyVaultSecret;
-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.exporter.logging.LoggingSpanExporter;
+import io.opentelemetry.sdk.OpenTelemetrySdk;
+import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
 import reactor.util.context.Context;
 
 import static com.azure.core.util.tracing.Tracer.PARENT_TRACE_CONTEXT_KEY;
@@ -26,7 +26,8 @@ public class ListKeyVaultSecretsAutoConfigurationSample {
     private static final String VAULT_URL = "<YOUR_VAULT_URL>";
     @SuppressWarnings("try")
     public void syncClient() {
-        Tracer tracer = configureTracing();
+        OpenTelemetrySdk openTelemetry = AutoConfiguredOpenTelemetrySdk.initialize().getOpenTelemetrySdk();
+        Tracer tracer = openTelemetry.getTracer("sample");
 
         // BEGIN: readme-sample-context-auto-propagation
         SecretClient secretClient = new SecretClientBuilder()
@@ -46,10 +47,12 @@ public void syncClient() {
         }
 
         // END: readme-sample-context-auto-propagation
+        openTelemetry.close();
     }
 
     public void asyncClient() {
-        Tracer tracer = configureTracing();
+        OpenTelemetrySdk openTelemetry = AutoConfiguredOpenTelemetrySdk.initialize().getOpenTelemetrySdk();
+        Tracer tracer = openTelemetry.getTracer("sample");
 
         // BEGIN: readme-sample-context-manual-propagation
         SecretAsyncClient secretAsyncClient = new SecretClientBuilder()
@@ -73,20 +76,7 @@ public void asyncClient() {
         } finally {
             span.end();
         }
-
         // END: readme-sample-context-manual-propagation
-    }
-
-    /**
-     * Configure the OpenTelemetry {@link LoggingSpanExporter} to enable tracing.
-     *
-     * @return The OpenTelemetry {@link Tracer} instance.
-     */
-    private static Tracer configureTracing() {
-        // configure OpenTelemetry SDK using io.opentelemetry:opentelemetry-sdk-extension-autoconfigure:
-        // OpenTelemetrySdk sdk = AutoConfiguredOpenTelemetrySdk.initialize()
-        //    .getOpenTelemetrySdk();
-
-        return GlobalOpenTelemetry.getTracer("Async-List-KV-Secrets-Sample");
+        openTelemetry.close();
     }
 }