Elasticsearch能否合并嵌套产品的inner hits以返回匹配产品列表？

当然可以！在Elasticsearch里完全能实现只返回匹配的嵌套产品列表，而不是以父文档为单位返回结果。下面给你几种实用的方案，根据你的场景选就行：

方案1：嵌套聚合 + Top Hits（推荐实时查询场景） #

这种方法直接在Elasticsearch端完成聚合和提取，能一次性拿到合并后的匹配产品列表，还能直接按评分、价格排序。

假设你的索引映射大概是这样：

{
  "mappings": {
    "properties": {
      "vendor": { "type": "keyword" },
      "products": {
        "type": "nested",
        "properties": {
          "name": { "type": "text" },
          "price": { "type": "float" },
          "score": { "type": "float" }
        }
      }
    }
  }
}

对应的查询语句：

GET /your_index/_search
{
  "size": 0, // 不返回父文档，只聚焦聚合结果
  "query": {
    "nested": {
      "path": "products",
      "query": {
        "match": { "products.name": "你的搜索关键词" } // 替换成你的搜索条件
      }
    }
  },
  "aggs": {
    "all_matching_products": {
      "nested": {
        "path": "products"
      },
      "aggs": {
        "filtered_products": {
          "filter": {
            "match": { "products.name": "你的搜索关键词" } // 和上面的查询条件保持一致
          },
          "aggs": {
            "product_list": {
              "top_hits": {
                "size": 100, // 按需调整返回的产品数量
                "sort": [
                  { "products.score": "desc" }, // 按评分降序
                  { "products.price": "asc" }   // 按价格升序
                ],
                "_source": {
                  "includes": ["products.*", "vendor"] // 指定要返回的字段，比如产品信息+供应商
                }
              }
            }
          }
        }
      }
    }
  }
}

查询结果会在aggregations.all_matching_products.filtered_products.product_list.hits.hits里，就是你要的扁平化匹配产品列表。

方案2：Inner Hits + 客户端合并（简单场景快速实现） #

如果你的父文档数量不多，也可以先获取包含inner hits的结果，再在应用端把每个父文档的匹配产品提取出来合并成列表，实现成本很低。

查询语句：

GET /your_index/_search
{
  "query": {
    "nested": {
      "path": "products",
      "query": {
        "match": { "products.name": "你的搜索关键词" }
      },
      "inner_hits": {
        "size": 100,
        "sort": [
          { "products.score": "desc" },
          { "products.price": "asc" }
        ],
        "_source": {
          "includes": ["products.*", "vendor"]
        }
      }
    }
  },
  "_source": false // 不返回父文档的原始内容，只保留inner hits
}

拿到结果后，遍历每个命中的父文档，取出inner_hits.hits.hits里的内容，合并成一个数组就可以了。

方案3：Elasticsearch Transform（高频查询/非实时场景最优） #

如果你的数据更新不频繁，或者需要高频做这类产品列表查询，建议用Transform把嵌套结构转成扁平化的独立文档。这样后续查询就和普通索引一样，性能拉满。

创建Transform的语句：

PUT _transform/product_flatten_transform
{
  "source": {
    "index": ["your_index"]
  },
  "dest": {
    "index": "flattened_products" // 生成的扁平化索引名
  },
  "pivot": {
    "group_by": {
      "product_id": { "terms": { "field": "products.id" } } // 假设产品有唯一ID，用来分组
    },
    "aggregations": {
      "vendor": { "terms": { "field": "vendor", "size": 1 } },
      "product_name": { "terms": { "field": "products.name", "size": 1 } },
      "product_price": { "avg": { "field": "products.price" } },
      "product_score": { "avg": { "field": "products.score" } }
    }
  }
}

创建后启动Transform：

POST _transform/product_flatten_transform/_start

之后flattened_products索引里每个文档就是一个独立的产品，你可以直接用普通的match查询+排序，完全不用处理嵌套结构了。

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