Merge pull request #227 from gen-mind/bug/milvus_userr

fix
gen-mind · Jun 13, 2024 · 6075f3a · 6075f3a
2 parents 7089488 + 21d38fc
commit 6075f3a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/src/backend/core/storage/milvus.go b/src/backend/core/storage/milvus.go
@@ -108,7 +108,9 @@ var MilvusModule = fx.Options(
 
 func NewMilvusClient(cfg *MilvusConfig) (MilvusClient, error) {
 	client, err := milvus.NewClient(context.Background(), milvus.Config{
-		Address: cfg.Address,
+		Address:  cfg.Address,
+		Username: "root",
+		Password: "sq5/6<$Y4aD`2;Gba'E#",
 	})
 	if err != nil {
 		return nil, err

diff --git a/src/backend/semantic/lib/db/milvus_db.py b/src/backend/semantic/lib/db/milvus_db.py
@@ -22,6 +22,9 @@
 milvus_index_type = os.getenv("MILVUS_INDEX_TYPE", "DISKANN")
 milvus_metric_type = os.getenv("MILVUS_METRIC_TYPE", "COSINE")
 
+milvus_user="root"
+milvus_pass="sq5/6<$Y4aD`2;Gba'E#"
+
 embedder_grpc_host = os.getenv("EMBEDDER_GRPC_HOST", "localhost")
 embedder_grpc_port = os.getenv("EMBEDDER_GRPC_PORT", "50051")
 
@@ -43,7 +46,9 @@ def delete_by_document_id_and_parent_id(self, document_id: int64, collection_nam
                 alias=milvus_alias,
                 host=milvus_host,
                 # host='milvus-standalone'
-                port=milvus_port
+                port=milvus_port,
+                user=milvus_user,
+                password=milvus_pass
             )
 
             if utility.has_collection(collection_name):