Create recommendation_logger.py

analytics/recommendation_logger.py

@@ -0,0 +1,59 @@
+from __future__ import annotations
+
+from typing import Any
+
+import pandas as pd
+
+
+def build_recommendation_log_rows(
+    recommendations: list[dict[str, Any]],
+    game_row: dict[str, Any],
+    created_at: str,
+) -> pd.DataFrame:
+    rows: list[dict[str, Any]] = []
+
+    away_team = str(game_row.get("away_team", "") or "").strip()
+    home_team = str(game_row.get("home_team", "") or "").strip()
+    status = str(game_row.get("status", "") or "").strip()
+    game_pk = str(game_row.get("game_pk", "") or "").strip()
+
+    for rec in recommendations:
+        rows.append(
+            {
+                "created_at": created_at,
+                "game_pk": game_pk,
+                "away_team": away_team,
+                "home_team": home_team,
+                "status": status,
+                "slot": rec.get("slot"),
+                "batter_name": rec.get("batter_name"),
+                "pitcher_name": rec.get("pitcher_name"),
+                "ev90": rec.get("ev90"),
+                "hit_prob": rec.get("hit_prob"),
+                "hr_prob": rec.get("hr_prob"),
+                "tb2p_prob": rec.get("tb2p_prob"),
+                "fair_hit_odds": rec.get("fair_hit_odds"),
+                "fair_hr_odds": rec.get("fair_hr_odds"),
+                "fair_tb2p_odds": rec.get("fair_tb2p_odds"),
+                "book_hit_odds": rec.get("book_hit_odds"),
+                "book_hr_odds": rec.get("book_hr_odds"),
+                "book_tb2p_odds": rec.get("book_tb2p_odds"),
+                "hit_edge": rec.get("hit_edge"),
+                "hr_edge": rec.get("hr_edge"),
+                "tb2p_edge": rec.get("tb2p_edge"),
+                "adjusted_edge": rec.get("adjusted_edge"),
+                "hit_bet_ev": rec.get("hit_bet_ev"),
+                "hr_bet_ev": rec.get("hr_bet_ev"),
+                "tb2p_bet_ev": rec.get("tb2p_bet_ev"),
+                "confidence": rec.get("confidence"),
+                "confidence_bucket": rec.get("confidence_bucket"),
+                "recommendation_tier": rec.get("recommendation_tier"),
+                "priority_score": rec.get("priority_score"),
+                "reason_tags": " | ".join(rec.get("reason_tags", []) or []),
+                "starter_stays_next_batter_prob": rec.get("starter_stays_next_batter_prob"),
+                "starter_stays_next_inning_prob": rec.get("starter_stays_next_inning_prob"),
+                "bullpen_entry_prob": rec.get("bullpen_entry_prob"),
+            }
+        )
+
+    return pd.DataFrame(rows)