Elasticsearch查询：获取最后状态为51的10条文档列表

原查询的问题分析 #

你当前的查询存在两个核心问题：

1. 过滤时机错误：post_filter是在collapse分组之后执行，过滤的是分组后的主文档，但主文档并非该transactionId的最新记录（collapse的主文档默认取分组内未指定排序的第一条，而非inner_hits中按timestamp排序的最新条目），导致过滤逻辑完全偏离预期。
2. 字段类型不匹配：你的文档中transactionStatus是数字类型，但查询里用了字符串值（如"51"），这会导致类型不匹配，过滤结果异常。

正确查询方法 #

方法1：Terms聚合 + Top Hits聚合 + Bucket Selector（精准匹配需求） #

这种方式先按transactionId分组，提取每组最新记录，再过滤出最新记录状态为51的分组，最后返回前10个符合要求的文档。

{
  "size": 0,
  "aggs": {
    "group_transaction": {
      "terms": {
        "field": "transactionId",
        "size": 10  // 若担心过滤后结果不足10，可设更大值如20
      },
      "aggs": {
        "latest_record": {
          "top_hits": {
            "size": 1,
            "sort": [{"timestamp": "desc"}]
          }
        },
        "filter_status_51": {
          "bucket_selector": {
            "buckets_path": {
              "current_status": "latest_record.hits.hits.0._source.transactionStatus"
            },
            "script": "params.current_status == 51"
          }
        }
      }
    }
  }
}

逻辑说明：

• terms聚合按transactionId做分组，确保每个交易只保留一个分组
• top_hits聚合提取每个分组内timestamp最新的1条记录
• bucket_selector脚本过滤出最新记录状态为51的分组
• 最终结果在aggregations.group_transaction.buckets下，每个bucket的latest_record.hits.hits即为目标文档

方法2：Collapse + 前置过滤（简洁高效） #

如果你的场景中，最新状态为51的交易，其最后一条记录的状态必然是51，可以直接先筛选所有状态为51的记录，再按transactionId分组取最新条目：

{
  "size": 10,
  "query": {
    "term": {
      "transactionStatus": 51  // 用数字匹配字段类型，避免类型错误
    }
  },
  "sort": [{"timestamp": "desc"}],
  "collapse": {
    "field": "transactionId",
    "inner_hits": {
      "name": "most_recent",
      "size": 1,
      "sort": [{"timestamp": "desc"}]
    }
  }
}

逻辑说明：

• 先通过query筛选所有状态为51的记录
• 全局按timestamp降序排序，确保最新记录排在最前
• collapse按transactionId分组，每个分组自动取排序后的第一条（即该交易的最新51状态记录）
• 直接返回10个不同交易的最新51状态文档

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