demo

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/Demo.java

@@ -2,6 +2,10 @@ package com.tzld.piaoquan.recommend.model.produce;
 
 import com.google.gson.Gson;
 import com.google.gson.JsonObject;
+import io.milvus.client.MilvusClient;
+import io.milvus.client.MilvusServiceClient;
+import io.milvus.param.ConnectParam;
+import io.milvus.param.RetryParam;
 import io.milvus.v2.client.ConnectConfig;
 import io.milvus.v2.client.MilvusClientV2;
 import io.milvus.v2.common.ConsistencyLevel;
@@ -25,6 +29,19 @@ import java.util.*;
 
 public class Demo {
     public static void main(String[] args) {
+
+
+        ConnectParam connectParamv1 = ConnectParam.newBuilder()
+                .withUri("https://in01-bf9dcd371016170.ali-cn-hangzhou.vectordb.zilliz.com.cn:19530")
+                .withToken("423a29de63a907e6662b9493c4f95caf799f64f8701cc70db930bb6da7f05914e6ed2374342dc438a8b9d37da0bf164c8ee531bd")
+                .build();
+        RetryParam retryParamv1 = RetryParam.newBuilder()
+                .withMaxRetryTimes(3)
+                .build();
+        System.out.println(connectParamv1);
+        MilvusClient milvusClientv1 = new MilvusServiceClient(connectParamv1).withRetry(retryParamv1);
+
+
         // connect to milvus
         final MilvusClientV2 milvusClientV2 = new MilvusClientV2(ConnectConfig.builder()
                 .uri("https://in01-bf9dcd371016170.ali-cn-hangzhou.vectordb.zilliz.com.cn:19530")

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/Demo2.java

@@ -41,8 +41,10 @@ public class Demo2 {
         String milvusCollection = argMap.get("milvusCollection");
         int batchSize = NumberUtils.toInt(argMap.get("batchSize"), 5000);
 
+
+
         ConnectParam connectParamv1 = ConnectParam.newBuilder()
-                .withUri(milvusUrl)
+                .withUri("https://in01-bf9dcd371016170.ali-cn-hangzhou.vectordb.zilliz.com.cn:19530")
                 .withToken(milvusToken)
                 .build();
         RetryParam retryParamv1 = RetryParam.newBuilder()