diff --git a/fam-core/src/fam_core/dispatcher/dispatcher.py b/fam-core/src/fam_core/dispatcher/dispatcher.py index ff74167..e4802cd 100644 --- a/fam-core/src/fam_core/dispatcher/dispatcher.py +++ b/fam-core/src/fam_core/dispatcher/dispatcher.py @@ -275,7 +275,12 @@ class Dispatcher: self._dispatch_direct(task, payload, upload_path) def _dispatch_direct(self, task, payload, video_path): - """小文件直接上传至 /enqueue""" + """小文件直接上传至 /enqueue + + 注意 timeout 第一参数: urllib3 发送 multipart body 期间 socket + timeout 取的是 connect timeout 值(实测传 60s 则 60s 整超时), + 而非 read timeout——跨境 1.4MB/s 下 17MB 需 ~12s,必须给足。 + """ task_id = task['task_id'] try: with open(video_path, 'rb') as fh: @@ -283,7 +288,7 @@ class Dispatcher: self.edge_url, data=payload, files={'video': (os.path.basename(video_path), fh, 'video/mp4')}, - timeout=(10, 300) + timeout=(120, 300) ) except requests.RequestException as e: logger.error(f"[task_id={task_id}] 上传失败: {e}")