Elasticsearch 脚本式指标聚合

在Elasticsearch中，可以使用脚本（Script）来进行复杂的度量计算。以下是一个使用脚本进行指标聚合的例子：

假设我们有一个sales索引，包含price和quantity字段，我们想要计算每个商品的总销售额。

POST /sales/_search
{
  "size": 0,
  "aggs": {
    "sales_per_product": {
      "terms": {
        "field": "product_id"
      },
      "aggs": {
        "total_sales": {
          "scripted_metric": {
            "init_script": "state.total = 0",
            "map_script": "state.total += doc['price'].value * doc['quantity'].value",
            "combine_script": "return state.total"
          }
        }
      }
    }
  }
}

在这个查询中，我们使用了scripted_metric聚合，它包含了三个脚本：

• init_script：初始化脚本，在每个桶（bucket）开始时执行，设置状态变量state.total为0。
• map_script：映射脚本，对每个文档执行，计算销售额并累加到state.total。
• combine_script：合并脚本，在所有文档映射之后，将每个桶（bucket）的状态合并为最终的销售额。

这个查询将返回每个商品的ID和总销售额。