如何合并两个异构索引的查询结果并按同类型时间字段排序？

针对你需要合并call和email两个索引的查询结果、按时间字段统一排序取最新25条的需求，推荐使用**多索引搜索+运行时字段（Runtime Field）**的方案，相比Multi Search需要客户端手动合并排序，这个方案让Elasticsearch直接完成合并和排序逻辑，更高效且结果准确。

核心实现思路 #

通过运行时字段动态生成一个统一的时间字段，判断当前文档所属的索引，分别映射到callTime或timestamp，然后基于这个统一字段进行降序排序，同时可以为两个索引分别指定各自的查询条件。

完整查询DSL示例 #

GET /call,email/_search
{
  "size": 25,
  "query": {
    "bool": {
      "should": [
        {
          "indices": {
            "indices": ["call"],
            "query": {
              // 替换为call索引的实际查询条件，比如特定type过滤
              "term": {
                "type": "ZOOM"
              }
            }
          }
        },
        {
          "indices": {
            "indices": ["email"],
            "query": {
              // 替换为email索引的实际查询条件，比如bcc过滤
              "term": {
                "bcc": "abc@test.com"
              }
            }
          }
        }
      ]
    }
  },
  "runtime_mappings": {
    "unified_time": {
      "type": "date",
      "script": """
        if (doc['callTime'].size() != 0) {
          emit(doc['callTime'].value);
        } else if (doc['timestamp'].size() != 0) {
          emit(doc['timestamp'].value);
        }
      """
    }
  },
  "sort": [
    {
      "unified_time": {
        "order": "desc"
      }
    }
  ]
}

关键部分说明 #

• 多索引指定：请求路径/call,email/_search同时查询两个目标索引
• 分索引查询条件：通过bool should结合indices查询，为每个索引单独设置查询规则（示例中分别过滤了call的type和email的bcc，可根据实际需求修改）
• 统一时间字段：runtime_mappings里的unified_time字段，会根据文档存在的时间字段自动取值，实现跨索引的时间字段统一
• 排序与结果数量：基于unified_time降序排序，size:25直接返回最新的25条合并结果

关于Multi Search的问题补充 #

你之前尝试的Multi Search（_msearch）会分别返回两个索引的查询结果，无法直接在ES层面完成合并排序，需要在客户端获取两个索引的结果后，手动提取时间字段、合并列表再排序，这种方式在数据量较大时效率较低，且容易出现漏取数据的情况（比如某索引返回的前25条可能不是全局最新的），因此更推荐上述方案。

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