s

monitor.py

@@ -5,38 +5,55 @@ import logging
 from collections import deque
 import os
 import tracemalloc
+import gc
+import sys
 
-# إنشاء logger خاص لهذه الوحدة
+# إنشاء logger
 logger = logging.getLogger("monitor")
 logger.setLevel(logging.DEBUG)
 
-# إعداد ملف السجل
 base_dir = os.path.dirname(os.path.abspath(__file__))
 log_dir = os.path.join(base_dir, "data")
 os.makedirs(log_dir, exist_ok=True)
 log_path = os.path.join(log_dir, "monitor.log")
 
-# إعداد handler لملف السجل
 file_handler = logging.FileHandler(log_path)
 file_handler.setLevel(logging.DEBUG)
 formatter = logging.Formatter("📁 [%(asctime)s] [%(levelname)s] %(message)s")
 file_handler.setFormatter(formatter)
 logger.addHandler(file_handler)
 
-# إعداد handler للوحدة الأساسية (اختياري)
 stream_handler = logging.StreamHandler()
 stream_handler.setFormatter(logging.Formatter("🪵 [%(asctime)s] [%(levelname)s] %(message)s"))
 logger.addHandler(stream_handler)
 
-# تفعيل تتبع الذاكرة
+# تتبع الذاكرة
 tracemalloc.start()
 logger.info("🔍 بدأ تتبع الذاكرة")
 
-# تخزين آخر 10 قياسات
 cpu_history = deque(maxlen=10)
 mem_history = deque(maxlen=10)
 current_metrics = {'cpu': 0, 'memory': 0}
 
+def analyze_memory_objects():
+    try:
+        objects = gc.get_objects()
+        logger.info(f"📦 عدد كائنات بايثون: {len(objects)}")
+        sizes = {}
+        for obj in objects:
+            try:
+                key = type(obj).__name__
+                sizes[key] = sizes.get(key, 0) + sys.getsizeof(obj)
+            except Exception:
+                continue
+
+        top = sorted(sizes.items(), key=lambda x: x[1], reverse=True)[:10]
+        logger.info("🧮 أعلى 10 أنواع من الكائنات استهلاكًا:")
+        for name, size in top:
+            logger.info(f"🔹 {name}: {size / 1024 / 1024:.2f} MB")
+    except Exception as e:
+        logger.error(f"❌ خطأ أثناء تحليل كائنات الذاكرة: {str(e)}")
+
 def monitor_resources():
     counter = 0
     logger.info("🔁 بدأ تشغيل مراقبة الموارد")
@@ -52,10 +69,11 @@ def monitor_resources():
             cpu_history.append(cpu_percent)
             mem_history.append(mem_percent)
 
-            logger.info(f"🧠 الذاكرة - RSS: {mem_info.rss / 1024**2:.2f} MB | VMS: {mem_info.vms / 1024**2:.2f} MB")
+            logger.info(f"🧠 RSS: {mem_info.rss / 1024**2:.2f} MB | VMS: {mem_info.vms / 1024**2:.2f} MB")
             current, peak = tracemalloc.get_traced_memory()
-            logger.info(f"📊 tracemalloc - الحالي: {current / 1024**2:.2f} MB | الأعلى: {peak / 1024**2:.2f} MB")
+            logger.info(f"📊 tracemalloc: الحالي = {current / 1024**2:.2f} MB | الأعلى = {peak / 1024**2:.2f} MB")
 
+            # كل دقيقة: تحليل إضافي
             counter += 1
             if counter % 12 == 0:
                 snapshot = tracemalloc.take_snapshot()
@@ -63,6 +81,7 @@ def monitor_resources():
                 logger.info("📌 أعلى 5 أسطر استهلاكًا للذاكرة:")
                 for stat in top_stats[:5]:
                     logger.info(f"   {stat}")
+                analyze_memory_objects()
 
         except Exception as e:
             logger.exception(f"❌ استثناء في مراقبة الموارد: {str(e)}")
@@ -80,4 +99,4 @@ def get_current_metrics():
 def start_monitoring_thread():
     thread = threading.Thread(target=monitor_resources, daemon=True)
     thread.start()
-    logger.info("✅ تم بدء مراقبة الموارد في خيط منفصل")
+    logger.info("✅ تم بدء مراقبة الموارد في خيط منفصل")