Elasticsearch：如何在单个查询中先折叠数据再执行过滤

完全可以在同一个查询里先执行collapse折叠，再对折叠结果过滤，你当前写法没生效是因为字段路径不匹配或主文档字段缺失。

核心问题分析 #

你用post_filter的思路是对的——Elasticsearch的执行顺序是先执行查询、再做collapse折叠、最后应用post_filter过滤。但问题出在两点：

• 字段路径不匹配：你的inner_hits指定返回is_active字段，但post_filter里写的是item.is_active，如果实际文档中is_active是一级字段而非嵌套在item下，就会导致过滤匹配失败。
• 主文档字段缺失：如果主文档的_source没有包含要过滤的字段，post_filter无法读取对应值，最好显式指定主查询的_source包含过滤所需字段。

修正后的查询语句 #

{
  "size": 1000,
  "_source": ["item.item_id", "is_active", "calculated_at"], // 显式指定主文档返回过滤所需字段
  "collapse": {
    "field": "item.item_id.keyword",
    "inner_hits": {
      "name": "latest",
      "size": 1,
      "sort": [
        {
          "calculated_at": "desc"
        }
      ],
      "_source": ["item_id", "timestamp", "is_active"]
    }
  },
  "post_filter": {
    "term": {
      "is_active": false // 确保字段路径和实际文档一致
    }
  }
}

额外说明 #

collapse后的主文档就是每个分组里按calculated_at排序后的第一个文档（即你要的最新数据），所以post_filter过滤主文档的is_active，本质就是过滤每个分组最新数据的状态，完全符合你的需求。

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