optimize: shorten sync interval to 4h and implement auto-cleanup for 1GB limit

app.py

@@ -49,7 +49,7 @@ def 启动后台采集():
         print(f"[Collector] {line.strip()}")
 
 def 周期性整理与同步():
-    """每隔 12 小时执行一次数据整理与 HF 同步"""
+    """每隔 4 小时执行一次数据整理与 HF 同步"""
     import sys
     organize_script = os.path.join("服务", "数据采集", "整理行情数据.py")
     env = os.environ.copy()
@@ -60,14 +60,19 @@ def 周期性整理与同步():
         time.sleep(60) # 启动后 1 分钟先跑一次
         print("🕒 开始执行周期性数据整理与同步...")
         try:
-            # 运行整理脚本，默认会触发 sync-hf (因为我们在脚本里改了默认值为 True)
+            # 1. 执行整理 (整理后会自动删除原始碎片)
             subprocess.run([sys.executable, organize_script], env=env, check=True)
-            print("✅ 周期性整理与同步完成。")
+            
+            # 2. 执行云端同步
+            print("📤 开始同步到 Hugging Face Dataset...")
+            from 服务.数据采集.hf_sync import sync_to_hf
+            if sync_to_hf():
+                print("✅ 周期性整理与同步完成。")
         except Exception as e:
-            print(f"❌ 周期性整理失败: {e}")
+            print(f"❌ 周期性整理与同步失败: {e}")
         
-        # 每 12 小时运行一次
-        time.sleep(12 * 3600)
+        # 每 4 小时运行一次
+        time.sleep(4 * 3600)
 
 # 启动后台线程
 thread_collector = threading.Thread(target=启动后台采集, daemon=True)

服务/数据采集/hf_sync.py

@@ -47,7 +47,7 @@ def sync_to_hf():
             return True
 
         # 上传整个目录
-        logger.info(f"� 正在同步数据到 Hugging Face Dataset: {repo_id}...")
+        logger.info(f"📤 正在同步数据到 Hugging Face Dataset: {repo_id}...")
         api.upload_folder(
             folder_path=str(LOCAL_DATA_DIR),
             repo_id=repo_id,
@@ -56,6 +56,21 @@ def sync_to_hf():
             ignore_patterns=["*.tmp", "*.log"]
         )
         logger.info("✅ 同步完成！")
+        
+        # --- 新增：同步成功后清理本地已整理的文件，节省 1GB 空间 ---
+        logger.info("🧹 正在清理本地已上传的数据以节省空间...")
+        try:
+            import shutil
+            for item in os.listdir(LOCAL_DATA_DIR):
+                item_path = os.path.join(LOCAL_DATA_DIR, item)
+                if os.path.isfile(item_path):
+                    os.remove(item_path)
+                elif os.path.isdir(item_path):
+                    shutil.rmtree(item_path)
+            logger.info("✅ 本地已整理数据清理完毕，空间已释放。")
+        except Exception as e:
+            logger.warning(f"⚠️ 清理本地空间时出错 (非致命): {e}")
+            
         return True
     except Exception as e:
         logger.error(f"❌ 同步过程中发生错误: {e}")