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,