Create web_viewer.py

web_viewer.py

@@ -0,0 +1,61 @@
+import gradio as gr
+import sqlite3
+import pandas as pd
+import json
+import os
+
+DB_PATH = os.path.join(os.getenv('BUCKET_PATH', '/data'), 'aviator_regression.db')
+
+def load_data():
+    if not os.path.exists(DB_PATH):
+        return pd.DataFrame(columns=["Date/Heure", "Cote Actuelle", "Historique (10 dernières)"])
+    
+    try:
+        # On se connecte avec un timeout pour ne pas bloquer le script de collecte
+        conn = sqlite3.connect(DB_PATH, timeout=5)
+        
+        # On lit les 500 dernières lignes pour ne pas surcharger le navigateur
+        df = pd.read_sql_query("""
+            SELECT cote, historique_10, timestamp 
+            FROM aviator_data 
+            ORDER BY id DESC 
+            LIMIT 500
+        """, conn)
+        conn.close()
+
+        if df.empty:
+            return pd.DataFrame(columns=["Date/Heure", "Cote Actuelle", "Historique (10 dernières)"])
+
+        # On transforme le texte JSON en vraie liste lisible
+        df['historique_10'] = df['historique_10'].apply(lambda x: str(json.loads(x)))
+        
+        # On formate le timestamp en date lisible
+        df['Date/Heure'] = pd.to_datetime(df['timestamp'], unit='s').dt.strftime('%Y-%m-%d %H:%M:%S')
+        
+        # On réorganise les colonnes
+        df = df[['Date/Heure', 'cote', 'historique_10']]
+        df.columns = ["Date/Heure", "Cote Actuelle", "Historique (10 dernières)"]
+        
+        return df
+
+    except Exception as e:
+        return pd.DataFrame({"Erreur": [f"Impossible de lire la DB : {str(e)}"]})
+
+# Création de l'interface web
+with gr.Blocks(title="DB Aviator", theme=gr.themes.Soft()) as demo:
+    gr.Markdown("# 📊 Explorateur de la base Aviator")
+    gr.Markdown("Les données se mettent à jour lorsque tu cliques sur le bouton.")
+    
+    btn = gr.Button("🔄 Rafraîchir les données", variant="primary")
+    table = gr.Dataframe(
+        headers=["Date/Heure", "Cote Actuelle", "Historique (10 dernières)"],
+        datatype=["str", "number", "str"],
+        interactive=False
+    )
+    
+    # Charge les données au démarrage et quand on clique
+    btn.click(fn=load_data, outputs=table)
+    demo.load(fn=load_data, outputs=table)
+
+# Lance le serveur sur le port 7860 (obligatoire pour HF)
+demo.launch(server_name="0.0.0.0", server_port=7860, show_error=True)