es嵌套聚合dsl（求均值，求和）

【1】根据客户号分组后求均值和求和

// dsl
{"_source":["RCRD_ID", "STATE", "BUSI_CODE"], "query":{"bool":{"filter":[{"term":{"STATE":"PDOS"}               }]}                 }, "aggs": {"by_loans":{"nested":{"path":"LOANS"}, "aggs":{"group_by_cust_num":{"terms":{"field":"LOANS.CUST_NUM"} , "aggs":{"by_avg_loan_bal_sum":{"avg":{"field":"LOANS.OVD_MONEY_SUM"}   }, "by_sum_loan_bal_sum":{"sum":{"field":"LOANS.OVD_MONEY_SUM"}   }}                          }}}}
}
// 结果
{"took": 8,"timed_out": false,"_shards": {"total": 1,"successful": 1,"skipped": 0,"failed": 0},"hits": {"total": {"value": 3,"relation": "eq"},"max_score": 0.0,"hits": [{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_01","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_01","STATE": "PDOS","BUSI_CODE": "pdi"}},{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_02","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_02","STATE": "PDOS","BUSI_CODE": "pdi"}},{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_03","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_03","STATE": "PDOS","BUSI_CODE": "pdi"}}]},"aggregations": {"by_loans": {"doc_count": 6,"group_by_cust_num": {"doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [{"key": "CUST_NUM_01","doc_count": 2,"by_sum_loan_bal_sum": {"value": 3333.0},"by_avg_loan_bal_sum": {"value": 1666.5}},{"key": "CUST_NUM_02","doc_count": 2,"by_sum_loan_bal_sum": {"value": 2227.0},"by_avg_loan_bal_sum": {"value": 1113.5}},{"key": "CUST_NUM_03","doc_count": 2,"by_sum_loan_bal_sum": {"value": 2231.0},"by_avg_loan_bal_sum": {"value": 1115.5}}]}}}
}

【2】求整个索引的均值和总和

// dsl
{"_source":["RCRD_ID", "STATE", "BUSI_CODE"], "query":{"bool":{"filter":[{"term":{"STATE":"PDOS"}               }]}                 }, "aggs": {"by_loans":{"nested":{"path":"LOANS"}, "aggs":{"by_avg_loan_bal_sum":{"avg":{"field":"LOANS.OVD_MONEY_SUM"}   }, "by_sum_loan_bal_sum":{"sum":{"field":"LOANS.OVD_MONEY_SUM"}   }}}}
}
// 结果
{"took": 12,"timed_out": false,"_shards": {"total": 1,"successful": 1,"skipped": 0,"failed": 0},"hits": {"total": {"value": 3,"relation": "eq"},"max_score": 0.0,"hits": [{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_01","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_01","STATE": "PDOS","BUSI_CODE": "pdi"}},{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_02","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_02","STATE": "PDOS","BUSI_CODE": "pdi"}},{"_index": "pdi_cust","_type": "_doc","_id": "tr_rd_03","_score": 0.0,"_source": {"RCRD_ID": "tr_rd_03","STATE": "PDOS","BUSI_CODE": "pdi"}}]},"aggregations": {"by_loans": {"doc_count": 6,"by_sum_loan_bal_sum": {"value": 7791.0},"by_avg_loan_bal_sum": {"value": 1298.5}}}
}

es嵌套聚合dsl（求均值，求和）相关推荐

es 时间字段聚合_ES按时间聚合、嵌套聚合
// POST index name/document name/_search格式 POST xxx-*/doc/_search { "query": { "bool& ...
Python 列表list 分段求和求均值（个人笔记）
Python 列表List 分段求和求均值(个人笔记) 文章目录 Python 列表List 分段求和求均值(个人笔记) 前言思路代码总结参考前言我要处理一个有 2046个元素的数 ...
Es Bucket聚合(桶聚合) 第一篇(常用桶聚合一览)
本篇将开始介绍Elasticsearch Bucket聚合(桶聚合). Buket Aggregations(桶聚合)不像metrics Aggregations(度量聚合)那样计算字段上的度量,而是 ...
R语言使用reshape2包的dcast函数将dataframe从长表到宽表（Long- to wide-format）、指定单个标识符、、表格转化的时候值不唯一设置聚合函数（均值）
R语言使用reshape2包的dcast函数将dataframe从长表到宽表(Long- to wide-format).指定单个标识符..表格转化的时候值不唯一设置聚合函数(均值) 目录
pandas使用groupby函数、agg函数获取每个分组聚合对应的均值（mean）实战：计算分组聚合单数据列的均值、计算分组聚合多数据列的均值
pandas使用groupby函数.agg函数获取每个分组聚合对应的均值(mean)实战:计算分组聚合单数据列的均值.计算分组聚合多数据列的均值目录
Numpy求均值、中位数、众数的方法
首先需要数据源,这里随便写了一个: nums = [1,2,3,4] 求均值和中位数均可以使用numpy库的方法: import numpy as np#均值 np.mean(nums) #中位数 n ...
python中列表数据汇总和平均值_python的列表List求均值和中位数实例
这篇文章主要介绍了python的列表List求均值和中位数实例,具有很好对参考价值,希望对大家有所帮助.一起跟随小编过来看看吧我就废话不多说了,直接上代码吧! import numpy as np ...
C++ vector求均值和方差
1 定义 (1)均值 (2)方差 (3)标准差 2 代码实现 //std::vector< double> 或者 std::vector< int> 类型变量求均值和方差 #i ...
R语言去掉NA求均值
数据里面有很多NA,去掉NA再对每列求均值怎么求呢? 这里用到的是dyplr包 a <- data.frame(a = c(1,2,NA,3),b = c(1,3,4,5),d=c(NA,1,2 ...

es嵌套聚合dsl（求均值，求和）

es嵌套聚合dsl（求均值，求和）相关推荐

最新文章

热门文章