如何通过Elasticsearch查询对单文档_source内数组检索、排序与分页？

1. 先定位目标文档 #

首先得精准揪出那个带products数组的特殊文档，用exists查询就行：

{
  "query": {
    "exists": {
      "field": "products"
    }
  }
}

2. 对products数组做筛选、排序、分页 #

Elasticsearch默认会把数组字段扁平化，直接查询会返回整个文档，但要单独处理数组内的元素，有几种实用方法：

方案一：用inner_hits（兼容普通数组） #

如果你的products是普通数组（未设置nested类型），可以先匹配目标文档+指定厂商，再用inner_hits处理数组的分页和排序：

{
  "query": {
    "bool": {
      "must": [
        { "exists": { "field": "products" } },
        { "term": { "products.vendor": "Volkswagen" } }
      ]
    }
  },
  "inner_hits": {
    "products": {
      "size": 100, // 每页100条
      "from": 0, // 分页起始位，第一页为0，第二页为100，以此类推
      "sort": [
        { "products.product": "desc" } // 按product字段降序排序
      ]
    }
  }
}

单文档场景下这个方法足够好用，inner_hits会返回所有匹配的数组元素，排序和分页逻辑也能正常生效。

方案二：把products设为nested类型（更推荐） #

如果还能修改索引mapping，把products设为nested类型是最优解——普通数组会被扁平化存储，而nested类型会把每个数组元素当作独立的小文档处理，操作精准度更高：
先更新索引mapping：

PUT /你的索引名/_mapping
{
  "properties": {
    "products": {
      "type": "nested",
      "properties": {
        "vendor": { "type": "keyword" },
        "product": { "type": "keyword" }
      }
    }
  }
}

然后用nested查询+inner_hits完成需求：

{
  "query": {
    "bool": {
      "must": [
        { "exists": { "field": "products" } },
        {
          "nested": {
            "path": "products",
            "query": {
              "term": { "products.vendor": "Volkswagen" }
            },
            "inner_hits": {
              "size": 100,
              "from": 0,
              "sort": [
                { "products.product": "desc" }
              ]
            }
          }
        }
      ]
    }
  }
}

这种方式下，inner_hits会精准返回符合条件的数组元素，排序和分页完全基于数组内的独立元素，不会有扁平化带来的逻辑混乱。

方案三：脚本字段临时处理（不推荐大规模使用） #

如果没法修改mapping，也可以用脚本字段在查询时直接处理数组，但性能较差，仅适合临时需求：

{
  "query": {
    "exists": { "field": "products" }
  },
  "script_fields": {
    "filtered_products": {
      "script": {
        "source": """
          def result = [];
          for (item in params._source.products) {
            if (item.vendor == 'Volkswagen') {
              result.add(item);
            }
          }
          // 按product字段降序排序
          result.sort((a,b) -> b.product.compareTo(a.product));
          // 分页取前100条
          return result.subList(0, Math.min(100, result.size()));
        """
      }
    }
  },
  "_source": false // 不需要返回原始文档，只取处理后的数组
}

总结 #

• 优先选择方案二，修改mapping为nested类型，精准度和性能表现最佳；
• 无法修改mapping时用方案一，简单直接满足需求；
• 方案三仅适合临时救急，不要在大规模数据场景下使用。

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