update prototype to test out otlp, added insecure field

Signed-off-by: Alex Boten <aboten@lightstep.com>
MrAlias · Feb 15, 2023 · 159b1b5 · 159b1b5
1 parent e45b943
commit 159b1b5
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 8 deletions.
diff --git a/json_schema/schema/schema.json b/json_schema/schema/schema.json
@@ -145,11 +145,13 @@
                 },
                 "default_histogram_aggregation": {
                     "type": "string"
+                },
+                "insecure": {
+                    "type": "boolean"
                 }
             },
             "required": [
-                "endpoint",
-                "protocol"
+                "endpoint"
             ],
             "title": "Otlp"
         },

diff --git a/prototypes/python/otel.py b/prototypes/python/otel.py
@@ -40,12 +40,12 @@ def _resource(self):
 
     # _get_exporter returns an exporter class for the signal
     def _get_exporter(self, signal: str, name: str):
-        # if name not in self._config.get("sdk").get(signal).get("exporters"):
-        #     raise Exception(f"exporter {name} not specified for {signal} signal")
+        if name not in self._config.get("sdk").get(signal).get("exporters"):
+            raise Exception(f"exporter {name} not specified for {signal} signal")
 
         exporter = _import_config_component(name, f"opentelemetry_{signal}_exporter")
         if issubclass(exporter, SpanExporter):
-            return exporter
+            return exporter(**self._config.get("sdk").get(signal).get("exporters").get(name))
         raise RuntimeError(f"{name} is not a {signal} exporter")
 
     def set_tracer_provider(self):
@@ -57,7 +57,7 @@ def set_tracer_provider(self):
             logging.debug("adding span processor %s", processor)
             try:
                 # TODO: pass in exporter arguments
-                processor = BatchSpanProcessor(self._get_exporter("traces", processor.get("args").get("exporter"))())
+                processor = BatchSpanProcessor(self._get_exporter("traces", processor.get("args").get("exporter")))
                 provider.add_span_processor(processor)
             except ModuleNotFoundError as exc:
                 logging.error("module not found", exc)

diff --git a/prototypes/python/prototype.py b/prototypes/python/prototype.py
@@ -15,8 +15,8 @@ def main():
     tracer = get_tracer("config-prototype")
 
     with tracer.start_as_current_span("operation-a"):
-        with tracer.start_as_current_span("operation-a"):
-            with tracer.start_as_current_span("operation-a"):
+        with tracer.start_as_current_span("operation-b"):
+            with tracer.start_as_current_span("operation-c"):
                 logging.debug("you should see traces after this line")
 
 main()
diff --git a/prototypes/python/requirements.txt b/prototypes/python/requirements.txt
@@ -2,5 +2,6 @@ jsonschema
 pyyaml
 opentelemetry-api
 opentelemetry-sdk
+opentelemetry-exporter-otlp
 opentelemetry-exporter-jaeger
 opentelemetry-exporter-zipkin