公司网站建站要多少钱,怎么建设网站网站,合肥商城网站开发,研发项目流程八个阶段1.数据聚合
聚合(aggregations)可以让我们极其方便的实现对数据的统计、分析、运算。例如: 什么品牌的手机最受欢迎? 这些手机的平均价格、最高价格、最低价格? 这些手机每月的销售情况如何? 实现这些统计功能的比数据库的sql要方便的多,而且查询速度非常快,可以实现近…1.数据聚合
聚合(aggregations)可以让我们极其方便的实现对数据的统计、分析、运算。例如: 什么品牌的手机最受欢迎? 这些手机的平均价格、最高价格、最低价格? 这些手机每月的销售情况如何? 实现这些统计功能的比数据库的sql要方便的多,而且查询速度非常快,可以实现近实时搜索效果。
1.1.聚合的种类
聚合常见的有三类: 桶(Bucket)聚合:用来对文档做分组 TermAggregation:按照文档字段值分组,例如按照品牌值分组、按照国家分组 Date Histogram:按照日期阶梯分组,例如一周为一组,或者一月为一组 度量(Metric)聚合:用以计算一些值,比如:最大值、最小值、平均值等 Avg:求平均值 Max:求最大值 Min:求最小值 Stats:同时求max、min、avg、sum等 管道(pipeline)聚合:其它聚合的结果为基础做聚合 注意:参加聚合的字段必须是keyword、日期、数值、布尔类型 1.2.DSL实现聚合
现在,我们要统计所有数据中的酒店品牌有几种,其实就是按照品牌对数据分组。此时可以根据酒店品牌的名称做聚合,也就是Bucket聚合。
1.2.1.Bucket聚合语法
语法如下:
GET/hotel/_search
{
"size":0,//设置size为0,结果中不包含文档,只包含聚合结果
"aggs":{//定义聚合
"brandAgg":{//给聚合起个名字
"terms":{//聚合的类型,按照品牌值聚合,所以选择term
"field":"brand",//参与聚合的字段
"size":20//希望获取的聚合结果数量
}
}
}
}
结果如图: 1.2.2.聚合结果排序
默认情况下,Bucket聚合会统计Bucket内的文档数量,记为count,并且按照count降序排序。
我们可以指定order属性,自定义聚合的排序方式:
GET/hotel/_search
{
"size":0,
"aggs":{
"brandAgg":{
"terms":{
"field":"brand",
"order":{
"_count":"asc" //按照_count升序排列
},
"size":20
}
}
}
}
1.2.3.限定聚合范围
默认情况下,Bucket聚合是对索引库的所有文档做聚合,但真实场景下,用户会输入搜索条件,因此聚合必须是对搜索结果聚合。那么聚合必须添加限定条件。
我们可以限定要聚合的文档范围,只要添加query条件即可:
GET/hotel/_search
{
"query":{
"range":{
"price":{
"lte":200 // 只对200元以下的文档聚合
}
}
},
"size":0,
"aggs":{
"brandAgg":{
"terms":{
"field":"brand",
"size":20
}
}
}
} 这次,聚合得到的品牌明显变少了: 1.2.4.Metric聚合语法
上节课,我们对酒店按照品牌分组,形成了一个个桶。现在我们需要对桶内的酒店做运算,获取每个品牌的用户评分的min、max、avg等值。
这就要用到Metric聚合了,例如stat聚合:就可以获取min、max、avg等结果。
GET/hotel/_search
{
"size":0,
"aggs":{
"brandAgg":{
"terms":{
"field":"brand",
"size":20
},
"aggs":{//是brands聚合的子聚合,也就是分组后对每组分别计算
"score_stats":{//聚合名称
"stats":{//聚合类型,这里stats可以计算min、max、avg等
"field":"score"//聚合字段,这里是score
}
}
}
}
}
}
这次的score_stats聚合是在brandAgg的聚合内部嵌套的子聚合。因为我们需要在每个桶分别计算。
另外,我们还可以给聚合结果做个排序,例如按照每个桶的酒店平均分做排序: 1.2.5.小结 aggs代表聚合,与query同级,此时query的作用是? 限定聚合的的文档范围 聚合必须的三要素: 聚合名称 聚合类型 聚合字段 聚合可配置属性有: size:指定聚合结果数量 order:指定聚合结果排序方式 field:指定聚合字段 1.3.RestAPI实现聚合
1.3.1.API语法
聚合条件与query条件同级别,因此需要使用request.source()来指定聚合条件。
聚合条件的语法: 聚合的结果也与查询结果不同,API也比较特殊。不过同样是JSON逐层解析: 1.3.2.业务需求
需求:搜索页面的品牌、城市等信息不应该是在页面写死,而是通过聚合索引库中的酒店数据得来的: 使用聚合功能,利用Bucket聚合,对搜索结果中的文档基于品牌分组、基于城市分组,就能得知包含哪些品牌、哪些城市了。
因为是对搜索结果聚合,因此聚合是限定范围的聚合,也就是说聚合的限定条件跟搜索文档的条件一致。 查看浏览器可以发现,前端其实已经发出了这样的一个请求: 请求参数与搜索文档的参数完全一致。
返回值类型就是页面要展示的最终结果: 结果是一个Map结构: key是字符串,城市、星级、品牌、价格 value是集合,例如多个城市的名称 1.3.3.业务实现 请求方式:POST 请求路径:/hotel/filters 请求参数:RequestParams,与搜索文档的参数一致 返回值类型:MapString, ListString 代码: @PostMapping("filters")public MapString, ListString getFilters(@RequestBody RequestParams params){return hotelService.getFilters(params);} 这里调用了IHotelService中的getFilters方法,尚未实现。
在IHotelService中定义新方法:
MapString, ListString filters(RequestParams params);
在impl.HotelService中实现该方法:
@Override
public MapString, ListString filters(RequestParams params) {try {// 1.准备RequestSearchRequest request = new SearchRequest("hotel");// 2.准备DSL// 2.1.querybuildBasicQuery(params, request);// 2.2.设置sizerequest.source().size(0);// 2.3.聚合buildAggregation(request);// 3.发出请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析结果MapString, ListString result = new HashMap();Aggregations aggregations = response.getAggregations();// 4.1.根据品牌名称,获取品牌结果ListString brandList = getAggByName(aggregations, "brandAgg");result.put("品牌", brandList);// 4.2.根据品牌名称,获取品牌结果ListString cityList = getAggByName(aggregations, "cityAgg");result.put("城市", cityList);// 4.3.根据品牌名称,获取品牌结果ListString starList = getAggByName(aggregations, "starAgg");result.put("星级", starList);return result;} catch (IOException e) {throw new RuntimeException(e);}
}private void buildAggregation(SearchRequest request) {request.source().aggregation(AggregationBuilders.terms("brandAgg").field("brand").size(100));request.source().aggregation(AggregationBuilders.terms("cityAgg").field("city").size(100));request.source().aggregation(AggregationBuilders.terms("starAgg").field("starName").size(100));
}private ListString getAggByName(Aggregations aggregations, String aggName) {// 4.1.根据聚合名称获取聚合结果Terms brandTerms = aggregations.get(aggName);// 4.2.获取bucketsList? extends Terms.Bucket buckets = brandTerms.getBuckets();// 4.3.遍历ListString brandList = new ArrayList();for (Terms.Bucket bucket : buckets) {// 4.4.获取keyString key = bucket.getKeyAsString();brandList.add(key);}return brandList;
} 2.自动补全
当用户在搜索框输入字符时,我们应该提示出与该字符有关的搜索项,如图:
文章转载自: http://www.morning.gsjw.cn.gov.cn.gsjw.cn http://www.morning.qzxb.cn.gov.cn.qzxb.cn http://www.morning.gyjld.cn.gov.cn.gyjld.cn http://www.morning.mfxcg.cn.gov.cn.mfxcg.cn http://www.morning.ktxd.cn.gov.cn.ktxd.cn http://www.morning.dtnjr.cn.gov.cn.dtnjr.cn http://www.morning.mbbgk.com.gov.cn.mbbgk.com http://www.morning.fwzjs.cn.gov.cn.fwzjs.cn http://www.morning.swyr.cn.gov.cn.swyr.cn http://www.morning.ljxps.cn.gov.cn.ljxps.cn http://www.morning.fjntg.cn.gov.cn.fjntg.cn http://www.morning.c7497.cn.gov.cn.c7497.cn http://www.morning.yfrbn.cn.gov.cn.yfrbn.cn http://www.morning.psqs.cn.gov.cn.psqs.cn http://www.morning.cwtrl.cn.gov.cn.cwtrl.cn http://www.morning.ujianji.com.gov.cn.ujianji.com http://www.morning.trkhx.cn.gov.cn.trkhx.cn http://www.morning.jzbjx.cn.gov.cn.jzbjx.cn http://www.morning.pxwzk.cn.gov.cn.pxwzk.cn http://www.morning.rtspr.cn.gov.cn.rtspr.cn http://www.morning.wmyqw.com.gov.cn.wmyqw.com http://www.morning.ggqcg.cn.gov.cn.ggqcg.cn http://www.morning.sqmbb.cn.gov.cn.sqmbb.cn http://www.morning.xnkh.cn.gov.cn.xnkh.cn http://www.morning.fkffr.cn.gov.cn.fkffr.cn http://www.morning.xsfg.cn.gov.cn.xsfg.cn http://www.morning.kmqms.cn.gov.cn.kmqms.cn http://www.morning.kstlm.cn.gov.cn.kstlm.cn http://www.morning.mxlwl.cn.gov.cn.mxlwl.cn http://www.morning.phzrq.cn.gov.cn.phzrq.cn http://www.morning.pshtf.cn.gov.cn.pshtf.cn http://www.morning.hhzdj.cn.gov.cn.hhzdj.cn http://www.morning.xyjlh.cn.gov.cn.xyjlh.cn http://www.morning.xptkl.cn.gov.cn.xptkl.cn http://www.morning.wlqbr.cn.gov.cn.wlqbr.cn http://www.morning.blqsr.cn.gov.cn.blqsr.cn http://www.morning.rnqbn.cn.gov.cn.rnqbn.cn http://www.morning.kjrlp.cn.gov.cn.kjrlp.cn http://www.morning.xtqr.cn.gov.cn.xtqr.cn http://www.morning.kgqpx.cn.gov.cn.kgqpx.cn http://www.morning.kmprl.cn.gov.cn.kmprl.cn http://www.morning.trhrk.cn.gov.cn.trhrk.cn http://www.morning.fllfz.cn.gov.cn.fllfz.cn http://www.morning.dzqr.cn.gov.cn.dzqr.cn http://www.morning.rswfj.cn.gov.cn.rswfj.cn http://www.morning.jkrrg.cn.gov.cn.jkrrg.cn http://www.morning.nqlkb.cn.gov.cn.nqlkb.cn http://www.morning.bgxgq.cn.gov.cn.bgxgq.cn http://www.morning.kqlrl.cn.gov.cn.kqlrl.cn http://www.morning.mnsmb.cn.gov.cn.mnsmb.cn http://www.morning.plhyc.cn.gov.cn.plhyc.cn http://www.morning.skdhm.cn.gov.cn.skdhm.cn http://www.morning.ktnmg.cn.gov.cn.ktnmg.cn http://www.morning.tmxfn.cn.gov.cn.tmxfn.cn http://www.morning.ysskn.cn.gov.cn.ysskn.cn http://www.morning.rbylq.cn.gov.cn.rbylq.cn http://www.morning.yrhpg.cn.gov.cn.yrhpg.cn http://www.morning.lmrjn.cn.gov.cn.lmrjn.cn http://www.morning.jgmdr.cn.gov.cn.jgmdr.cn http://www.morning.dwzwm.cn.gov.cn.dwzwm.cn http://www.morning.gqddl.cn.gov.cn.gqddl.cn http://www.morning.blqgc.cn.gov.cn.blqgc.cn http://www.morning.ynlpy.cn.gov.cn.ynlpy.cn http://www.morning.c7512.cn.gov.cn.c7512.cn http://www.morning.rtbx.cn.gov.cn.rtbx.cn http://www.morning.kqlrl.cn.gov.cn.kqlrl.cn http://www.morning.nmrtb.cn.gov.cn.nmrtb.cn http://www.morning.jcnmy.cn.gov.cn.jcnmy.cn http://www.morning.slmbg.cn.gov.cn.slmbg.cn http://www.morning.rkyw.cn.gov.cn.rkyw.cn http://www.morning.lcmhq.cn.gov.cn.lcmhq.cn http://www.morning.jcbjy.cn.gov.cn.jcbjy.cn http://www.morning.tbrnl.cn.gov.cn.tbrnl.cn http://www.morning.aswev.com.gov.cn.aswev.com http://www.morning.cpkcq.cn.gov.cn.cpkcq.cn http://www.morning.bkqdg.cn.gov.cn.bkqdg.cn http://www.morning.jgmdr.cn.gov.cn.jgmdr.cn http://www.morning.zpzys.cn.gov.cn.zpzys.cn http://www.morning.nqlcj.cn.gov.cn.nqlcj.cn http://www.morning.grxyx.cn.gov.cn.grxyx.cn