Update app/streamlit_app.py

app/streamlit_app.py

@@ -211,6 +211,41 @@ class StreamlitAppManager:
             return None
 
 
+    def get_monitoring_metrics_from_api(self):
+        """Get current monitoring metrics from API"""
+        try:
+            if not self.api_available:
+                return None
+            response = self.session.get(f"{self.config['api_url']}/monitor/metrics/current", timeout=10)
+            return response.json() if response.status_code == 200 else None
+        except Exception as e:
+            logger.warning(f"Could not fetch monitoring metrics: {e}")
+            return None
+    
+    def get_monitoring_alerts_from_api(self):
+        """Get monitoring alerts from API"""
+        try:
+            if not self.api_available:
+                return None
+            response = self.session.get(f"{self.config['api_url']}/monitor/alerts", timeout=10)
+            return response.json() if response.status_code == 200 else None
+        except Exception as e:
+            logger.warning(f"Could not fetch monitoring alerts: {e}")
+            return None
+    
+    def get_prediction_patterns_from_api(self, hours: int = 24):
+        """Get prediction patterns from API"""
+        try:
+            if not self.api_available:
+                return None
+            response = self.session.get(f"{self.config['api_url']}/monitor/patterns?hours={hours}", timeout=10)
+            return response.json() if response.status_code == 200 else None
+        except Exception as e:
+            logger.warning(f"Could not fetch prediction patterns: {e}")
+            return None
+
+
+
 # Initialize app manager
 app_manager = StreamlitAppManager()
 
@@ -297,7 +332,9 @@ def show_logs_section():
         "Scheduler Log": path_manager.get_logs_path("scheduler_execution.json"),
         "Drift History": path_manager.get_logs_path("drift_history.json"),
         "Drift Alerts": path_manager.get_logs_path("drift_alerts.json"),
-        "Monitoring Log": path_manager.get_logs_path("monitoring_log.json")
+        "Prediction Monitor": path_manager.get_logs_path("monitor/predictions.json"),
+        "Metrics Log": path_manager.get_logs_path("monitor/metrics.json"),
+        "Alerts Log": path_manager.get_logs_path("monitor/alerts.json")
     }
     
     col1, col2 = st.columns([2, 1])
@@ -984,15 +1021,17 @@ def main():
                 '<div class="error-message">🔴 API Service: Offline</div>', unsafe_allow_html=True)
 
     # Main content area
-    tab1, tab2, tab3, tab4, tab5, tab6 = st.tabs([
+    tab1, tab2, tab3, tab4, tab5, tab6, tab7 = st.tabs([
         "🔍 Prediction",
-        "📊 Batch Analysis",
+        "📊 Batch Analysis", 
         "📈 Analytics",
         "🎯 Model Training",
         "📋 Logs",
-        "⚙️ System Status"
+        "⚙️ System Status",
+        "📊 Monitoring"  # New monitoring tab
     ])
 
+
     # Tab 1: Individual Prediction
     with tab1:
         st.header("Single Text Analysis")
@@ -1503,6 +1542,19 @@ def main():
     with tab6:
         render_system_status()
 
+    # Tab 7: Monitoring
+    with tab7:
+        st.header("Real-time System Monitoring")
+        
+        col1, col2 = st.columns([1, 1])
+        with col1:
+            if st.button("🔄 Refresh Monitoring", use_container_width=True):
+                st.rerun()
+        
+        render_monitoring_dashboard()
+        st.divider()
+        render_monitoring_alerts()
+
 def render_system_status():
     """Render system status tab"""
     st.header("System Status & Monitoring")
@@ -1604,6 +1656,74 @@ def render_system_status():
     else:
         st.warning("No model metadata available")
 
+def render_monitoring_dashboard():
+    """Render real-time monitoring dashboard"""
+    st.subheader("📊 Real-time Monitoring Dashboard")
+    
+    monitoring_data = app_manager.get_monitoring_metrics_from_api()
+    
+    if monitoring_data:
+        # Current metrics display
+        col1, col2, col3, col4 = st.columns(4)
+        
+        pred_metrics = monitoring_data.get('prediction_metrics', {})
+        system_metrics = monitoring_data.get('system_metrics', {})
+        api_metrics = monitoring_data.get('api_metrics', {})
+        
+        with col1:
+            st.metric("Predictions/Min", f"{pred_metrics.get('predictions_per_minute', 0):.1f}")
+            st.metric("Avg Confidence", f"{pred_metrics.get('avg_confidence', 0):.2f}")
+        
+        with col2:
+            st.metric("Response Time", f"{api_metrics.get('avg_response_time', 0):.2f}s")
+            st.metric("Error Rate", f"{api_metrics.get('error_rate', 0):.1%}")
+        
+        with col3:
+            st.metric("CPU Usage", f"{system_metrics.get('cpu_percent', 0):.1f}%")
+            st.metric("Memory Usage", f"{system_metrics.get('memory_percent', 0):.1f}%")
+        
+        with col4:
+            anomaly_score = pred_metrics.get('anomaly_score', 0)
+            st.metric("Anomaly Score", f"{anomaly_score:.3f}")
+            if anomaly_score > 0.3:
+                st.warning("High anomaly score detected!")
+    else:
+        st.warning("Monitoring data not available")
+
+def render_monitoring_alerts():
+    """Render monitoring alerts section"""
+    st.subheader("🚨 Active Alerts")
+    
+    alerts_data = app_manager.get_monitoring_alerts_from_api()
+    
+    if alerts_data:
+        active_alerts = alerts_data.get('active_alerts', [])
+        alert_stats = alerts_data.get('alert_statistics', {})
+        
+        # Alert statistics
+        col1, col2, col3 = st.columns(3)
+        with col1:
+            st.metric("Active Alerts", alert_stats.get('active_alerts', 0))
+        with col2:
+            st.metric("Critical Alerts", alert_stats.get('critical_alerts_active', 0))
+        with col3:
+            st.metric("24h Alert Rate", f"{alert_stats.get('alert_rate_per_hour', 0):.1f}/hr")
+        
+        # Active alerts display
+        if active_alerts:
+            for alert in active_alerts:
+                alert_type = alert.get('type', 'info')
+                if alert_type == 'critical':
+                    st.error(f"🔴 **{alert.get('title', 'Unknown')}**: {alert.get('message', '')}")
+                elif alert_type == 'warning':
+                    st.warning(f"🟡 **{alert.get('title', 'Unknown')}**: {alert.get('message', '')}")
+                else:
+                    st.info(f"🔵 **{alert.get('title', 'Unknown')}**: {alert.get('message', '')}")
+        else:
+            st.success("No active alerts")
+    else:
+        st.warning("Alert data not available")
+        
 
 # Auto-refresh logic
 if st.session_state.auto_refresh: