Replacing SimpleSpanProcessor with BatchSpanProcessor

Author: dpb-bah

dataactcore/broker_logging.py

@@ -4,7 +4,7 @@
 from opentelemetry import trace
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk.trace import TracerProvider
-from opentelemetry.sdk.trace.export import SimpleSpanProcessor, ConsoleSpanExporter
+from opentelemetry.sdk.trace.export import BatchSpanProcessor, ConsoleSpanExporter
 from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
 from opentelemetry.instrumentation.logging import LoggingInstrumentor
 from opentelemetry.instrumentation.urllib import URLLibInstrumentor
@@ -89,7 +89,7 @@ def configure_logging(service_name='broker'):
         otel_endpoint = os.getenv("OTEL_EXPORTER_OTLP_TRACES_ENDPOINT")
         if otel_endpoint:
             exporter = OTLPSpanExporter(endpoint=otel_endpoint)
-            trace.get_tracer_provider().add_span_processor(SimpleSpanProcessor(exporter))
+            trace.get_tracer_provider().add_span_processor(BatchSpanProcessor(exporter))
 
     LoggingInstrumentor(logging_format="%(asctime)s %(levelname)s:%(name)s:%(message)s")
     LoggingInstrumentor().instrument(tracer_provider=trace.get_tracer_provider(), set_logging_format=False)