aggregation分類

aggregations —— 聚合，提供了一種基于查詢條件來對數(shù)據(jù)進行分桶、計算的方法。有點類似于 SQL 中的 group by 再加一些函數(shù)方法的操作。

聚合可以嵌套，由此可以組成復(fù)雜的操作（Bucketing聚合可以包含sub-aggregation）。

聚合整體上可以分為 3 類：

1. Bucketing：桶分聚合：

• 此類聚合執(zhí)行的是對文檔分組的操作，把滿足相關(guān)特性的文檔分到一個桶里，即桶分。輸出結(jié)果往往是一個個包含多個文檔的桶。
• 此類聚合會有一個關(guān)鍵字（field、script），以及一些桶分（分組）的判斷條件。執(zhí)行聚合操作時候，文檔會判斷每一個分組條件，如果滿足某個，該文檔就會被分為該組（fall in）。

2. Metric：指標聚合：

• 此類聚合是對文檔進行一些權(quán)值計算（比如求所有文檔某個字段的max值）。輸出結(jié)果往往是文檔的權(quán)值，相當于為文檔添加了一些統(tǒng)計信息。
• 此類聚合基于特定字段（field）或腳本值（generated using scripts），計算聚合中文檔的權(quán)值。

3. Pipeline：管道聚合：

• 對其它聚合操作的輸出及其關(guān)聯(lián)指標進行聚合。
• 此類聚合的作用對象往往是桶，而不是文檔，是一種后期對每個分桶的一些計算操作。

應(yīng)用場景

對于 3 中聚合，常見的應(yīng)用場景如下流程：

buckets 聚合對文檔進行必要的歸類（桶分） ——> metric 聚合對每個桶進行一些額外的信息計算（如：max） ——> pipeline 聚合針對所有桶做一些桶層面的統(tǒng)計或計算

應(yīng)用示例：

{"aggs" : {"sales_per_month" : {"date_histogram" : { // bucket 聚合，按照月份進行分桶，每個月的歸屬一個桶"field" : "date","interval" : "month"},"aggs": {"sales": {"sum": { // metric 聚合，對每個桶類的 price 求和，即每月的銷售額"field": "price"}}}},"max_monthly_sales": {"max_bucket": { // pipeline 聚合，求所有桶中銷售額 sales 最大的值"buckets_path": "sales_per_month>sales" }}} }

?

aggregation結(jié)構(gòu)

聚合可以是父子（嵌套）關(guān)系聚合，buckets 聚合作為父，metric 聚合作為子。

聚合也可以是兄弟關(guān)系聚合，buckets 聚合在前，pipeline 聚合在后。

結(jié)構(gòu)如下：

"aggregations" : { //定義聚合對象,也可用 "aggs""<aggregation_name>" : { //聚合的名稱,用戶自定義"<aggregation_type>" : { //聚合類型,比如 "histogram"<aggregation_body> //每個聚合類型都有其自己的結(jié)構(gòu)定義 }[,"meta" : { [<meta_data_body>] } ]?[,"aggregations" : { [<sub_aggregation>]+ } ]? //可以定義多個 sub-aggregation }[,"<aggregation_name_2>" : { ... } ]* //定義額外的多個平級 aggregation,只有 Bucketing 類型才有意義 }

?

轉(zhuǎn)載于:https://www.cnblogs.com/licongyu/p/5499388.html

總結(jié)

以上是生活随笔為你收集整理的aggregations 详解1（概述）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。