feat: 更改milvus相关环境变量名称
This commit is contained in:
@@ -38,8 +38,8 @@ class MilvusService:
|
|||||||
|
|
||||||
# 检查Milvus连接是否正常
|
# 检查Milvus连接是否正常
|
||||||
async def check_milvus_connection(self):
|
async def check_milvus_connection(self):
|
||||||
retrieve_result = await self.async_search("hello")
|
await self.async_search("hello")
|
||||||
print("✅ Milvus connection successful:", f"{env.milvus_uri}:{env.milvus_database}/{env.milvus_collection}", f"[{retrieve_result}]")
|
print("✅ Milvus connection successful:", f"Milvus://{env.milvus_username}:{env.milvus_password}@{env.milvus_uri}/{env.llama_index_database}/{env.llama_index_collection}")
|
||||||
|
|
||||||
async def async_create_index_from_documents(self, documents: List[Document]) -> VectorStoreIndex:
|
async def async_create_index_from_documents(self, documents: List[Document]) -> VectorStoreIndex:
|
||||||
vector_store = await self.get_vector_store()
|
vector_store = await self.get_vector_store()
|
||||||
|
|||||||
Reference in New Issue
Block a user