fix

config.py

@@ -219,6 +219,11 @@ else:
             BOS_BUCKET_NAME,
         ]
     )
+_bos_async_env = os.environ.get("BOS_UPLOAD_ASYNC")
+if _bos_async_env is None or not _bos_async_env.strip():
+    BOS_UPLOAD_ASYNC = True
+else:
+    BOS_UPLOAD_ASYNC = _bos_async_env.strip().lower() in ("1", "true", "on", "yes")
 APP_SECRET_TOKEN = os.environ.get("APP_SECRET_TOKEN", "******")
 HOSTNAME = os.environ.get("HOSTNAME", "default-hostname")
 MODELS_PATH = os.path.abspath(

utils.py

@@ -32,6 +32,7 @@ from config import (
     BOS_BUCKET_NAME,
     BOS_IMAGE_DIR,
     BOS_UPLOAD_ENABLED,
+    BOS_UPLOAD_ASYNC,
     BOS_DOWNLOAD_TARGETS,
     HUGGINGFACE_REPO_ID,
     HUGGINGFACE_REVISION,
@@ -46,6 +47,7 @@ _BOS_DOWNLOAD_LOCK = threading.Lock()
 _BOS_DOWNLOAD_COMPLETED = False
 _BOS_BACKGROUND_EXECUTOR = None
 _BOS_BACKGROUND_FUTURES = []
+_BOS_UPLOAD_EXECUTOR = None
 _IMAGES_DIR_ABS = os.path.abspath(os.path.expanduser(IMAGES_DIR))
 _BOS_UPLOAD_CACHE = OrderedDict()
 _BOS_UPLOAD_CACHE_LOCK = threading.Lock()
@@ -255,6 +257,13 @@ def _get_background_executor() -> ThreadPoolExecutor:
     return _BOS_BACKGROUND_EXECUTOR
 
 
+def _get_upload_executor() -> ThreadPoolExecutor:
+    global _BOS_UPLOAD_EXECUTOR
+    if _BOS_UPLOAD_EXECUTOR is None:
+        _BOS_UPLOAD_EXECUTOR = ThreadPoolExecutor(max_workers=2, thread_name_prefix="bos-upload")
+    return _BOS_UPLOAD_EXECUTOR
+
+
 def ensure_huggingface_models(force_download: bool = False) -> bool:
     """确保 HuggingFace 模型仓库同步到本地 MODELS_PATH。"""
     repo_id = (HUGGINGFACE_REPO_ID or "").strip()
@@ -443,7 +452,7 @@ def ensure_bos_resources(force_download: bool = False, include_background: bool
 
 def upload_file_to_bos(file_path: str, object_name: str | None = None) -> bool:
     """
-    将指定文件上传到 BOS，失败不会抛出异常。
+    将指定文件上传到 BOS，失败不会抛出异常。默认使用后台线程异步上传。
     :param file_path: 本地文件路径
     :param object_name: BOS 对象名称（可选）
     :return: 是否成功上传
@@ -465,8 +474,7 @@ def upload_file_to_bos(file_path: str, object_name: str | None = None) -> bool:
     except OSError:
         return False
 
-    client = _get_bos_client()
-    if client is None:
+    if _get_bos_client() is None:
         return False
 
     # 生成对象名称
@@ -495,19 +503,35 @@ def upload_file_to_bos(file_path: str, object_name: str | None = None) -> bool:
         logger.info("文件已同步至 BOS（跳过重复上传，耗时 %.1f ms）: %s", elapsed_ms, object_key)
         return True
 
-    try:
-        client.upload_file(expanded_path, BOS_BUCKET_NAME, object_key)
-        elapsed_ms = (time.perf_counter() - start_time) * 1000
-        logger.info("文件已同步至 BOS（耗时 %.1f ms）: %s", elapsed_ms, object_key)
-        with _BOS_UPLOAD_CACHE_LOCK:
-            _BOS_UPLOAD_CACHE[cache_key] = cache_signature
-            _BOS_UPLOAD_CACHE.move_to_end(cache_key)
-            while len(_BOS_UPLOAD_CACHE) > _BOS_UPLOAD_CACHE_MAX:
-                _BOS_UPLOAD_CACHE.popitem(last=False)
-        return True
-    except (ClientError, BotoCoreError, Exception) as e:
-        logger.warning(f"上传到 BOS 失败（{object_key}）: {e}")
-        return False
+    def _do_upload(mode_label: str) -> bool:
+        client_inner = _get_bos_client()
+        if client_inner is None:
+            return False
+        upload_start = time.perf_counter()
+        try:
+            client_inner.upload_file(expanded_path, BOS_BUCKET_NAME, object_key)
+            elapsed_ms = (time.perf_counter() - upload_start) * 1000
+            logger.info("文件已同步至 BOS（%s，耗时 %.1f ms）: %s", mode_label, elapsed_ms, object_key)
+            with _BOS_UPLOAD_CACHE_LOCK:
+                _BOS_UPLOAD_CACHE[cache_key] = cache_signature
+                _BOS_UPLOAD_CACHE.move_to_end(cache_key)
+                while len(_BOS_UPLOAD_CACHE) > _BOS_UPLOAD_CACHE_MAX:
+                    _BOS_UPLOAD_CACHE.popitem(last=False)
+            return True
+        except (ClientError, BotoCoreError, Exception) as exc:
+            logger.warning("上传到 BOS 失败（%s，%s）: %s", object_key, mode_label, exc)
+            return False
+
+    if BOS_UPLOAD_ASYNC:
+        try:
+            executor = _get_upload_executor()
+            executor.submit(_do_upload, "异步")
+            return True
+        except Exception as exc:
+            logger.warning("调度 BOS 异步上传失败，将改为同步执行: %s", exc)
+            return _do_upload("同步")
+
+    return _do_upload("同步")
 
 
 def delete_file_from_bos(file_path: str | None = None,