如何在ElasticSearch过滤脚本中遍历嵌套类型并实现动态价格筛选

• 核心思路：利用Elasticsearch的nested查询处理嵌套的product_variants，在嵌套上下文内编写脚本计算每个变体的当前生效价格，同时通过inner_hits返回触发筛选条件的变体。
• 关键注意事项：嵌套类型的字段必须在nested查询的上下文内访问，顶级查询/脚本无法直接遍历嵌套对象数组；脚本中必须添加非空判断，避免空指针异常。

完整查询示例 #

GET /your_product_index/_search
{
  "query": {
    "nested": {
      "path": "product_variants",
      "query": {
        "script": {
          "script": {
            "source": """
              // 获取当前时间戳（也可提前生成作为参数传入，提升性能）
              long now = new Date().getTime();
              // 访问当前嵌套变体的价格数组，先做非空判断
              def priceList = doc['product_variants.variant_prices'];
              if (priceList == null || priceList.isEmpty()) {
                return false;
              }
              // 筛选出已生效的价格（date_since <= 当前时间）
              def validPrices = priceList.stream()
                .filter(p -> p.date_since != null && p.date_since.value <= now)
                .collect(Collectors.toList());
              if (validPrices.isEmpty()) {
                return false;
              }
              // 找出最新生效的价格（date_since最大的记录）
              def activePrice = validPrices.stream()
                .max(Comparator.comparingLong(p -> p.date_since.value))
                .get().price.value;
              // 判断价格是否≥指定最小值
              return activePrice >= params.min_price;
            """,
            "params": {
              "min_price": 100 // 替换为你的价格阈值
            }
          }
        }
      },
      "inner_hits": {
        "_source": ["product_variants.id", "product_variants.variant_prices"]
      }
    }
  }
}

关键细节说明 #

1. 嵌套上下文的必要性：外层nested查询指定path: product_variants后，脚本会运行在每个独立变体的上下文内，此时doc['product_variants.variant_prices']能正确访问当前变体的价格数组，避免了顶级上下文无法遍历嵌套对象的问题。
2. 空安全处理：脚本中对priceList、date_since等字段添加非空判断，直接规避了空指针异常。
3. 性能优化：使用doc而非params._source访问字段，因为doc基于倒排索引缓存，性能远高于直接读取原始文档；若需访问未索引的字段，可改用params._source?.product_variants?.variant_prices（用?.做空安全访问）。
4. inner_hits配置：通过inner_hits返回命中的变体字段，方便直接定位触发筛选条件的具体变体。

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