sync: 193 file da Baida98/AI@6dc5684d (2026-08-27 21:57 UTC) [deploy-all]

api/performance_rum.py

@@ -11,6 +11,7 @@ from __future__ import annotations
 
 import asyncio
 import hashlib
+import logging
 import math
 import os
 import re
@@ -37,6 +38,7 @@ _ALLOWED_NAVIGATION = frozenset({"navigate", "reload", "back-forward", "prerende
 _RATE_WINDOW_SECONDS = 60
 _RATE_LIMIT = 120
 _rate_buckets: dict[str, tuple[float, int]] = {}
+_logger = logging.getLogger("performance_rum")
 
 
 class MetricSample(BaseModel):
@@ -148,24 +150,36 @@ async def ingest_metric(
     if not _allow_rate(_rate_key(request, os.getenv("RUM_HASH_SALT", "rum"))):
         raise HTTPException(status_code=429, detail="rate limit exceeded")
 
-    await asyncio.to_thread(
-        _execute,
-        """
-        insert into public.rum_samples
-          (metric, value, release, device, connection_type, navigation_type, bucket_start)
-        values (%(metric)s, %(value)s, %(release)s, %(device)s, %(connection_type)s,
-                %(navigation_type)s, %(bucket_start)s)
-        """,
-        {
-            "metric": sample.metric,
-            "value": sample.value,
-            "release": sample.release,
-            "device": sample.device,
-            "connection_type": sample.connection_type,
-            "navigation_type": sample.navigation_type,
-            "bucket_start": _bucket_start(datetime.now(timezone.utc)),
-        },
-    )
+    try:
+        await asyncio.to_thread(
+            _execute,
+            """
+            insert into public.rum_samples
+              (metric, value, release, device, connection_type, navigation_type, bucket_start)
+            values (%(metric)s, %(value)s, %(release)s, %(device)s, %(connection_type)s,
+                    %(navigation_type)s, %(bucket_start)s)
+            """,
+            {
+                "metric": sample.metric,
+                "value": sample.value,
+                "release": sample.release,
+                "device": sample.device,
+                "connection_type": sample.connection_type,
+                "navigation_type": sample.navigation_type,
+                "bucket_start": _bucket_start(datetime.now(timezone.utc)),
+            },
+        )
+    except HTTPException:
+        raise
+    except Exception as exc:
+        _logger.error(
+            "RUM database operation failed type=%s metric=%s device=%s",
+            type(exc).__name__, sample.metric, sample.device,
+        )
+        raise HTTPException(
+            status_code=status.HTTP_503_SERVICE_UNAVAILABLE,
+            detail="RUM database temporaneamente non disponibile",
+        ) from exc
     return {"accepted": True}
 
 
@@ -183,25 +197,37 @@ async def performance_summary(
     if release != "all" and not _RELEASE_RE.fullmatch(release.lower()):
         raise HTTPException(status_code=400, detail="invalid release")
 
-    rows = await asyncio.to_thread(
-        _execute,
-        """
-        select metric, release, device,
-               count(*)::integer as sample_count,
-               percentile_cont(0.50) within group (order by value) as p50,
-               percentile_cont(0.75) within group (order by value) as p75,
-               percentile_cont(0.95) within group (order by value) as p95
-        from public.rum_samples
-        where bucket_start >= %(from_time)s
-          and bucket_start < %(to_time)s
-          and device = %(device)s
-          and (%(release)s = 'all' or release = %(release)s)
-        group by metric, release, device
-        order by metric, release
-        """,
-        {"from_time": from_time, "to_time": to_time, "device": device, "release": release.lower()},
-        fetch=True,
-    )
+    try:
+        rows = await asyncio.to_thread(
+            _execute,
+            """
+            select metric, release, device,
+                   count(*)::integer as sample_count,
+                   percentile_cont(0.50) within group (order by value) as p50,
+                   percentile_cont(0.75) within group (order by value) as p75,
+                   percentile_cont(0.95) within group (order by value) as p95
+            from public.rum_samples
+            where bucket_start >= %(from_time)s
+              and bucket_start < %(to_time)s
+              and device = %(device)s
+              and (%(release)s = 'all' or release = %(release)s)
+            group by metric, release, device
+            order by metric, release
+            """,
+            {"from_time": from_time, "to_time": to_time, "device": device, "release": release.lower()},
+            fetch=True,
+        )
+    except HTTPException:
+        raise
+    except Exception as exc:
+        _logger.error(
+            "RUM summary database operation failed type=%s device=%s",
+            type(exc).__name__, device,
+        )
+        raise HTTPException(
+            status_code=status.HTTP_503_SERVICE_UNAVAILABLE,
+            detail="RUM database temporaneamente non disponibile",
+        ) from exc
     for row in rows:
         if row["sample_count"] < 20:
             row["p50"] = row["p75"] = row["p95"] = None