Elasticsearch聚合过滤器与查询过滤器结果不一致问题排查

核心问题点 #

嵌套类型（nested）的每个子文档都是独立存储的，必须在对应的nested聚合上下文中进行过滤和聚合，否则会出现跨嵌套文档的错误匹配，导致聚合结果不符合预期。你之前直接把查询过滤器套用到聚合中，就是因为没维护好嵌套上下文的层级关系。

字段映射确认（Mapping） #

{
  "mappings": {
    "properties": {
      "categories": {
        "type": "nested",
        "properties": {
          "name": { "type": "keyword" },
          "subcategories": {
            "type": "nested",
            "properties": {
              "name": { "type": "keyword" },
              "subsubcategories": {
                "type": "nested",
                "properties": {
                  "name": { "type": "keyword" }
                }
              }
            }
          }
        }
      }
    }
  }
}

示例数据（Sample Data） #

[
  {
    "categories": [
      {
        "name": "电子产品",
        "subcategories": [
          {
            "name": "手机",
            "subsubcategories": [
              { "name": "智能手机" },
              { "name": "功能机" }
            ]
          },
          {
            "name": "电脑",
            "subsubcategories": [
              { "name": "笔记本" },
              { "name": "台式机" }
            ]
          }
        ]
      },
      {
        "name": "家居",
        "subcategories": [
          {
            "name": "家具",
            "subsubcategories": [
              { "name": "沙发" },
              { "name": "床" }
            ]
          }
        ]
      }
    ]
  },
  {
    "categories": [
      {
        "name": "电子产品",
        "subcategories": [
          {
            "name": "手机",
            "subsubcategories": [
              { "name": "智能手机" }
            ]
          }
        ]
      }
    ]
  }
]

场景1：查询过滤与聚合过滤不同 #

比如：查询所有家居分类的商品，但聚合统计电子产品->手机下的三级分类分布（聚合过滤与查询过滤完全独立）

{
  "query": {
    "nested": {
      "path": "categories",
      "query": {
        "term": { "categories.name": "家居" }
      }
    }
  },
  "aggs": {
    "filter_electronics": {
      "nested": {
        "path": "categories"
      },
      "aggs": {
        "filter_category": {
          "filter": {
            "term": { "categories.name": "电子产品" }
          },
          "aggs": {
            "subcategories_nested": {
              "nested": {
                "path": "categories.subcategories"
              },
              "aggs": {
                "filter_subcategory": {
                  "filter": {
                    "term": { "categories.subcategories.name": "手机" }
                  },
                  "aggs": {
                    "subsubcategories_nested": {
                      "nested": {
                        "path": "categories.subcategories.subsubcategories"
                      },
                      "aggs": {
                        "subsubcategory_distribution": {
                          "terms": { "field": "categories.subcategories.subsubcategories.name" }
                        }
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

关键点说明 #

• 每一层嵌套字段的操作都要先通过nested聚合进入对应上下文
• 聚合内的过滤器是逐层生效的：先过滤一级分类，再进入二级嵌套上下文过滤二级分类，最后进入三级嵌套上下文做聚合

场景2：基于一级分类聚合三级分类 #

比如：查询所有商品，聚合统计电子产品下所有三级分类的分布

{
  "query": { "match_all": {} },
  "aggs": {
    "categories_nested": {
      "nested": { "path": "categories" },
      "aggs": {
        "filter_electronics": {
          "filter": { "term": { "categories.name": "电子产品" } },
          "aggs": {
            "subcategories_nested": {
              "nested": { "path": "categories.subcategories" },
              "aggs": {
                "subsubcategories_nested": {
                  "nested": { "path": "categories.subcategories.subsubcategories" },
                  "aggs": {
                    "subsubcategory_distribution": {
                      "terms": { "field": "categories.subcategories.subsubcategories.name" }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

场景3：基于二级分类聚合三级分类 #

比如：查询所有商品，聚合统计手机二级分类下的三级分类分布（不管所属一级分类）

{
  "query": { "match_all": {} },
  "aggs": {
    "categories_nested": {
      "nested": { "path": "categories" },
      "aggs": {
        "subcategories_nested": {
          "nested": { "path": "categories.subcategories" },
          "aggs": {
            "filter_phone": {
              "filter": { "term": { "categories.subcategories.name": "手机" } },
              "aggs": {
                "subsubcategories_nested": {
                  "nested": { "path": "categories.subcategories.subsubcategories" },
                  "aggs": {
                    "subsubcategory_distribution": {
                      "terms": { "field": "categories.subcategories.subsubcategories.name" }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

常见错误写法示例（为什么错） #

直接在外层聚合加过滤器，未进入嵌套上下文：

// 错误写法
{
  "aggs": {
    "wrong_filter": {
      "filter": { "term": { "categories.name": "电子产品" } },
      "aggs": {
        "subsubcategory_distribution": {
          "terms": { "field": "categories.subcategories.subsubcategories.name" }
        }
      }
    }
  }
}

这种写法会导致Elasticsearch无法关联嵌套文档的层级，把所有三级分类（无论所属一级/二级分类）都统计进来，结果完全不符合预期。

内容的提问来源于stack exchange，提问作者sj_7