🐳 Alter docker setup to use Open Telemetry

Dockerfile

@@ -42,6 +42,7 @@ RUN apt-get update && apt-get install -y --no-install-recommends \
 
 COPY --from=build /usr/local/lib/python3.7 /usr/local/lib/python3.7
 COPY --from=build /usr/local/bin/uwsgi /usr/local/bin/uwsgi
+COPY --from=build /usr/local/bin/opentelemetry-instrument /usr/local/bin/opentelemetry-instrument
 
 # Stage 3.2 - Copy source code
 WORKDIR /app

bin/docker_start.sh

@@ -51,14 +51,14 @@ fi
 
 # Start server
 >&2 echo "Starting server"
-uwsgi \
+cd src/
+opentelemetry-instrument uwsgi \
     --http :$uwsgi_port \
     --http-keepalive \
     --manage-script-name \
     --mount $mountpoint=objects.wsgi:application \
     --static-map /static=/app/static \
     --static-map /media=/app/media  \
-    --chdir src \
     --enable-threads \
     --processes $uwsgi_processes \
     --threads $uwsgi_threads \

src/manage.py

@@ -1,11 +1,16 @@
 #!/usr/bin/env python
 import sys
 
+from opentelemetry.instrumentation.django import DjangoInstrumentor
+
 from objects.setup import setup_env
 
 if __name__ == "__main__":
     setup_env()
 
+    # This call is what makes the Django application be instrumented
+    DjangoInstrumentor().instrument()
+
     try:
         from django.core.management import execute_from_command_line
     except ImportError:

src/objects/utils/apps.py

@@ -1,9 +1,55 @@
 from django.apps import AppConfig
+import json
+# from opentelemetry import trace
+from opentelemetry.sdk.trace import TracerProvider
+from opentelemetry.sdk.trace.export import (
+    BatchSpanProcessor,
+    ConsoleSpanExporter,
+    SpanExportResult,
+    SpanExporter,
+)
+import sys
+from os import linesep
+from elasticapm.contrib.opentelemetry import trace
+
+# class CustomSpanExporter(SpanExporter):
+#     def __init__(
+#         self,
+#         service_name=None,
+#         out=sys.stdout,
+#         formatter=lambda span: span.to_json()
+#         + linesep,
+#     ):
+#         self.out = out
+#         self.formatter = formatter
+#         self.service_name = service_name
+
+#     def export(self, spans) -> SpanExportResult:
+#         for span in spans:
+#             data = json.loads(span.to_json())
+#             print(data)
+#             self.out.write(self.formatter(span))
+#         self.out.flush()
+#         return SpanExportResult.SUCCESS
 
 
 class UtilsConfig(AppConfig):
     name = "objects.utils"
 
     def ready(self):
+        from opentelemetry import trace
+        from opentelemetry.sdk.trace import TracerProvider
+        from opentelemetry.sdk.trace.export import (
+            BatchSpanProcessor,
+            ConsoleSpanExporter,
+        )
+
         from . import checks  # noqa
         from . import oas_extensions  # noqa
+
+        provider = TracerProvider()
+        trace.set_tracer_provider(provider)
+
+        provider.add_span_processor(
+            BatchSpanProcessor(ConsoleSpanExporter(service_name="Objects API"))
+        )