From 24563ee00ed5f99627c5840a546f45f9cfd6f524 Mon Sep 17 00:00:00 2001 From: HuangHai <10402852@qq.com> Date: Wed, 25 Jun 2025 17:48:31 +0800 Subject: [PATCH] 'commit' --- dsRag/Start.py | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/dsRag/Start.py b/dsRag/Start.py index 7db62625..d700c8dc 100644 --- a/dsRag/Start.py +++ b/dsRag/Start.py @@ -13,7 +13,6 @@ from Dao.KbDao import KbDao from Util.MySQLUtil import init_mysql_pool from Config import Config from fastapi.staticfiles import StaticFiles -import urllib3 # 初始化日志 logger = logging.getLogger(__name__) @@ -43,23 +42,7 @@ async def lifespan(app: FastAPI): api_key=Config.DEEPSEEK_API_KEY, base_url=Config.DEEPSEEK_URL ) - - # 启动文档处理任务 - async def document_processor(): - while True: - try: - # 获取未处理文档 - # 处理文档 - # 保存到ES - await asyncio.sleep(10) - except Exception as e: - logger.error(f"文档处理出错: {e}") - await asyncio.sleep(10) - - task = asyncio.create_task(document_processor()) yield - # 关闭时取消任务 - task.cancel() # 关闭数据库连接池 await app.state.kb_dao.mysql_pool.close()