如何在Elasticsearch中获取嵌套对象数量并用于查询、排序？

一、你的Runtime Field报错原因 #

嵌套类型字段在Elasticsearch中会被拆分为独立的Lucene文档存储，无法通过doc['user']直接访问原始的嵌套对象数组，这就是你遇到No field found for [user] in mapping错误的核心原因。

二、正确使用Runtime Field实现需求 #

要计算嵌套对象数量，需要通过params._source访问原始文档中的嵌套数组，同时要处理字段不存在的边界情况。以下是完整的查询示例，包含过滤用户数大于指定值和按用户数降序排序：

GET my-index-000001/_search
{
  "runtime_mappings": {
    "user_count": {
      "type": "long",
      "script": {
        "source": "emit(params._source.user != null ? params._source.user.size() : 0)"
      }
    }
  },
  "query": {
    "range": {
      "user_count": {
        "gt": 1 // 过滤用户数大于1的文档
      }
    }
  },
  "sort": [
    {
      "user_count": {
        "order": "desc" // 按用户数降序排列
      }
    }
  ],
  "fields": ["some_id", "user_count"]
}

三、性能更优的方案：提前存储嵌套对象数量 #

如果你的查询频率较高，建议在索引文档时直接计算并存储嵌套对象的数量（比如新增user_count字段），这样可以避免Runtime脚本带来的性能开销：

1. 更新索引映射（可选，若未提前定义） #

PUT my-index-000001/_mapping
{
  "properties": {
    "user_count": {"type": "long"}
  }
}

2. 索引文档时写入数量值 #

PUT my-index-000001/_doc/1
{
  "some_id": 111,
  "user" : [
    {
      "first" : "John",
      "last" :  "Smith"
    },
    {
      "first" : "Alice",
      "last" :  "White"
    }
  ],
  "user_count": 2
}

3. 简化查询与排序 #

GET my-index-000001/_search
{
  "query": {
    "range": {
      "user_count": {
        "gt": 1
      }
    }
  },
  "sort": [
    {
      "user_count": {
        "order": "desc"
      }
    }
  ]
}

四、用聚合统计嵌套对象数量分布 #

如果需要统计不同用户数的文档数量分布，无论是使用Runtime Field还是提前存储的字段，都可以通过terms聚合实现：

使用Runtime Field的聚合示例 #

GET my-index-000001/_search
{
  "size": 0, // 不返回具体文档，只返回聚合结果
  "runtime_mappings": {
    "user_count": {
      "type": "long",
      "script": {
        "source": "emit(params._source.user != null ? params._source.user.size() : 0)"
      }
    }
  },
  "aggs": {
    "user_count_distribution": {
      "terms": {
        "field": "user_count"
      }
    }
  }
}

使用提前存储字段的聚合示例 #

GET my-index-000001/_search
{
  "size": 0,
  "aggs": {
    "user_count_distribution": {
      "terms": {
        "field": "user_count"
      }
    }
  }
}

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