feat: 调整 nltk 的初始化时机
This commit is contained in:
+1
-1
@@ -19,12 +19,12 @@ def create_app():
|
|||||||
@asynccontextmanager
|
@asynccontextmanager
|
||||||
async def lifespan(app: FastAPI):
|
async def lifespan(app: FastAPI):
|
||||||
print("lifespan:启动阶段")
|
print("lifespan:启动阶段")
|
||||||
|
await check_nltk()
|
||||||
async_results = await asyncio.gather(
|
async_results = await asyncio.gather(
|
||||||
asyncio.create_task(check_database_connection()),
|
asyncio.create_task(check_database_connection()),
|
||||||
asyncio.create_task(check_postgres_connection()),
|
asyncio.create_task(check_postgres_connection()),
|
||||||
asyncio.create_task(milvus_service.check_milvus_connection()),
|
asyncio.create_task(milvus_service.check_milvus_connection()),
|
||||||
asyncio.create_task(redis_utils.check_redis_connection()),
|
asyncio.create_task(redis_utils.check_redis_connection()),
|
||||||
asyncio.create_task(check_nltk()),
|
|
||||||
)
|
)
|
||||||
async_engine = async_results[0]
|
async_engine = async_results[0]
|
||||||
yield
|
yield
|
||||||
|
|||||||
@@ -22,7 +22,8 @@ async_engine = AsyncEngine(create_engine(
|
|||||||
pool_size=5, # 连接池保持的连接数
|
pool_size=5, # 连接池保持的连接数
|
||||||
max_overflow=10, # 允许超过pool_size的最大连接数
|
max_overflow=10, # 允许超过pool_size的最大连接数
|
||||||
pool_timeout=30, # 获取连接的超时时间(秒)
|
pool_timeout=30, # 获取连接的超时时间(秒)
|
||||||
pool_recycle=300, # 连接回收时间(秒)
|
pool_recycle=180, # 连接回收时间(秒)
|
||||||
|
pool_pre_ping=True, # 启用连接有效性检测
|
||||||
echo=True, # 启用SQL语句日志输出,便于开发调试
|
echo=True, # 启用SQL语句日志输出,便于开发调试
|
||||||
future=True, # 启用SQLAlchemy 2.0风格的未来模式API
|
future=True, # 启用SQLAlchemy 2.0风格的未来模式API
|
||||||
))
|
))
|
||||||
|
|||||||
Reference in New Issue
Block a user