feat: milvus连接成功

This commit is contained in:
martsforever
2025-12-16 18:17:05 +08:00
parent b74bc195eb
commit e44361d0b8
2 changed files with 3 additions and 3 deletions
+1 -1
View File
@@ -12,7 +12,7 @@ PG_DB_DATABASE=langgraph_db # postgres数据库连接的数据库名
MILVUS_URI=http://49.232.230.189:7323 # milvus数据库的连接uri MILVUS_URI=http://49.232.230.189:7323 # milvus数据库的连接uri
MILVUS_USERNAME=root # milvus数据库连接用户名 MILVUS_USERNAME=root # milvus数据库连接用户名
MILVUS_PASSWORD=Fpf5XP44hGwBG3RbQk8S # milvus数据库连接用户的密码 MILVUS_PASSWORD=JyNB46F8v2XSrmuQKN6C # milvus数据库连接用户的密码
LLAMA_INDEX_DATABASE=llamaindex_db # llama-index所使用的数据名称(需要提前创建) LLAMA_INDEX_DATABASE=llamaindex_db # llama-index所使用的数据名称(需要提前创建)
LLAMA_INDEX_COLLECTION=llama_index # llama-index所使用的集合名称(不需要提前创建,会自动创建) LLAMA_INDEX_COLLECTION=llama_index # llama-index所使用的集合名称(不需要提前创建,会自动创建)
LLAMA_INDEX_DIMENSION=1024 # llama-index所使用嵌入模型的向量维度 LLAMA_INDEX_DIMENSION=1024 # llama-index所使用嵌入模型的向量维度
+2 -2
View File
@@ -19,11 +19,11 @@ def create_app():
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
print("lifespan:启动阶段") print("lifespan:启动阶段")
# await check_nltk() 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()),
) )
async_engine = async_results[0] async_engine = async_results[0]