如何通过单条ElasticSearch查询实现单文档拆分多文档

没问题！你要的这种单条查询拆分文档、又不占用额外存储空间的需求，完全可以通过Elasticsearch的Runtime Nested字段配合嵌套查询来实现——所有处理都在查询时动态完成，不会修改你原有的存储文档，刚好符合你CPU内存充足但想省存储空间的要求。

推荐方案（Elasticsearch 7.11+） #

这个方案利用Runtime字段的特性，在查询时临时把数组转换成嵌套对象，再通过嵌套查询的inner_hits返回拆分后的每条数据，结果格式和你期望的高度一致。

查询示例 #

GET /your_index/_search
{
  "query": {
    "nested": {
      "path": "runtime_values",
      "query": {
        "match_all": {}
      },
      "inner_hits": {
        "_source": false,
        "fields": [
          "name",
          "runtime_values.value",
          "runtime_values.sequence"
        ],
        "size": 1000
      }
    }
  },
  "runtime_mappings": {
    "runtime_values": {
      "type": "nested",
      "script": """
        emit(doc['values'].stream().map(val -> ['value': val, 'sequence': (doc['values'].indexOf(val) + 1)]).collect(Collectors.toList()));
      """
    }
  },
  "_source": false
}

方案解释 #

• runtime_mappings：临时定义一个嵌套类型的字段runtime_values，用Painless脚本把原文档的values数组转换成包含value（数组元素值）和sequence（元素序号，索引+1）的嵌套对象列表。这个字段只在查询时存在，不会写入存储。
• nested查询：匹配这个临时嵌套字段的所有元素，inner_hits会把每个嵌套元素作为单独的结果条目返回，完美实现单文档拆多文档的效果。
• 字段控制：关闭原文档的_source，只返回需要的name、value和sequence，结果结构和你期望的几乎一致。

低版本替代方案（Elasticsearch <7.11） #

如果你的ES版本不支持Runtime Nested字段，可以用聚合的方式模拟，虽然返回的是聚合结构，但客户端简单处理后就能得到目标格式：

查询示例 #

GET /your_index/_search
{
  "size": 0,
  "aggs": {
    "values_split": {
      "terms": {
        "script": {
          "source": """
            def result = [];
            for (int i = 0; i < doc['values'].length; i++) {
              result.add(doc['values'][i] + "|" + (i+1));
            }
            return result;
          """,
          "lang": "painless"
        },
        "size": 1000
      },
      "aggs": {
        "original_info": {
          "top_hits": {
            "_source": ["name"],
            "size": 1
          }
        }
      }
    }
  }
}

方案解释 #

• 用脚本把每个数组元素和序号拼接成唯一的term，通过terms聚合拆分每个元素。
• 每个聚合桶里通过top_hits获取原文档的name字段。
• 客户端只需拆分每个桶的key（按|分割得到value和sequence），再和name组合，就能得到你想要的文档结构。

注意事项 #

• 两种方案都不会修改原存储文档，完全基于查询时的动态计算，不会额外占用存储空间。
• 如果你的values数组很大，注意调整inner_hits或聚合的size参数，确保能返回所有拆分后的条目。

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