Elasticsearch：如何仅聚合符合条件的嵌套文档求指定科目平均分

你的问题核心在于：普通的查询+聚合只会匹配包含目标科目的整个文档，但会把该文档里所有科目的分数都纳入计算，所以才得到了(47+22+65+72)/4=51.5的结果，而不是你想要的(47+65)/2=56。

要实现只计算subject=maths的分数平均值，需要精准定位到每个嵌套的project条目，而不是整个文档，下面分两种场景给出解决方案：

场景1：project字段已配置为nested类型（推荐方案） #

这是处理Elasticsearch嵌套数组的标准方式，如果你已经把project字段设为nested类型，直接用嵌套聚合+过滤聚合就能实现需求：

{
  "size": 0,
  "aggs": {
    "enter_nested_projects": {
      "nested": {
        "path": "project"
      },
      "aggs": {
        "filter_maths_subject": {
          "filter": {
            "term": {
              "project.subject": "maths"
            }
          },
          "aggs": {
            "avg_maths_marks": {
              "avg": {
                "field": "project.marks"
              }
            }
          }
        }
      }
    }
  }
}

逻辑拆解： #

• nested聚合：进入project数组的每个嵌套文档上下文，让Elasticsearch把每个project条目当作独立的文档处理
• filter聚合：只保留subject=maths的嵌套条目
• avg聚合：对筛选后的marks字段计算平均值

执行这个查询后，你会得到预期的56.0结果。

场景2：project字段未配置为nested类型（临时 workaround） #

如果你的索引里project是普通的object数组（Elasticsearch会自动扁平化存储，丢失嵌套关联），可以用脚本聚合临时解决，但性能较差（不推荐大数据量使用）：

{
  "size": 0,
  "aggs": {
    "avg_maths_marks": {
      "avg": {
        "script": {
          "source": """
            def sum = 0;
            def count = 0;
            // 遍历每个subject，匹配maths时累加对应的marks
            for (int i = 0; i < doc['project.subject'].length; i++) {
              if (doc['project.subject'][i].value == 'maths') {
                sum += doc['project.marks'][i].value;
                count++;
              }
            }
            // 避免除以0的情况
            return count > 0 ? sum / count : null;
          """
        }
      }
    }
  }
}

注意： #

如果可以的话，强烈建议修改索引映射，把project字段改为nested类型——这是Elasticsearch处理嵌套数组的最优方式，后续的聚合、查询都会更高效准确。

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