先来看你的需求对应的SQL逻辑：

SELECT count(*) as total,country_code FROM orders WHERE product_id = ? GROUP BY country_code ORDER BY total desc LIMIT 3

你的Elasticsearch查询没生效主要有几个问题，我来帮你修正并解释：

核心问题分析 #

1. 错误的聚合统计方式：你用value_count统计_index字段完全没必要，terms聚合本身会自动返回doc_count字段，这正好对应SQL里的count(*)
2. 可能的嵌套字段匹配问题：如果line_items是嵌套（nested）类型，直接用match无法正确匹配数组内的product_id，需要用nested查询
3. 缺少聚合结果排序：你没有对聚合后的结果按统计数量降序排序，也没正确限制返回的分组数量

修正后的Elasticsearch查询 #

情况1：line_items是普通对象/字段（非嵌套类型） #

{
  "query": {
    "bool": {
      "must": [
        {
          "match": {
            "line_items.product_id": "0001112223333"
          }
        }
      ]
    }
  },
  "size": 0,  // 不需要返回原始文档，只需要聚合结果
  "aggregations": {
    "country_groups": {
      "terms": {
        "field": "country_code",
        "size": 3,  // 对应SQL的LIMIT 3
        "order": {
          "_count": "desc"  // 对应SQL的ORDER BY total desc
        }
      }
    }
  }
}

情况2：line_items是嵌套（nested）类型 #

如果你的line_items是嵌套数组，必须用nested查询才能正确过滤包含目标product_id的文档：

{
  "query": {
    "nested": {
      "path": "line_items",
      "query": {
        "bool": {
          "must": [
            {
              "match": {
                "line_items.product_id": "0001112223333"
              }
            }
          ]
        }
      }
    }
  },
  "size": 0,
  "aggregations": {
    "country_groups": {
      "terms": {
        "field": "country_code",
        "size": 3,
        "order": {
          "_count": "desc"
        }
      }
    }
  }
}

结果说明 #

返回的聚合结果里，country_groups.buckets就是你要的分组数据：

• key对应SQL里的country_code
• doc_count对应SQL里的total（也就是count(*)的结果）
• 已经按doc_count降序排列，并且只返回前3个分组

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