datasync / yoho-datasync-fullsync · Commits

Go to a project

Authored by 张帅
Commit 6fd91337bc70c5eb5346a2b16c2046774b3e544a 1 parent 339ff09a

线上es配置

Inline Side-by-side
Showing 3 changed files with 9 additions and 2 deletions
@@ -85,7 +85,7 @@ public class UserInfoDataSyncServiceImpl { @@ -85,7 +85,7 @@ public class UserInfoDataSyncServiceImpl {
85 // 批量增加 85 // 批量增加
86 BulkRequest bulkAddRequest = new BulkRequest(); 86 BulkRequest bulkAddRequest = new BulkRequest();
87 for (UserInfo info : userInfoList) { 87 for (UserInfo info : userInfoList) {
88 - IndexRequest indexRequest = new IndexRequest("user", "userInfo", String.valueOf(info.getYoho_uid())); 88 + IndexRequest indexRequest = new IndexRequest("grass", "userInfo", String.valueOf(info.getYoho_uid()));
89 indexRequest.source(JSON.toJSONString(info), XContentType.JSON); 89 indexRequest.source(JSON.toJSONString(info), XContentType.JSON);
90 bulkAddRequest.add(indexRequest); 90 bulkAddRequest.add(indexRequest);
91 } 91 }
@@ -30,5 +30,12 @@ spring: @@ -30,5 +30,12 @@ spring:
30 password: +BfhVxZQ4LuPKt+QxSy9naMwEu/zaKV31I9S8xDJIUA= 30 password: +BfhVxZQ4LuPKt+QxSy9naMwEu/zaKV31I9S8xDJIUA=
31 driver-class-name: com.mysql.jdbc.Driver 31 driver-class-name: com.mysql.jdbc.Driver
32 32
  33 +elasticSearch:
  34 + host: 10.66.107.6
  35 + port: 9200
  36 + client:
  37 + connectNum: 10
  38 + connectPerRoute: 50
  39 +
33 logging: 40 logging:
34 config: classpath:logback-boot.xml 41 config: classpath:logback-boot.xml
@@ -27,7 +27,7 @@ spring: @@ -27,7 +27,7 @@ spring:
27 driver-class-name: com.mysql.jdbc.Driver 27 driver-class-name: com.mysql.jdbc.Driver
28 28
29 yhCommunity: 29 yhCommunity:
30 - url: jdbc:mysql://192.168.102.219:3306/test?useUnicode=true&characterEncoding=UTF-8 30 + url: jdbc:mysql://192.168.102.219:3306/yh_community?useUnicode=true&characterEncoding=UTF-8
31 username: yh_test 31 username: yh_test
32 password: 9nm0icOwt6bMHjMusIfMLw== 32 password: 9nm0icOwt6bMHjMusIfMLw==
33 driver-class-name: com.mysql.jdbc.Driver 33 driver-class-name: com.mysql.jdbc.Driver