如何在Elasticsearch中对数组字段值求和并按预期格式返回结果

问题原因 #

script_fields 是 Elasticsearch 专门用于返回文档本身不存在的计算字段的特性，其设计规范就是将所有计算结果统一放在fields节点下，无法通过配置直接将字段提到 hit 的根节点和_source平级，所以你现在的返回结果不符合预期是正常现象。

解决方案 #

根据你的业务场景可以选择以下两种方案：

方案1：预计算存储（性能最优，推荐生产环境使用） #

如果total_marks字段的查询频率较高，推荐直接将计算结果固化存储到文档中，避免每次查询都执行脚本计算，大幅提升查询性能。
你可以用update_by_query接口批量给存量数据补全total_marks字段：

POST sample/_update_by_query
{
  "query": {
    "match_all": {}
  },
  "script": {
    "source": """
      double sum = 0.0;
      for(item in ctx._source.student.marks) {
        sum += item.sub;
      }
      ctx._source.total_marks = sum;
    """
  }
}

后续新写入文档时也同步计算total_marks字段存入，之后正常查询就能直接拿到和_source平级的total_marks字段，完全符合你的预期返回格式。

方案2：搜索管道动态计算（无需修改原始文档） #

如果你不能修改原始文档结构，需要每次查询动态计算结果，可以通过创建搜索管道的方式实现预期格式：

1. 先创建用于计算总分的搜索管道

PUT _ingest/pipeline/calculate_total_marks
{
  "processors": [
    {
      "script": {
        "source": """
          double sum = 0.0;
          for(item in ctx._source.student.marks) {
            sum += item.sub;
          }
          ctx.total_marks = sum;
        """
      }
    }
  ]
}

2. 查询时指定使用该管道

GET sample/_search?search_pipeline=calculate_total_marks
{
  "query": {
    "match_all": {}
  }
}

这个方式不需要修改原始文档，返回结果会直接在每个 hit 的根节点下生成total_marks字段，完全符合你的需求。

轻量折中方案 #

如果你不想修改ES侧的任何配置，也可以直接沿用你原来的script_fields查询逻辑，在业务代码层做简单的结果处理，将fields节点下的total_marks提取到根节点即可，开发成本极低。

内容的提问来源于stack exchange，提问作者Manonandan S K