Update streamlit_app.py

streamlit_app.py

@@ -61,51 +61,56 @@ def get_tiktok_stream_url():
         pass
     return None
 
-def start_stream_light(stream_key, stream_url):
+def start_stream_emergency(stream_key, stream_url):
     """
-    إعدادات محسّنة لبيئة Hugging Face: جودة أعلى دون قتل المعالج.
+    إعدادات طوارئ منخفضة الاستهلاك جداً لتخفيف الضغط العالي.
     """
     if not stream_key or not stream_url:
         return None
-    log("🎬 بدء البث (جودة محسّنة – HF آمن)...")
+    log("🎬 بدء البث (وضع الطوارئ – خفيف جداً)...")
     rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{stream_key}"
 
+    # قتل أي عمليات عالقة من محاولات سابقة
+    try:
+        subprocess.run(["killall", "-9", "ffmpeg", "yt-dlp"], stderr=subprocess.DEVNULL)
+    except:
+        pass
+
     cmd = [
         "nice", "-n", "19", "ffmpeg",
-        "-hide_banner", "-loglevel", "verbose",
+        "-hide_banner", "-loglevel", "warning",
         "-re",
-        "-analyzeduration", "30M",
-        "-probesize", "30M",
-        "-thread_queue_size", "4096",
-        "-rtbufsize", "256M",
+        "-analyzeduration", "15M",        # تقليل التحليل
+        "-probesize", "15M",
+        "-thread_queue_size", "2048",     # أقل استهلاكاً
+        "-rtbufsize", "128M",             # تقليل البفر
 
-        # صمود عالي
+        # صمود مخفف (لا داعي لقيم ضخمة تثقل النظام)
         "-reconnect", "1",
         "-reconnect_streamed", "1",
         "-reconnect_delay_max", "30",
-        "-timeout", "30000000",
-        "-rw_timeout", "60000000",
+        "-timeout", "10000000",
+        "-rw_timeout", "20000000",
 
         "-i", stream_url,
         "-err_detect", "ignore_err",
 
-        # فلتر تغيير الحجم: lanczos يعطي وضوحًا أفضل من الافتراضي دون تكلفة معالجة كبيرة
-        "-vf", "scale=1080:1920:force_original_aspect_ratio=increase:flags=lanczos,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black:eval=frame",
+        # فلتر بسيط سريع (bicubic الافتراضي) دون تحميل lanczos
+        "-vf", "scale=1080:1920:force_original_aspect_ratio=increase,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black:eval=frame",
 
-        # ترميز فيديو محسّن (veryfast بدلاً من ultrafast) مع رفع معدل البت قليلاً
+        # ترميز ultrafast (الأسرع والأخف)
         "-c:v", "libx264",
-        "-preset", "veryfast",         # جودة أفضل +10% استهلاك معالج فقط
-        "-crf", "20",                  # جودة عالية ثابتة
-        "-maxrate", "9000k",           # أعلى بقليل للاستفادة من الباندويث
-        "-bufsize", "18000k",          # ضعف maxrate لسلاسة في التدفق
+        "-preset", "ultrafast",
+        "-crf", "22",                     # أعلى رقم = أقل جودة لكن أقل معالج
+        "-maxrate", "6000k",              # أقل لتخفيف الضغط
+        "-bufsize", "12000k",
         "-g", "60",
         "-vsync", "2",
         "-pix_fmt", "yuv420p",
 
-        # نسخ الصوت مباشرة بدون إعادة ترميز
         "-c:a", "copy",
-        "-max_muxing_queue_size", "4096",
-        "-max_delay", "3000000",
+        "-max_muxing_queue_size", "2048",
+        "-max_delay", "2000000",
         "-flvflags", "no_duration_filesize+add_keyframe_index",
         "-f", "flv", rtmp_url
     ]
@@ -117,14 +122,12 @@ def start_stream_light(stream_key, stream_url):
     return {"ffmpeg": proc}
 
 def log_system_stats():
-    """تسجيل حالة المعالج والذاكرة"""
     try:
         load1, load5, load15 = os.getloadavg()
         mem = psutil.virtual_memory()
-        mem_used_percent = mem.percent
-        log(f"📊 تحميل المعالج: 1min={load1:.2f}, 5min={load5:.2f}, 15min={load15:.2f} | ذاكرة مستخدمة: {mem_used_percent:.1f}%")
+        log(f"📊 CPU Load: {load1:.2f} / {load5:.2f} / {load15:.2f} | RAM: {mem.percent:.1f}%")
     except Exception as e:
-        log(f"⚠️ تعذر قراءة إحصائيات النظام: {e}")
+        log(f"⚠️ إحصائيات: {e}")
 
 def run_monitor():
     if os.path.exists(LOCK_FILE):
@@ -144,8 +147,8 @@ def run_monitor():
     was_streaming = False
     consecutive_fails = 0
 
-    log("🚀 محرك البث بجودة محسّنة – HF آمن")
-    log_system_stats()  # أول قراءة
+    log("🚀 محرك الطوارئ الخفيف جداً")
+    log_system_stats()
 
     while True:
         try:
@@ -156,20 +159,19 @@ def run_monitor():
                     log("🟢 بدء بث جديد...")
                     if processes:
                         kill_process_tree(processes["ffmpeg"].pid)
-                    processes = start_stream_light(STREAM_KEY, stream_url)
+                    processes = start_stream_emergency(STREAM_KEY, stream_url)
                     if processes:
                         is_streaming = True
                         was_streaming = True
                         consecutive_fails = 0
-                        log_system_stats()  # قراءة بعد بدء البث
+                        log_system_stats()
                 else:
                     if is_streaming and processes and processes["ffmpeg"].poll() is not None:
                         exit_code = processes["ffmpeg"].poll()
                         log(f"⚠️ ffmpeg مات! exit code: {exit_code}")
                         if os.path.exists(FFMPEG_LOG):
                             with open(FFMPEG_LOG) as f:
-                                lines = f.readlines()
-                                log("📋 آخر سجلات ffmpeg:\n" + "".join(lines[-20:]))
+                                log("📋 آخر سجلات ffmpeg:\n" + "".join(f.readlines()[-10:]))
                         is_streaming = False
                         processes = None
                         was_streaming = False
@@ -184,9 +186,7 @@ def run_monitor():
                     was_streaming = False
                     consecutive_fails = 0
 
-            # تسجيل إحصائيات النظام كل دورة (10 ثوانٍ)
             log_system_stats()
-
             time.sleep(10)
 
         except Exception as e:
@@ -194,7 +194,7 @@ def run_monitor():
             time.sleep(10)
 
 if __name__ == "__main__":
-    log("✅ بدء تشغيل المحرك بجودة محسّنة لبيئة Hugging Face")
+    log("✅ بدء محرك الطوارئ الخفيف")
     t = threading.Thread(target=run_monitor, daemon=True)
     t.start()
     while True: