fix(lipsync): 私有桶 OSS 媒体 URL 提交 MediaKit 前统一重签 7 天，修复对口型 403 (#1839)

根因：bucket xiaoxia-autocut 为私有桶（匿名 GET 返回 403 AccessDenied）。 TTS 直生音频/输出成片经 storage.upload_file 返回不带签名的裸 public_url， MediaKit GPU worker(terminator→storageGW) 拉取时 403 Forbidden；前端传入的 1h 短预签名 video_url 排队后也可能过期。修复（仅改对口型相关）： - 新增 LipsyncService._sign_media_url()：自家 OSS 桶 host 的 URL（裸的/ 将过期的短预签名）统一重签为 7 天长有效期；外部临时 URL（CosyVoice/ MediaKit）原样透传；异常降级原 URL 不阻断。 - create_job 提交 MediaKit 前对 video_url/audio_url 统一重签。 - _persist_output_video 返回成片前同样重签，私有桶播放不再 403。 - 6 个新单测覆盖重签/透传/降级/端到端；lipsync 相关 46 测试全过。
2026-09-10 12:59:09 +08:00
parent b5b324d94e
commit 09fcc39e4f
2 changed files with 147 additions and 1 deletions
@@ -15,6 +15,7 @@ import logging
 import uuid
 from datetime import datetime, timezone
 from typing import Optional
+from urllib.parse import urlparse

 from app.services.mediakit_client import (
    STATUS_COMPLETED,
@@ -33,6 +34,10 @@ from packages.shared.url_security import ALLOWED_AUDIO_MIME_TYPES, safe_download

 logger = logging.getLogger(__name__)

+# 传给 MediaKit GPU worker / 回给前端播放的 OSS 预签名有效期：7 天。
+# MediaKit 排队 + 拉取可能延迟，私有桶裸 URL 或 1 小时短预签名都会 403，故统一重签长有效期。
+MEDIAKIT_URL_TTL_SECONDS = 7 * 24 * 3600
+

 class LipsyncService:
    """对口型任务 Service."""
@@ -176,6 +181,12 @@ class LipsyncService:
                emotion=emotion,
            )

+        # #1839: 私有桶 OSS 的裸 URL / 即将过期的短预签名会让 MediaKit GPU worker 拉取时 403，
+        # 提交前统一重签长有效期；外部临时 URL（CosyVoice/MediaKit）原样透传。
+        video_url = self._sign_media_url(video_url)
+        if audio_url:
+            audio_url = self._sign_media_url(audio_url)
+
        # 1. 创建数据库记录
        job_id = str(uuid.uuid4())
        job = LipsyncJobModel(
@@ -316,11 +327,36 @@ class LipsyncService:
            storage_key = f"lipsync-outputs/{user_id}/{job_id}.mp4"
            permanent_url = storage.upload_file(io.BytesIO(data), storage_key, content_type="video/mp4")
            logger.info("对口型输出视频已转存 OSS: job_id=%s key=%s", job_id, storage_key)
-            return permanent_url or temp_url
+            return self._sign_media_url(permanent_url) or temp_url
        except Exception as exc:
            logger.warning("对口型输出视频转存 OSS 失败，回退临时 URL: job_id=%s err=%s", job_id, exc)
            return temp_url

+    def _sign_media_url(self, url: str) -> str:
+        """对自家 OSS 私有桶 URL 重签长有效期预签名，供 MediaKit 拉取 / 前端播放。
+
+        - 裸 public_url（upload_file 返回，不带签名）→ 私有桶匿名访问 403，重签。
+        - 已带签名但即将过期的 URL（如前端 1h 预签名）→ 抽 storage_key 后重签。
+        - 外部 URL（CosyVoice/MediaKit 临时链接，非本桶 host）→ 原样透传。
+        - 任何异常都降级原样返回，不阻断主流程。
+        """
+        if not url:
+            return url
+        try:
+            storage = get_shared_storage_service()
+            public_base = getattr(storage, "public_url", "")
+            if not isinstance(public_base, str) or not public_base:
+                return url  # 无法判定归属，保守透传
+            own_host = urlparse(public_base).netloc.lower()
+            host = urlparse(url).netloc.lower()
+            if not own_host or host != own_host:
+                return url  # 非自家 OSS（外部临时链接），不处理
+            signed = storage.get_download_url(url, expires_seconds=MEDIAKIT_URL_TTL_SECONDS)
+            return signed or url
+        except Exception as exc:  # noqa: BLE001 - 签名失败不阻断，降级原 URL
+            logger.warning("对口型 URL 重签失败，原样返回: url_prefix=%s err=%s", url[:80], exc)
+            return url
+
    # ── 取消任务 ──────────────────────────────────────────────────────────

    def cancel_job(self, job_id: str, user_id: str) -> Optional[LipsyncJobModel]: