From f024b6953ec6058c809be5141e235c2745f87610 Mon Sep 17 00:00:00 2001 From: chakcy <947105045@qq.com> Date: Mon, 3 Aug 2026 09:16:23 +0800 Subject: [PATCH] modify: aibox sophon adapter video --- aibox_sophon_adapter/__init__.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/aibox_sophon_adapter/__init__.py b/aibox_sophon_adapter/__init__.py index e0fbc2c..7c67e70 100644 --- a/aibox_sophon_adapter/__init__.py +++ b/aibox_sophon_adapter/__init__.py @@ -95,7 +95,7 @@ async def create_workers(session, config, count=1, worker_manager=None): hb_interval = worker_config.get("interval", 5) hb_timeout = worker_config.get("timeout", _default_timeout) check_interval = worker_config.get("check_interval", 10) - mediamtx_addr = worker_config.get("mediamtx_addr", "rtsp://172.21.110.223:8554") + mediamtx_addr = worker_config.get("mediamtx_addr", "rtsp://127.0.0.1:8554") link_path = worker_config.get("link_path", "/data/bm-app") # 设定全局变量 @@ -138,7 +138,7 @@ async def cleanup(worker_item: str): 在 Worker 关闭时调用，关闭数据库连接和后台任务。 """ - from .global_var import db + from .global_var import db, stream_manager global _offline_check_task if _offline_check_task is not None and not _offline_check_task.done(): @@ -152,4 +152,7 @@ async def cleanup(worker_item: str): if db is not None: await db.dispose() + if stream_manager is not None: + await stream_manager.stop_all() + logger.info(f"[aibox_sophon_adapter] {worker_item} 清理完毕")