...
| Code Block |
|---|
import(collection_name="test", files={"uid": "file_1.json", "vector": "file_2.npy"}) |
...
Proxy RPC Interfaces
| Code Block |
|---|
service MilvusService {
rpc Import(ImportRequest) returns (ImportResponse) {}
rpc GetImportState(GetImportStateRequest) returns (GetImportStateResponse) {}
}
message ImportRequest {
string collection_name = 1; // target collection
string partition_name = 2; // target partition
bool rowBasedrow_based = 3; // the file is row-based or column-based
repeated string files = 4; // file paths to be imported
repeated common.KeyValuePair options = 5; // import options
}
message ImportResponse {
common.Status status = 1;
repeated int64 taskIDstasks = 2;
}
message GetImportStateRequest {
// id int64array taskIDof =import 1;tasks
}
message GetImportStateResponseGetImportStateRequest {
common.Statusint64 statustask = 1;
bool// finished = 2;
int64 rowCount = 3;
} |
...
| Code Block |
|---|
service MilvusService { rpc Import(ImportRequest) returns (ImportResponse) {}id of animport task } message ImportRequestGetImportStateResponse { common.MsgBaseStatus basestatus = 1; stringbool optionsfinished = 2; // optionsis inthis JSON format } message ImportResponse { common.Status status = 1;import task finished or not repeated schema.IDs IDsint64 row_count = 23; // auto-generated ids for succeed chunks uint32 succ_index = 3; // number of chunks that successfully imported } |
...
if the task is finished, this value is how many rows are imported. if the task is not finished, this value is how many rows are parsed.
} |
Datacoord RPC interfaces
The declaration of import API in datacoord RPC:
| Code Block |
|---|
service DataCoord {
rpc Import(milvuspbmilvus.ImportRequest) returns (milvuspbmilvus.ImportResponse) {}
rpc GetImportState(milvus.GetImportStateRequest) returns (milvus.GetImportStateResponse) {}
rpc CompleteImport(ImportResult) returns (common.Status) {}
}
message ImportResult {
common.Status status = 1;
repeated schema.IDsint64 IDssegments = 2; // id array of new // auto-generated idssealed segments
repeated int64 segmentsrow_count = 3; // how many //rows idare arrayimported ofby newthis sealed segmentstask
} |
Datanode interfaces
The declaration of import API in datanode RPC:
...