Elasticsearch嵌套查询结合nested term聚合未返回bucket如何解决

问题排查点 #

• 字段不存在错误：当前查询中使用的original.storefrontId字段未在你提供的mapping中定义，original对象下仅包含id/purchaseStatus/marketCode/salesProfiles四个属性，对不存在的字段做term查询会直接过滤掉所有文档，导致聚合没有返回结果。
• 缺少核心匹配逻辑：你的需求是筛选recommended.salesProfiles.marketCode等于original.marketCode的结果，但当前查询完全没有加入该等值判断逻辑，即使字段正确也无法返回符合要求的结果。
• 查询类型使用不当：recommended.salesProfiles.purchaseStatus是keyword类型，适合用term精确匹配而非match查询，match查询会触发分词逻辑，keyword类型字段无分词配置时虽然也可能匹配，但不符合最佳实践，极端情况会导致匹配结果不符合预期。
• nested字段跨上下文匹配规则问题：ES常规查询语法无法直接做不同层级字段的等值比较，需要借助painless脚本实现跨字段的等值判断，且要注意nested字段的访问路径。

修复方案 #

先将查询中不存在的original.storefrontId替换为你实际需要筛选的字段（以下示例假设你是笔误，实际要筛选的是original.id = "12345"），再添加脚本判断两个字段等值，修改后的查询如下：

GET index/_search
{
  "query": {
    "bool": {
      "filter": [
        // 替换为你实际需要的original字段筛选条件
        {
          "term": {
            "original.id": "12345"
          }
        },
        {
          "nested": {
            "path": "recommended.salesProfiles",
            "query": {
              "bool": {
                "must": [
                  {
                    "term": {
                      "recommended.salesProfiles.purchaseStatus": "PAID"
                    }
                  },
                  {
                    "script": {
                      "script": {
                        "source": "doc['recommended.salesProfiles.marketCode'].value == doc['original.marketCode'].value",
                        "lang": "painless"
                      }
                    }
                  }
                ]
              }
            }
          }
        }
      ]
    }
  },
  "aggs": {
    "similarities": {
      "filter": {
        "match_all": {}
      },
      "aggs": {
        "markets": {
          "nested": {
            "path": "recommended.salesProfiles"
          },
          "aggs": {
            "recommendedMarket": {
              "terms": {
                "field": "recommended.salesProfiles.marketCode",
                "size": 100
              }
            }
          }
        }
      }
    }
  },
  "explain": false
}

注：如果你的索引中存在original.marketCode为空的文档，可以在脚本中添加非空判断避免报错

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