标签：System 聚合 request sourceBuilder 查询 client new ES out

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 一休
 * @date 2021/10/19 14:52
 */
@Configuration
public class EsClientConfig {

    @Value("${es.url}")
    private String[] esUrls;
    @Value("${es.username}")
    private String esUserName;
    @Value("${es.password}")
    private String esPassword;

    @Bean
    public RestHighLevelClient restHighLevelClient() {
        // 测试
        RestClientBuilder builder = RestClient.builder(new HttpHost("192.168.202.128", 9200, "http"));
        RestClient client = builder.build();
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(client);
        return restHighLevelClient;
        //账号密码连接
       /* HttpHost[] hosts = new HttpHost[esUrls.length];
        for (int i = 0; i < esUrls.length; i++) {
            String[] strings = esUrls[i].split(":");
            hosts[i] = new HttpHost(strings[0], Integer.parseInt(strings[1]));
        }
        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(esUserName, esPassword));
        RestClientBuilder builder =
                RestClient.builder(hosts).setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                    @Override
                    public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                        return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
                    }
                });
        return new RestHighLevelClient(builder.build());*/
    }

}

去重查询

 @Resource
 private RestHighLevelClient client;

 @Test
    void contextLoads() throws Exception {
        SearchRequest request = new SearchRequest();
        request.indices("students").types("student");
        // 构建搜索条件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        //指定去重字段
        CollapseBuilder collapseBuilder = new CollapseBuilder("name.keyword");
        // 查询去重后的结果数量
        CardinalityAggregationBuilder aggregationBuilder = AggregationBuilders.cardinality("name").field("name.keyword");
        sourceBuilder.collapse(collapseBuilder);
        sourceBuilder.aggregation(aggregationBuilder);
        sourceBuilder.size(1000);
        request.source(sourceBuilder);

        SearchResponse response = client.search(request);
        System.out.println(JSON.toJSONString(response.getAggregations()));
        SearchHits hits = response.getHits();
        System.out.println(hits.getHits().length);
        System.out.println(JSON.toJSONString(hits));
        for (SearchHit hit : hits) {
            System.out.println(JSON.toJSONString(hit.getSource()));
        }

    }

聚合取值 、重点获取桶内数据

 @Test
    void contextLoads() throws Exception {
        SearchRequest request = new SearchRequest();
      // 设置索引和type
      //  request.indices("students").types("student");
        // 构建搜索条件
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
      // 分组，排序 ：key 和 hit 为自定义，第二个参数为 条件查询字段
        TermsAggregationBuilder terms = AggregationBuilders.terms("key").field("recText.keyword")
                .subAggregation(AggregationBuilders.topHits("hit").sort("statisDate.keyword", SortOrder.DESC));
        sourceBuilder.aggregation(terms);
        sourceBuilder.size(1000);
        request.source(sourceBuilder);
        SearchResponse response = client.search(request);
        Long hs = response.getHits().getTotalHits();
        System.out.println(hs);

        ParsedTerms terms1 = (ParsedTerms) response.getAggregations().getAsMap().get("key");
        List<ParsedTerms.ParsedBucket> list = (List<ParsedTerms.ParsedBucket>) terms1.getBuckets();
        for (ParsedTerms.ParsedBucket parsedBucket : list) {
            System.out.println(parsedBucket.getKeyAsString());
            ParsedTopHits topHits = parsedBucket.getAggregations().get("hit");
            SearchHit hit = topHits.getHits().getHits()[0];
            String time = hit.getSourceAsMap().get("createTime").toString();
            System.out.println(time);
            return;
        }

标签：System,聚合,request,sourceBuilder,查询,client,new,ES,out
来源： https://blog.csdn.net/weixin_43334140/article/details/121749094

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。