Testing GCP cloud trace exporter

Author: jamescrowley

back/boxtribute_server/app.py

@@ -102,35 +102,34 @@ def setup_opentelemetry(app):
     # https://cloud.google.com/stackdriver/docs/instrumentation/choose-approach#app_engine
     # https://cloud.google.com/trace/docs/setup/python-ot
     # https://github.com/GoogleCloudPlatform/opentelemetry-operations-python/blob/1f1775886d7314b113acd322633afb278f875687/samples/instrumentation-quickstart/setup_opentelemetry.py
-    from opentelemetry.sdk.resources import SERVICE_INSTANCE_ID, SERVICE_NAME, Resource
-
     # No permission for trace.googleapis.com
-    # from opentelemetry import trace
+    from opentelemetry import trace
+    from opentelemetry.exporter.cloud_trace import CloudTraceSpanExporter
+    from opentelemetry.propagate import set_global_textmap
+    from opentelemetry.propagators.cloud_trace_propagator import (
+        CloudTraceFormatPropagator,
+    )
+    from opentelemetry.sdk.resources import SERVICE_INSTANCE_ID, Resource
+
     # from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
-    # from opentelemetry.sdk.trace import TracerProvider
-    # from opentelemetry.sdk.trace.export import BatchSpanProcessor
-
-    from opentelemetry import metrics
-    from opentelemetry.exporter.otlp.proto.http.metric_exporter import OTLPMetricExporter
-    from opentelemetry.sdk.metrics import MeterProvider
-    from opentelemetry.sdk.metrics.export import PeriodicExportingMetricReader
-
-    resource = Resource.create(attributes={
-        # Use the PID as the service.instance.id to avoid duplicate timeseries
-        # from different Gunicorn worker processes.
-        SERVICE_INSTANCE_ID: f"worker-{os.getpid()}",
-    })
-
-    # tracer_provider = TracerProvider(resource=resource)
-    # processor = BatchSpanProcessor(OTLPSpanExporter())
-    # tracer_provider.add_span_processor(processor)
-    # trace.set_tracer_provider(tracer_provider)
-
-    reader = PeriodicExportingMetricReader(
-        OTLPMetricExporter()
+    from opentelemetry.sdk.trace import TracerProvider
+    from opentelemetry.sdk.trace.export import BatchSpanProcessor
+
+    resource = Resource.create(
+        attributes={
+            # Use the PID as the service.instance.id to avoid duplicate timeseries
+            # from different Gunicorn worker processes.
+            SERVICE_INSTANCE_ID: f"worker-{os.getpid()}",
+        }
     )
-    meter_provider = MeterProvider(metric_readers=[reader], resource=resource)
-    metrics.set_meter_provider(meter_provider)
+
+    provider = TracerProvider(resource=resource)
+    processor = BatchSpanProcessor(CloudTraceSpanExporter())
+    provider.add_span_processor(processor)
+
+    trace.set_tracer_provider(provider)
+    set_global_textmap(CloudTraceFormatPropagator())
 
     from opentelemetry.instrumentation.flask import FlaskInstrumentor
+
     FlaskInstrumentor().instrument_app(app)

back/requirements-deploy.txt

@@ -1,4 +1,5 @@
 google-cloud-logging==3.11.3
 opentelemetry-sdk==1.27.0
-opentelemetry-exporter-otlp-proto-http==1.27.0
 opentelemetry-instrumentation-flask==0.48b0
+opentelemetry-exporter-gcp-trace==1.7.0
+opentelemetry-propagator-gcp==1.7.0