Elasticsearch百分位聚合返回0值问题排查（嵌套文档场景）

尝试通过Elasticsearch聚合计算pricingscore字段的75百分位值，但最终匹配条件的docCount为0，导致百分位值为0。

索引映射 #

"pricingbytrade" : {
    "type" : "nested",
    "properties" : {
      "name" : {
        "type" : "text",
        "fields" : {
          "analyzed" : {
            "type" : "text",
            "analyzer" : "standard",
            "search_analyzer" : "synonym_analyzer"
          },
          "keyword" : {
            "type" : "keyword",
            "ignore_above" : 256,
            "normalizer" : "lowercase"
          }
        }
      },
      "pricingbycbsa" : {
        "type" : "nested",
        "properties" : {
          "cbsaid" : {
            "type" : "integer"
          },
          "cbsaname" : {
            "type" : "text"
          },
          "pricingscore" : {
            "type" : "float"
          }
        }
      }
    }
} 

原聚合代码 #

要求仅当pricingbytrade.name匹配指定搜索词且pricingbytrade.pricingbycbsa.cbsaid匹配指定cbsaid时，计算pricingbytrade.pricingbycbsa.pricingscore的75百分位：

.Nested("pricingbytrade", n => n
    .Path("pricingbytrade")
    .Aggregations(nestedAggs => nestedAggs
        .Nested("pricingbycbsa", nn => nn
            .Path("pricingbytrade.pricingbycbsa")
            .Aggregations(nestedNestedAggs => nestedNestedAggs
                .Filter("filter_bycbsa", ff => ff
                    .Filter(filter => filter
                        .Bool(b => b
                            .Should(filterList => filterList
                              .Term(t => t
                                    .Field("pricingbytrade.pricingbycbsa.cbsaid")
                                    .Value(_cbsaId)
                                ),
                                filterList => filterList
                                    .Term(t => t
                                        .Field("pricingbytrade.name")
                                        .Value(_searchTerm.ToLower())
                                    )
                           )
                        )
                    )
                    .Aggregations(subAggs => subAggs
                        .Percentiles("price_score_percentiles", p => p
                            .Field("pricingbytrade.pricingbycbsa.pricingscore")
                            .Percents(75)
                        )
                    )
                )
            )
        )
    )
);

原结果访问代码 #

var priceScorePercentiles = response.Aggregations
              .Nested("pricingbytrade")
              .Nested("pricingbycbsa")
              .Nested("filter_bycbsa")
              .PercentilesBucket("price_score_percentiles")
              .Items[0]
              .Value;

尽管存在匹配文档，但price_score_percentiles桶的docCount始终为0。

核心错误点 #

1. 跨嵌套层级过滤无效：pricingbytrade.name属于外层nested对象，进入内层pricingbycbsa的nested聚合后，无法直接过滤外层字段——内层nested文档独立于外层，看不到外层的name字段，导致过滤条件永远不匹配。
2. 字段使用错误：pricingbytrade.name是text类型，用Term查询会匹配分词后的结果，而你需要的是精确匹配，应该使用其keyword子字段（已配置小写归一化）。
3. 聚合层级逻辑混乱：原代码把两个跨层级的过滤条件放在同一层filter里，不符合nested聚合的层级隔离特性。

修正后的聚合代码 #

调整逻辑：先在外层nested聚合中过滤name匹配的文档，再在内层nested聚合中过滤cbsaid匹配的文档，最后计算百分位：

.Nested("pricingbytrade", n => n
    .Path("pricingbytrade")
    // 先过滤外层nested中name匹配的文档
    .Query(q => q
        .Term(t => t
            .Field("pricingbytrade.name.keyword")
            .Value(_searchTerm) // 无需手动转小写，keyword字段已配置lowercase normalizer
        )
    )
    .Aggregations(nestedAggs => nestedAggs
        .Nested("pricingbycbsa", nn => nn
            .Path("pricingbytrade.pricingbycbsa")
            // 过滤内层nested中cbsaid匹配的文档
            .Query(q => q
                .Term(t => t
                    .Field("pricingbytrade.pricingbycbsa.cbsaid")
                    .Value(_cbsaId)
                )
            )
            .Aggregations(subAggs => subAggs
                .Percentiles("price_score_percentiles", p => p
                    .Field("pricingbytrade.pricingbycbsa.pricingscore")
                    .Percents(75)
                )
            )
        )
    )
);

修正后的结果访问代码 #

原代码错误地将filter聚合当作nested聚合访问，需要调整为正确的聚合类型访问方式：

var priceScorePercentiles = response.Aggregations
    .Nested("pricingbytrade")
    .Nested("pricingbycbsa")
    .Percentiles("price_score_percentiles")
    .Items.FirstOrDefault()?.Value ?? 0;

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