Elasticsearch Terms Lookup过滤问题：筛选用户高分评价车辆

你的查询失败的核心原因是：

• 你在针对cars索引的搜索中添加了ratings.score的范围过滤，但cars索引根本没有ratings字段（该字段仅存在于users索引中），因此没有任何文档能匹配这个过滤条件。
• 原有的terms查询只是从用户3的所有评价中提取了car_id，但没有对评价的评分做筛选，之后错误地在cars索引上尝试过滤评分，这完全不符合数据结构。

正确的做法是在从users索引获取car_id的过程中，就筛选出评分≥20的车辆ID，再用这些ID去查询cars索引。可以通过在terms查询的索引查找参数中添加嵌套查询来实现：

GET cars/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "terms": {
            "car_id": {
              "index": "users",
              "type": "_doc",
              "id": "3",
              "path": "ratings.car_id",
              "query": {
                "nested": {
                  "path": "ratings",
                  "query": {
                    "range": {
                      "ratings.score": {
                        "gte": 20
                      }
                    }
                  }
                }
              }
            }
          }
        }
      ]
    }
  }
}

关键修改说明 #

1. 限定查询范围到cars索引：在GET请求中指定cars/_search，避免不必要的跨索引搜索。
2. 在索引查找中添加嵌套过滤：
   • 通过query参数在users索引的用户3文档内，使用nested查询筛选出ratings.score ≥20的嵌套对象。
   • 只从符合条件的嵌套对象中提取car_id，这样terms查询只会匹配这些高评分车辆的ID。

如果觉得嵌套查询的索引查找逻辑复杂，也可以分两步实现：

1. 先从users索引获取用户3评分≥20的car_id：

GET users/_doc/3
{
  "script_fields": {
    "high_score_car_ids": {
      "script": {
        "source": """
          def ids = [];
          for (rating in params._source.ratings) {
            if (rating.score >= 20) {
              ids.add(rating.car_id);
            }
          }
          return ids;
        """
      }
    }
  }
}

2. 使用返回的car_id列表查询cars索引：

GET cars/_search
{
  "query": {
    "terms": {
      "car_id": ["yyy"] // 替换为上一步获取的ID列表
    }
  }
}

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