Added json logger

requirements.txt

@@ -10,6 +10,7 @@ mysql-connector-python==9.4.0
 prometheus_client==0.23.1
 pydantic==2.12.0
 pydantic_core==2.41.1
+python-json-logger==4.0.0
 requests==2.32.5
 sniffio==1.3.1
 starlette==0.48.0

src/logger_handler.py

@@ -1,5 +1,11 @@
-import logging
 import os
+import logging
+
+try:
+	from pythonjsonlogger import jsonlogger
+	JSON_LOGGING = True
+except ImportError:
+	JSON_LOGGING = False
 
 LOG_LEVEL = os.getenv("LOG_LEVEL", "INFO").upper()
 if LOG_LEVEL not in {"ERROR", "DEBUG", "INFO", "WARNING", "CRITICAL"}:
@@ -9,9 +15,14 @@ def setup_logger(name: str) -> logging.Logger:
 	logger = logging.getLogger(name)
 	if not logger.handlers:
 		handler = logging.StreamHandler()
-		formatter = logging.Formatter(
-			'%(asctime)s - %(name)s - %(levelname)s - %(message)s'
-		)
+		if JSON_LOGGING:
+			formatter = jsonlogger.JsonFormatter(
+				"%(asctime)s %(name)s %(levelname)s %(message)s"
+			)
+		else:
+			formatter = logging.Formatter(
+				"%(asctime)s - %(name)s - %(levelname)s - %(message)s"
+			)
 		handler.setFormatter(formatter)
 		logger.addHandler(handler)
 	logger.setLevel(getattr(logging, LOG_LEVEL))