insecure

DIRACGrid · May 28, 2024 · 81bf845 · 81bf845
1 parent de1acd6
commit 81bf845
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/diracx-routers/src/diracx/routers/__init__.py b/diracx-routers/src/diracx/routers/__init__.py
@@ -67,6 +67,7 @@ class OTELSettings(ServiceSettingsBase, env_prefix="DIRACX_OTEL_"):
     enabled: bool = False
     application_name: str = "diracx"
     grpc_endpoint: str = ""
+    grpc_insecure: bool = False
 
 
 def instrument_otel(app: FastAPI) -> None:
@@ -103,14 +104,20 @@ def instrument_otel(app: FastAPI) -> None:
     # default otel-collector-grpc
     tracer_provider.add_span_processor(
         BatchSpanProcessor(
-            OTLPSpanExporterGRPC(endpoint=otel_settings.grpc_endpoint, insecure=True)
+            OTLPSpanExporterGRPC(
+                endpoint=otel_settings.grpc_endpoint,
+                insecure=otel_settings.grpc_insecure,
+            )
         )
     )
     trace.set_tracer_provider(tracer_provider)
 
     # metric_reader = PeriodicExportingMetricReader(ConsoleMetricExporter(),export_interval_millis=1000)
     metric_reader = PeriodicExportingMetricReader(
-        OTLPMetricExporter(endpoint=otel_settings.grpc_endpoint, insecure=True),
+        OTLPMetricExporter(
+            endpoint=otel_settings.grpc_endpoint,
+            insecure=otel_settings.grpc_insecure,
+        ),
         export_interval_millis=3000,
     )
     meter_provider = MeterProvider(metric_readers=[metric_reader])
@@ -126,7 +133,10 @@ def instrument_otel(app: FastAPI) -> None:
     logger_provider = LoggerProvider(resource=resource)
     _logs.set_logger_provider(logger_provider)
 
-    otlp_exporter = OTLPLogExporter(endpoint=otel_settings.grpc_endpoint, insecure=True)
+    otlp_exporter = OTLPLogExporter(
+        endpoint=otel_settings.grpc_endpoint,
+        insecure=otel_settings.grpc_insecure,
+    )
     logger_provider.add_log_record_processor(BatchLogRecordProcessor(otlp_exporter))
     handler = LoggingHandler(level=logging.DEBUG, logger_provider=logger_provider)
     handler.setFormatter(logging.Formatter(DEFAULT_LOGGING_FORMAT))