azure-core-tracing-opentelemetry

import os from opentelemetry import trace from opentelemetry.sdk.trace import TracerProvider from opentelemetry.sdk.trace.export import ConsoleSpanExporter, SimpleSpanProcessor from azure.core.tracing.ext.opentelemetry_span import use_opentelemetry from azure.storage.blob import BlobServiceClient # 1. Set up OpenTelemetry TracerProvider and SpanProcessor # This example uses ConsoleSpanExporter; for Azure Monitor, use AzureMonitorTraceExporter trace.set_tracer_provider(TracerProvider()) span_processor = SimpleSpanProcessor(ConsoleSpanExporter()) trace.get_tracer_provider().add_span_processor(span_processor) # 2. Enable OpenTelemetry tracing plugin for Azure SDK use_opentelemetry() # 3. Create an Azure SDK client (e.g., Azure Blob Storage) # Ensure AZURE_STORAGE_CONNECTION_STRING is set in your environment for actual operations connection_string = os.environ.get( "AZURE_STORAGE_CONNECTION_STRING", "DefaultEndpointsProtocol=https;AccountName=test;AccountKey=test;BlobEndpoint=https://test.blob.core.windows.net/" ) if connection_string == "DefaultEndpointsProtocol=https;AccountName=test;AccountKey=test;BlobEndpoint=https://test.blob.core.windows.net/": print("WARNING: Using a placeholder connection string. Tracing will run, but actual Azure operations will fail unless AZURE_STORAGE_CONNECTION_STRING is set.") blob_service_client = BlobServiceClient.from_connection_string(connection_string) # 4. Perform an Azure SDK operation try: container_name = "otel-test-container" container_client = blob_service_client.get_container_client(container_name) print(f"Attempting to create container '{container_name}'...") container_client.create_container() print(f"Container '{container_name}' created successfully.") print(f"Attempting to delete container '{container_name}'...") container_client.delete_container() print(f"Container '{container_name}' deleted successfully.") except Exception as e: print(f"An error occurred during Azure Storage operation (check your connection string and permissions): {e}") print("Traces should be printed to the console if successful and the connection string is valid.")