重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
目录ElasticSearch版本:7.6.2
公司主营业务:成都做网站、网站制作、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联公司推出和县免费做网站回馈大家。
Springboot版本:2.3.12.RELEASE
springboot、es版本对应关系
Elasticsearch Clients列表
Java High Level REST Client参考文档
org.springframework.boot spring-boot-starter-parent 2.3.12.RELEASE org.springframework.data spring-data-elasticsearch
实例化RestHighLevelClient@Configuration
public class ElasticSearchConfig {@Bean
public RestHighLevelClient restHighLevelClient() {return new RestHighLevelClient(
RestClient.builder(
new HttpHost("127.0.0.1", 9200, "http")));
}
}
查询
多条件分组查询并对结果排序@Test
public void testSearchGroupby() throws Exception{SearchRequest searchRequest = new SearchRequest("trafficlight_error_log");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
boolQueryBuilder.must(QueryBuilders.rangeQuery("errorTime").gte("1673403774000").lte("1673414574000"));
searchSourceBuilder.query(boolQueryBuilder);
// 分组排序,size:分组之后前N条数据,sort:.key:按key排序;.count:按count结果排序
TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders.terms("aIntersectionId_count").field(
"aIntersectionId").size(1000).order(BucketOrder.key(true));
TermsAggregationBuilder termsAggregationBuilder2 = AggregationBuilders.terms("errorMsg_count").field(
"errorMsg.keyword").order(BucketOrder.count(true));
// 多条件分组查询
termsAggregationBuilder.subAggregation(termsAggregationBuilder2);
searchSourceBuilder.aggregation(termsAggregationBuilder);
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
// System.out.println(searchResponse.getAggregations().asMap().get("aIntersectionId_count").getClass().getSimpleName());
ParsedLongTerms aIntersectionId_count = (ParsedLongTerms) searchResponse.getAggregations().asMap().get("aIntersectionId_count");
Iterator extends Terms.Bucket>iterator = aIntersectionId_count.getBuckets().iterator();
// 遍历
while (iterator.hasNext()) {Terms.Bucket next = iterator.next();
System.out.println(next.getKey());
System.out.println(next.getDocCount());
// System.out.println(next.getAggregations().asMap().get("errorMsg_count").getClass().getSimpleName());
ParsedStringTerms terms = (ParsedStringTerms) next.getAggregations().asMap().get("errorMsg_count");
Iterator extends Terms.Bucket>iterator1 = terms.getBuckets().iterator();
while (iterator1.hasNext()) {Terms.Bucket next1 = iterator1.next();
System.out.println(next1.getKey());
System.out.println(next1.getDocCount());
}
System.out.println("+++++++++++++++++++++");
}
}
你是否还在寻找稳定的海外服务器提供商?创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源,准确流量调度确保服务器高可用性,企业级服务器适合批量采购,新人活动首月15元起,快前往官网查看详情吧