update blob data insert request

Signed-off-by: muzhouliu <[email protected]>
milvus-io · Feb 17, 2024 · abbe5bb · abbe5bb
1 parent 5f0d8f6
commit abbe5bb
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 5 deletions.
diff --git a/proto/milvus.proto b/proto/milvus.proto
@@ -133,6 +133,8 @@ service MilvusService {
 
   rpc CreateBlobStorage(CreateBlobStorageRequest) returns (common.Status) {}
   rpc DropBlobStorage(DropBlobStorageRequest) returns (common.Status) {}
+  rpc InsertBlobData(InsertRequest) returns (InsertBlobDataResponse) {}
+  rpc DeleteBlobData(DeleteRequest) returns (MutationResult) {}
 
   rpc ReplicateMessage(ReplicateMessageRequest) returns (ReplicateMessageResponse) {}
 }
@@ -1824,6 +1826,16 @@ message DropBlobStorageRequest {
   string storage_path = 2;
 }
 
+message InsertBlobDataResponse {
+  option (common.privilege_ext_obj) = {
+    object_type: Global
+    object_privilege: PrivilegeInsert
+    object_name_index: -1
+  };
+  common.Status status = 1;
+  schema.FieldData saved_blob_path_string = 2;
+}
+
 message ReplicateMessageRequest {
   common.MsgBase base = 1;
   string channel_name = 2;

diff --git a/proto/schema.proto b/proto/schema.proto
@@ -67,8 +67,6 @@ message FieldSchema {
   bool is_dynamic = 12; // mark whether this field is the dynamic field
   bool is_partition_key = 13; // enable logic partitions
   bool is_clustering_key = 14;
-
-  bool is_blob_saved = 15; // for blob type, mark if the blob is saved
 }
 
 /**
@@ -105,9 +103,9 @@ message ArrayArray {
 message JSONArray { repeated bytes data = 1; }
 
 message BlobFile {
-  bytes data = 1 ;
-  string file_name = 2;
-  string stored_path = 3;
+  bytes data = 1 ; //data field will be set to null after saved
+  string file_name = 2; // s3://<collection's root blob path>/<partition folder>/<file name> locates the blob file
+  string sha256 = 3;
 }
 
 message ValueField {