【Elasticsearch】nested聚合

在 Elasticsearch 中，嵌套聚合（`nested`aggregation）的语法形式用于对嵌套字段（`nested`fields）进行聚合操作。嵌套字段是 Elasticsearch 中的一种特殊字段类型，用于存储数组中的对象，这些对象需要独立于其父文档进行索引和查询。

以下是嵌套聚合的基本语法形式及其组成部分的详细说明：

基本语法

```json

{

  "aggs": {

    "<nested_aggregation_name>": {

      "nested": {

        "path": "<nested_field_path>"

      },

      "aggs": {

        "<sub_aggregation_name>": {

          "<sub_aggregation_type>": {

            "<sub_aggregation_body>"

          }

        }

      }

    }

  }

}

```

组成部分

1. `<nested_aggregation_name>`：

• 这是嵌套聚合的名称，由用户自定义，用于在查询结果中标识该聚合。

2. `nested`：

• 这是嵌套聚合的类型标识符，表明这是一个嵌套聚合。

3. `path`：

• 指定嵌套字段的路径。嵌套字段路径是从根文档到嵌套字段的完整路径。例如，如果嵌套字段是`resellers`，则路径为`"resellers"`。

4. `aggs`：

• 在嵌套聚合中，可以定义一个或多个子聚合。子聚合可以是任何类型的聚合（如`min`、`max`、`avg`、`terms`等），用于对嵌套文档进行进一步的分析。

5. `<sub_aggregation_name>`：

• 子聚合的名称，由用户自定义，用于在查询结果中标识该子聚合。

6. `<sub_aggregation_type>`：

• 子聚合的类型，例如`min`、`max`、`avg`、`terms`等。

7. `<sub_aggregation_body>`：

• 子聚合的具体定义，包含子聚合的字段和其他参数。

示例

以下是一个具体的嵌套聚合示例，假设我们有一个产品索引`products`，其中包含一个嵌套字段`resellers`，每个`reseller`有`reseller`（经销商名称）和`price`（价格）两个字段。

创建索引和映射

```json

PUT /products

{

  "mappings": {

    "properties": {

      "resellers": {

        "type": "nested",

        "properties": {

          "reseller": {

            "type": "keyword"

          },

          "price": {

            "type": "double"

          }

        }

      }

    }

  }

}

```

添加文档

```json

PUT /products/_doc/0?refresh

{

  "name": "LED TV",

  "resellers": [

    {

      "reseller": "companyA",

      "price": 350

    },

    {

      "reseller": "companyB",

      "price": 500

    }

  ]

}

```

嵌套聚合查询

1. 查询所有经销商的最低价格：

```json

GET /products/_search?size=0

{

  "aggs": {

    "resellers_agg": {

      "nested": {

        "path": "resellers"

      },

      "aggs": {

        "min_price": {

          "min": {

            "field": "resellers.price"

          }

        }

      }

    }

  }

}

```

• `resellers_agg`：嵌套聚合的名称。

• `nested`：指定这是一个嵌套聚合。

• `path`：指定嵌套字段的路径为`resellers`。

• `min_price`：子聚合的名称。

• `min`：子聚合的类型，用于计算最小值。

• `field`：指定聚合操作的字段为`resellers.price`。

2. 查询特定经销商的最低价格：

```json

GET /products/_search?size=0

{

  "aggs": {

    "resellers_agg": {

      "nested": {

        "path": "resellers"

      },

      "aggs": {

        "filter_reseller": {

          "filter": {

            "bool": {

              "filter": [

                {

                  "term": {

                    "resellers.reseller": "companyB"

                  }

                }

              ]

            }

          },

          "aggs": {

            "min_price": {

              "min": {

                "field": "resellers.price"

              }

            }

          }

        }

      }

    }

  }

}

```

• `filter_reseller`：过滤子聚合的名称。

• `filter`：过滤条件，用于筛选出`resellers.reseller`为`companyB`的文档。

• `term`：过滤条件的类型，用于匹配特定的值。

响应示例

1. 查询所有经销商的最低价格：

```json

{

  "aggregations": {

    "resellers_agg": {

      "doc_count": 2,

      "min_price": {

        "value": 350.0

      }

    }

  }

}

```

2. 查询特定经销商的最低价格：

```json

{

  "aggregations": {

    "resellers_agg": {

      "doc_count": 2,

      "filter_reseller": {

        "doc_count": 1,

        "min_price": {

          "value": 500.0

        }

      }

    }

  }

}

```

总结

嵌套聚合的语法形式包括以下关键部分：

• `nested`：指定这是一个嵌套聚合。

• `path`：指定嵌套字段的路径。

• 子聚合：在嵌套聚合中嵌套其他聚合操作，用于对嵌套文档进行进一步分析。

通过嵌套聚合，可以对嵌套字段中的文档进行复杂的聚合操作，从而满足复杂的查询需求。