From b90688f835081441f8bf5526279304947fbef01c Mon Sep 17 00:00:00 2001 From: litianxiang Date: Tue, 13 Jan 2026 13:57:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=94=B9=E5=A2=9E=E9=87=8F=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/api/api_recommendation.py | 3 +++ app/service/recommendation_system/incremental_listener.py | 4 ++++ 2 files changed, 7 insertions(+) diff --git a/app/api/api_recommendation.py b/app/api/api_recommendation.py index 24ab52c..ac1e9ec 100644 --- a/app/api/api_recommendation.py +++ b/app/api/api_recommendation.py @@ -141,6 +141,9 @@ router = APIRouter() async def startup_event(): """启动时初始化增量监听任务""" try: + # 屏蔽 apscheduler 的 INFO 日志 + logging.getLogger("apscheduler").setLevel(logging.WARNING) + # 确保 Milvus 集合已创建（若已存在则直接返回） try: create_collection() diff --git a/app/service/recommendation_system/incremental_listener.py b/app/service/recommendation_system/incremental_listener.py index bc662ee..5e554eb 100644 --- a/app/service/recommendation_system/incremental_listener.py +++ b/app/service/recommendation_system/incremental_listener.py @@ -308,6 +308,10 @@ class IncrementalListener: def start_background_listener(scheduler: BackgroundScheduler): """将增量监听任务注册到后台调度器""" + # 降低 apscheduler 的日志级别，避免大量刷屏 + logging.getLogger('apscheduler.executors.default').setLevel(logging.WARNING) + logging.getLogger('apscheduler.scheduler').setLevel(logging.WARNING) + listener = IncrementalListener() scheduler.add_job( listener.process_once,