Переглянути джерело

bulk_import add apiKey note (#1608)

Signed-off-by: lentitude2tk <xushuang.hu@zilliz.com>
xushuang.hu 2 тижнів тому
батько
коміт
cedb703733

+ 5 - 1
examples/src/main/java/io/milvus/v1/BulkWriterExample.java

@@ -499,6 +499,7 @@ public class BulkWriterExample {
                 .collectionName(ALL_TYPES_COLLECTION_NAME)
                 .partitionName("")
                 .files(batchFiles)
+                .apiKey(USER_NAME + ":" + PASSWORD)
                 .build();
         String bulkImportResult = BulkImportUtils.bulkImport(url, milvusImportRequest);
         System.out.println(bulkImportResult);
@@ -508,7 +509,9 @@ public class BulkWriterExample {
         System.out.println("Create a bulkInert task, job id: " + jobId);
 
         System.out.println("\n===================== listBulkInsertJobs() ====================");
-        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME).build();
+        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME)
+                .apiKey(USER_NAME + ":" + PASSWORD)
+                .build();
         String listImportJobsResult = BulkImportUtils.listImportJobs(url, listImportJobsRequest);
         System.out.println(listImportJobsResult);
         while (true) {
@@ -518,6 +521,7 @@ public class BulkWriterExample {
             System.out.println("\n===================== getBulkInsertState() ====================");
             MilvusDescribeImportRequest request = MilvusDescribeImportRequest.builder()
                     .jobId(jobId)
+                    .apiKey(USER_NAME + ":" + PASSWORD)
                     .build();
             String getImportProgressResult = BulkImportUtils.getImportProgress(url, request);
             System.out.println(getImportProgressResult);

+ 5 - 1
examples/src/main/java/io/milvus/v2/bulkwriter/BulkWriterRemoteExample.java

@@ -442,6 +442,7 @@ public class BulkWriterRemoteExample {
         MilvusImportRequest milvusImportRequest = MilvusImportRequest.builder()
                 .collectionName(ALL_TYPES_COLLECTION_NAME)
                 .files(batchFiles)
+                .apiKey(USER_NAME + ":" + PASSWORD)
                 .options(options)
                 .build();
         String bulkImportResult = BulkImportUtils.bulkImport(url, milvusImportRequest);
@@ -452,7 +453,9 @@ public class BulkWriterRemoteExample {
         System.out.println("Create a bulkInert task, job id: " + jobId);
 
         System.out.println("\n===================== listBulkInsertJobs() ====================");
-        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME).build();
+        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME)
+                .apiKey(USER_NAME + ":" + PASSWORD)
+                .build();
         String listImportJobsResult = BulkImportUtils.listImportJobs(url, listImportJobsRequest);
         System.out.println(listImportJobsResult);
         while (true) {
@@ -462,6 +465,7 @@ public class BulkWriterRemoteExample {
             System.out.println("\n===================== getBulkInsertState() ====================");
             MilvusDescribeImportRequest request = MilvusDescribeImportRequest.builder()
                     .jobId(jobId)
+                    .apiKey(USER_NAME + ":" + PASSWORD)
                     .build();
             String getImportProgressResult = BulkImportUtils.getImportProgress(url, request);
             System.out.println(getImportProgressResult);

+ 2 - 1
sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java

@@ -33,7 +33,8 @@ import java.io.Serializable;
 public class BaseDescribeImportRequest implements Serializable {
     private static final long serialVersionUID = -787626534606813089L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 }

+ 2 - 1
sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java

@@ -34,7 +34,8 @@ import java.util.Map;
 public class BaseImportRequest implements Serializable {
     private static final long serialVersionUID = 8192049841043084620L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 

+ 2 - 1
sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java

@@ -34,7 +34,8 @@ import java.io.Serializable;
 public class BaseListImportJobsRequest implements Serializable {
     private static final long serialVersionUID = -1890380396466908530L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 }