Use BatchSpanProcessor in examples (open-telemetry#1928)

Author: srikanthccv

docs/examples/auto-instrumentation/client.py

@@ -20,15 +20,15 @@
 from opentelemetry.propagate import inject
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 trace.set_tracer_provider(TracerProvider())
 tracer = trace.get_tracer_provider().get_tracer(__name__)
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 
 

docs/examples/auto-instrumentation/server_instrumented.py

@@ -19,8 +19,8 @@
 from opentelemetry.propagate import extract
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 app = Flask(__name__)
@@ -29,7 +29,7 @@
 tracer = trace.get_tracer_provider().get_tracer(__name__)
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 
 

docs/examples/auto-instrumentation/server_uninstrumented.py

@@ -17,16 +17,16 @@
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 app = Flask(__name__)
 
 trace.set_tracer_provider(TracerProvider())
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 
 

docs/examples/basic_tracer/basic_trace.py

@@ -15,13 +15,13 @@
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 trace.set_tracer_provider(TracerProvider())
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 tracer = trace.get_tracer(__name__)
 with tracer.start_as_current_span("foo"):

docs/examples/basic_tracer/resources.py

@@ -16,8 +16,8 @@
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 # Use Resource.create() instead of constructor directly
@@ -26,7 +26,7 @@
 trace.set_tracer_provider(TracerProvider(resource=resource))
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 tracer = trace.get_tracer(__name__)
 with tracer.start_as_current_span("foo"):

docs/examples/django/client.py

@@ -20,15 +20,15 @@
 from opentelemetry.propagate import inject
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 trace.set_tracer_provider(TracerProvider())
 tracer = trace.get_tracer_provider().get_tracer(__name__)
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 
 

docs/examples/django/pages/views.py

@@ -16,14 +16,14 @@
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
     ConsoleSpanExporter,
-    SimpleSpanProcessor,
 )
 
 trace.set_tracer_provider(TracerProvider())
 
 trace.get_tracer_provider().add_span_processor(
-    SimpleSpanProcessor(ConsoleSpanExporter())
+    BatchSpanProcessor(ConsoleSpanExporter())
 )
 
 

docs/examples/fork-process-model/flask-gunicorn/app.py

@@ -22,6 +22,8 @@
 
 FlaskInstrumentor().instrument_app(application)
 
+tracer = trace.get_tracer(__name__)
+
 
 def fib_slow(n):
     if n <= 1:
@@ -39,7 +41,6 @@ def fib_fast(n):
 
 @application.route("/fibonacci")
 def fibonacci():
-    tracer = trace.get_tracer(__name__)
     n = int(request.args.get("n", 1))
     with tracer.start_as_current_span("root"):
         with tracer.start_as_current_span("fib_slow") as slow_span:

docs/examples/fork-process-model/flask-uwsgi/app.py

@@ -29,6 +29,8 @@
 
 FlaskInstrumentor().instrument_app(application)
 
+tracer = trace.get_tracer(__name__)
+
 
 @postfork
 def init_tracing():
@@ -59,7 +61,6 @@ def fib_fast(n):
 
 @application.route("/fibonacci")
 def fibonacci():
-    tracer = trace.get_tracer(__name__)
     n = int(request.args.get("n", 1))
     with tracer.start_as_current_span("root"):
         with tracer.start_as_current_span("fib_slow") as slow_span:

docs/examples/opentracing/main.py

@@ -5,7 +5,7 @@
 from opentelemetry import trace
 from opentelemetry.exporter.jaeger.thrift import JaegerExporter
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor
+from opentelemetry.sdk.trace.export import BatchSpanProcessor
 from opentelemetry.shim import opentracing_shim
 
 # Configure the tracer using the default implementation
@@ -17,7 +17,7 @@
     agent_host_name="localhost",
     agent_port=6831,
 )
-span_processor = SimpleSpanProcessor(jaeger_exporter)
+span_processor = BatchSpanProcessor(jaeger_exporter)
 tracer_provider.add_span_processor(span_processor)
 
 # Create an OpenTracing shim. This implements the OpenTracing tracer API, but