bulkImport()
Creates a bulk import job from prepared data files in Milvus or Zilliz Cloud.
public static String bulkImport(String url, BaseImportRequest request)
Request Syntax
Use this request when importing files into open-source Milvus.
MilvusImportRequest.builder()
.apiKey(apiKey)
.dbName(dbName)
.collectionName(collectionName)
.partitionName(partitionName)
.files(files)
.options(options)
.build();
PARAMETERS:
-
apiKey (String) - Milvus authentication in
username:passwordform. -
dbName (String) - Default:
defaultTarget database name. -
collectionName (String) - Target collection name.
-
partitionName (String) - Default:
defaultTarget partition name when the collection does not use a partition key. -
files (List<List<String>>) - Files or file groups stored in the bucket accessible to Milvus.
-
options (Map<String, Object>) - Additional import options passed to the server.
RETURNS:
String
A JSON response whose data.jobId identifies the created import job.
Example
Creates an import job for files accessible to Milvus.
MilvusImportRequest request = MilvusImportRequest.builder()
.collectionName("books")
.files(List.of(List.of("bulk_data/books.parquet")))
.apiKey("root:Milvus")
.build();
String response = BulkImportUtils.bulkImport("http://localhost:19530", request);