更改增量更新日志级别
This commit is contained in:
@@ -141,6 +141,9 @@ router = APIRouter()
|
||||
async def startup_event():
|
||||
"""启动时初始化增量监听任务"""
|
||||
try:
|
||||
# 屏蔽 apscheduler 的 INFO 日志
|
||||
logging.getLogger("apscheduler").setLevel(logging.WARNING)
|
||||
|
||||
# 确保 Milvus 集合已创建(若已存在则直接返回)
|
||||
try:
|
||||
create_collection()
|
||||
|
||||
@@ -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,
|
||||
|
||||
Reference in New Issue
Block a user