Use SDK providers in example code (#488)

Author: c24t

docs/examples/metrics/observer_example.py

@@ -19,14 +19,15 @@
 import psutil
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import LabelSet
+from opentelemetry.sdk.metrics import LabelSet, MeterProvider
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.batcher import UngroupedBatcher
 from opentelemetry.sdk.metrics.export.controller import PushController
 
 # Configure a stateful batcher
 batcher = UngroupedBatcher(stateful=True)
 
+metrics.set_meter_provider(MeterProvider())
 meter = metrics.get_meter(__name__)
 
 # Exporter to export metrics to the console

docs/examples/metrics/prometheus.py

@@ -21,13 +21,14 @@
 
 from opentelemetry import metrics
 from opentelemetry.ext.prometheus import PrometheusMetricsExporter
-from opentelemetry.sdk.metrics import Counter
+from opentelemetry.sdk.metrics import Counter, MeterProvider
 from opentelemetry.sdk.metrics.export.controller import PushController
 
 # Start Prometheus client
 start_http_server(port=8000, addr="localhost")
 
 # Meter is responsible for creating and recording metrics
+metrics.set_meter_provider(MeterProvider())
 meter = metrics.get_meter(__name__)
 # exporter to export metrics to Prometheus
 prefix = "MyAppPrefix"

docs/examples/metrics/record.py

@@ -19,10 +19,12 @@
 import time
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import Counter
+from opentelemetry.sdk.metrics import Counter, MeterProvider
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.controller import PushController
 
+# Use the meter type provided by the SDK package
+metrics.set_meter_provider(MeterProvider())
 # Meter is responsible for creating and recording metrics
 meter = metrics.get_meter(__name__)
 # exporter to export metrics to the console

docs/examples/metrics/simple_example.py

@@ -23,7 +23,7 @@
 import time
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import Counter, Measure
+from opentelemetry.sdk.metrics import Counter, Measure, MeterProvider
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.controller import PushController
 
@@ -43,13 +43,13 @@ def usage(argv):
         usage(sys.argv)
         sys.exit(1)
 
-# Meter is responsible for creating and recording metrics
 
-# Meter's namespace corresponds to the string passed as the first argument Pass
-# in True/False to indicate whether the batcher is stateful. True indicates the
-# batcher computes checkpoints from over the process lifetime. False indicates
-# the batcher computes checkpoints which describe the updates of a single
-# collection period (deltas)
+# The Meter is responsible for creating and recording metrics. Each meter has a
+# unique name, which we set as the module's name here. The second argument
+# determines whether how metrics are collected: if true, metrics accumulate
+# over the process lifetime. If false, metrics are reset at the beginning of
+# each collection interval.
+metrics.set_meter_provider(MeterProvider())
 meter = metrics.get_meter(__name__, batcher_mode == "stateful")
 
 # Exporter to export metrics to the console

docs/examples/opentelemetry-example-app/src/opentelemetry_example_app/flask_example.py

@@ -23,6 +23,7 @@
 import opentelemetry.ext.http_requests
 from opentelemetry import trace
 from opentelemetry.ext.flask import instrument_app
+from opentelemetry.sdk.trace import TracerProvider
 
 
 def configure_opentelemetry(flask_app: flask.Flask):
@@ -33,21 +34,16 @@ def configure_opentelemetry(flask_app: flask.Flask):
     * sets tracer to the SDK's Tracer
     * enables requests integration on the Tracer
     * uses a WSGI middleware to enable configuration
-
-    TODO:
-
-    * processors?
-    * exporters?
     """
-    # Start by configuring all objects required to ensure
-    # a complete end to end workflow.
+    # Start by configuring all objects required to ensure a complete end to end
+    # workflow.
+    trace.set_tracer_provider(TracerProvider())
 
-    # Next, we need to configure how the values that are used by
-    # traces and metrics are propagated (such as what specific headers
-    # carry this value).
-    # Integrations are the glue that binds the OpenTelemetry API
-    # and the frameworks and libraries that are used together, automatically
-    # creating Spans and propagating context as appropriate.
+    # Next, we need to configure how the values that are used by traces and
+    # metrics are propagated (such as what specific headers carry this value).
+    # Integrations are the glue that binds the OpenTelemetry API and the
+    # frameworks and libraries that are used together, automatically creating
+    # Spans and propagating context as appropriate.
     opentelemetry.ext.http_requests.enable(trace.get_tracer_provider())
     instrument_app(flask_app)
 
@@ -57,8 +53,7 @@ def configure_opentelemetry(flask_app: flask.Flask):
 
 @app.route("/")
 def hello():
-    # emit a trace that measures how long the
-    # sleep takes
+    # Emit a trace that measures how long the sleep takes
     version = pkg_resources.get_distribution(
         "opentelemetry-example-app"
     ).version

docs/examples/opentracing/main.py

@@ -3,9 +3,12 @@
 from opentelemetry import trace
 from opentelemetry.ext import opentracing_shim
 from opentelemetry.ext.jaeger import JaegerSpanExporter
+from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import SimpleExportSpanProcessor
 from rediscache import RedisCache
 
+# Configure the tracer using the default implementation
+trace.set_tracer_provider(TracerProvider())
 tracer_provider = trace.get_tracer_provider()
 
 # Configure the tracer to export traces to Jaeger

examples/metrics/collector.py

@@ -21,10 +21,11 @@
 from opentelemetry.ext.otcollector.metrics_exporter import (
     CollectorMetricsExporter,
 )
-from opentelemetry.sdk.metrics import Counter
+from opentelemetry.sdk.metrics import Counter, MeterProvider
 from opentelemetry.sdk.metrics.export.controller import PushController
 
 # Meter is responsible for creating and recording metrics
+metrics.set_meter_provider(MeterProvider())
 meter = metrics.get_meter(__name__)
 # exporter to export metrics to OT Collector
 exporter = CollectorMetricsExporter(

ext/opentelemetry-ext-dbapi/README.rst

@@ -12,9 +12,12 @@ Usage
 
     import mysql.connector
     import pyodbc
-    from opentelemetry.trace import tracer_provider
+
     from opentelemetry.ext.dbapi import trace_integration
+    from opentelemetry.sdk.trace import TracerProvider
+    from opentelemetry.trace import tracer_provider
 
+    trace.set_tracer_provider(TracerProvider())
     tracer = trace.get_tracer(__name__)
     # Ex: mysql.connector
     trace_integration(tracer_provider(), mysql.connector, "connect", "mysql", "sql")

ext/opentelemetry-ext-jaeger/README.rst

@@ -32,8 +32,10 @@ gRPC is still not supported by this implementation.
 
     from opentelemetry import trace
     from opentelemetry.ext import jaeger
+    from opentelemetry.sdk.trace import TracerProvider
     from opentelemetry.sdk.trace.export import BatchExportSpanProcessor
 
+    trace.set_tracer_provider(TracerProvider())
     tracer = trace.get_tracer(__name__)
 
     # create a JaegerSpanExporter

ext/opentelemetry-ext-jaeger/examples/jaeger_exporter_example.py

@@ -2,8 +2,10 @@
 
 from opentelemetry import trace
 from opentelemetry.ext import jaeger
+from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import BatchExportSpanProcessor
 
+trace.set_tracer_provider(TracerProvider())
 tracer = trace.get_tracer(__name__)
 
 # create a JaegerSpanExporter