Add request summary in MozLog format

Author: leplatrem

src/app/api.py

@@ -1,3 +1,8 @@
+import logging
+import sys
+import time
+from datetime import datetime
+
 import uvicorn  # type: ignore
 from fastapi import FastAPI, Request
 from fastapi.responses import RedirectResponse
@@ -6,6 +11,31 @@
 from src.app.monitor import api_router as monitor_router
 from src.jbi.router import api_router as jbi_router
 
+settings = get_settings()
+
+logging_config = {
+    "version": 1,
+    "formatters": {
+        "json": {
+            "()": "dockerflow.logging.JsonLogFormatter",
+            "logger_name": "jbi",
+        },
+    },
+    "handlers": {
+        "console": {
+            "level": settings.log_level.upper(),
+            "class": "logging.StreamHandler",
+            "formatter": "json",
+            "stream": sys.stdout,
+        }
+    },
+    "loggers": {
+        "request.summary": {"handlers": ["console"], "level": "INFO"},
+    },
+}
+
+logging.config.dictConfig(logging_config)
+
 app = FastAPI(
     title="Jira Bugzilla Integration (JBI)",
     description="JBI v2 Platform",
@@ -15,6 +45,7 @@
 app.include_router(monitor_router)
 app.include_router(jbi_router)
 
+summary_logger = logging.getLogger("request.summary")
 
 @app.get("/", include_in_schema=False)
 def root(request: Request):
@@ -26,8 +57,32 @@ def root(request: Request):
     return RedirectResponse(url="./docs")
 
 
+@app.middleware("http")
+async def request_summary(request: Request, call_next):
+    previous_time = time.time()
+
+    infos = {
+        "agent": request.headers.get("User-Agent"),
+        "path": request.url.path,
+        "method": request.method,
+        "lang": request.headers.get("Accept-Language"),
+        "querystring": dict(request.query_params),
+        "errno": 0,
+    }
+
+    response = await call_next(request)
+
+    current = time.time()
+    duration = int((current - previous_time) * 1000.0)
+    isotimestamp = datetime.fromtimestamp(current).isoformat()
+    infos = {"time": isotimestamp, "code": response.status_code, "t": duration, **infos}
+
+    summary_logger.info("", extra=infos)
+
+    return response
+
+
 if __name__ == "__main__":
-    settings = get_settings()
     uvicorn.run(
         "app:app", host="0.0.0.0", port=settings.port, reload=settings.app_reload
     )

src/app/environment.py

@@ -6,6 +6,7 @@
 
 
 class Settings(BaseSettings):
+    host: str = "0.0.0.0"
     port: str = "80"
     app_reload: bool = True
 
@@ -20,6 +21,9 @@ class Settings(BaseSettings):
     jira_password: str
     bugzilla_api_key: str
 
+    # Logging
+    log_level: str = "info"
+
 
 @lru_cache()
 def get_settings() -> Settings: