opentelemetry_gcp_resource_detector_for_gke_gce_cloudrun.py

1from opentelemetry import trace
2from opentelemetry.sdk.resources import Resource, get_aggregated_resources
3from opentelemetry.sdk.trace import TracerProvider
4from opentelemetry.sdk.trace.export import BatchSpanProcessor, ConsoleSpanExporter
5from opentelemetry.resourcedetector.gcp import GCEResourceDetector, GKEResourceDetector, CloudRunResourceDetector
6
7# The get_aggregated_resources function can be used to run multiple detectors
8# and merge the results into a single Resource object.
9resource = get_aggregated_resources([
10    GKEResourceDetector(),
11    GCEResourceDetector(),
12    CloudRunResourceDetector(),
13])
14
15# Initialize the TracerProvider with the detected resource metadata
16provider = TracerProvider(resource=resource)
17processor = BatchSpanProcessor(ConsoleSpanExporter())
18provider.add_span_processor(processor)
19trace.set_tracer_provider(provider)
20
21tracer = trace.get_tracer(__name__)
22
23with tracer.start_as_current_span("example-span"):
24    print("This span will include GCP resource metadata.")