作者： CheungQ

再续一下前面两篇相关的内容，ElasticSearch 分页查询方法from&size，scroll，及search_after浅析，es聚合导出（不是），Map#merge方法使用

在开发那个聚合导出功能的时候，最先考虑到的其实不是scroll扫数据并内存计算，之前了解过ElasticSeach是可以支持聚合计算查询的，但是没有实际在大批量数据的索引中使用过，所以再开发功能的设计阶段进行了测试之后发现并不能满足我们功能开发的需求，遂放弃了。网上使用aggs进行ElasticSearch聚合查询的介绍文章也很多，于是写下本文做一点记录，和给别人提供一点掉坑提醒

官方文档地址：https://www.elastic.co/guide/cn/elasticsearch/guide/current/aggregations.html

详尽的使用方式你也可以再这里面找到

下面是坑记录

• 字段类型选择

因为开发不规范、对ElasticSearch不了解等原因，原本功能开发的时候建的ES索引中对应订单价格、运费等字段的字段类型全部都是keyword类型的。而这次要做聚合统计的话，要对价格字段进行聚合统计执行类似如下语句的时候

GET /your_es_index/your_es_type/_search
{
  "size":0,
  "aggs":{
    "sum_claims":{
      "sum":{
        "field":"cost_of_claims"
      }
    }
  }
}

会得到一个这样的错误信息

Expected numeric type on field [cost_of_claims], but got [keyword]"}

基本意思就是cost_of_claims字段类型为keyword，但是进行聚合统计运算的时候期望cost_of_claims字段为numeric型的。也就是说明ES的聚合统计运算只能作用于numeric型字段上。那么遇到问题解决问题，接下来就是想要尝试将cost_of_claims变更为numeric型字段这件事上。

在进行avg和sum等Metrics Aggregations(度量聚合)的时候报错的，进行数学维度的计算，期望得到一个数字字段，但是得到的是一个String的keyword类型，若把cost_of_claims.keyword换成cost_of_claims，则又会报另一个错误。则需要在index数据之前进行mapping配置，将该字段的值定义为numeric，或者开启mapping的Numeric detection(数字探测)

但是这时候遇到个问题，在es中，是不支持更改现有字段的映射或字段类型的，如果我们非得需要更改字段的类型，怎么办，数据迁移，重建索引，建立我们想要的正确的映射规则。接下来新建一个相同结构的索引，对应字段修改为numeric的类型，然后把老索引的数据reindex过来。同时，reindex之后把老索引删除，并给新索引添加一个别名和老索引的名字一样，这样就可以完整切换过来，且不用修改现有业务代码中和老索引相关的内容。

异常信息:java.io.IOException: listener timeout after waiting for [60000] ms

异常堆栈:

java.io.IOException: listener timeout after waiting for [60000] ms
	at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:660)
	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:219)
	at org.elasticsearch.client.RestClient.performRequest(RestClient.java:191)
	at com.suning.maoning.core.es.EsClientHolder.performRequest(EsClientHolder.java:113)
	at com.suning.maoning.core.es.EsClientHolder.performRequest(EsClientHolder.java:127)
	at com.suning.maoning.core.es.EsClient.searchAfter(EsClient.java:343)
	at com.suning.maoning.mnbi.service.impl.commissionexport.XXXXXXXXXXXService.queryData(BaseCommissionEsExcelExportService.java:76)
	at com.suning.maoning.excel.common.export.service.impl.EsScrollRunnable.async(EsScrollRunnable.java:39)
	at com.suning.maoning.excel.common.export.service.impl.EsScrollRunnable$$FastClassBySpringCGLIB$$1736c315.invoke(<generated>)
	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:721)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
	at com.suning.maoning.core.cache.interceptor.RedisInterceptor.invoke(RedisInterceptor.java:119)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)
	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
	at org.springframework.aop.interceptor.AsyncExecutionInterceptor$1.call(AsyncExecutionInterceptor.java:115)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

根据异常堆栈指示的信息，找到对应发生异常的业务类，定位到相关具体语句，是一个ES查询调用的地方，调用方法为

esClient.searchAfter

继续跟踪对应方法