微服务Day7学习-数据聚合、同步、补全

文章目录

• 数据聚合
• • 聚合分类
  • 自动补全
  • • DSL实现Bucket聚合
    • DSL实现Metrics聚合
    • RestAPI实现聚合
    • 多条件聚合
    • 对接前端接口
    • 拼音分词器
    • 自定义分词器
    • 自动补全查询
    • 实现酒店搜索框自动补全
    • 数据同步
    • • 数据同步思路分析
      • 利用mq实现mysql与elasticsearch数据同步
      • 集群
      • • 介绍
        • 搭建ES集群

          数据聚合

          聚合分类

          自动补全

          DSL实现Bucket聚合

          DSL实现Metrics聚合

          RestAPI实现聚合

          测试类

              @Test    void testAggregation() throws IOException {        //1.准备Request        SearchRequest request = new SearchRequest("hotel");        //2.准备DSL        //2.1 设置size        request.source().size(0);        //2.2 聚合        request.source().aggregation(AggregationBuilders                .terms("brandAgg")                .field("brand")                .size(20));        //3.发出请求        SearchResponse response = client.search(request, RequestOptions.DEFAULT);        //4.解析结果        System.out.println(response);    }

              @Test    void testAggregation() throws IOException {        //1.准备Request        SearchRequest request = new SearchRequest("hotel");        //2.准备DSL        //2.1 设置size        request.source().size(0);        //2.2 聚合        request.source().aggregation(AggregationBuilders                .terms("brandAgg")                .field("brand")                .size(20));        //3.发出请求        SearchResponse response = client.search(request, RequestOptions.DEFAULT);        //4.解析结果        Aggregations aggregations = response.getAggregations();        //4.1 根据聚合名称获取聚合结果        Terms brandTerms = aggregations.get("brandAgg");        //4.2 获取buckets        List