如何在Node.js中使用Elasticsearch和Promise执行多搜索查询？

要在Node.js里结合Elasticsearch和Promise执行多个搜索查询，最高效的方式是用Elasticsearch官方提供的_msearch（多搜索）API——它能让你在单个HTTP请求里打包多个搜索任务，再通过Promise优雅处理异步结果。下面一步步给你讲清楚：

一、先搞懂Elasticsearch的_msearch请求格式 #

_msearch的请求体是成对出现的：每一组查询由元数据行和查询体行组成。元数据用来指定该查询对应的索引、文档类型（旧版本ES需要）等参数，查询体就是你熟悉的DSL查询语句。

举个原生HTTP请求示例：

POST /_msearch
{ "index": "INDEX_NAME_1", "type": "TYPE_NAME_1" }
{ "query": { "match_all": {}}}
{ "index": "INDEX_NAME_2", "type": "TYPE_NAME_2" }
{ "query": { "match_all": {}}}

二、Node.js中结合Promise的实现代码 #

Elasticsearch的Node.js客户端自带msearch方法，而且它本身就返回Promise，咱们可以直接用它处理异步逻辑，也可以结合async/await让代码更清爽。

基础版（用Promise的then/catch） #

// 初始化Elasticsearch客户端
const elasticClient = require('elasticsearch').Client({
  host: 'http://your-es-host:9200',
  // 按需添加认证、超时等配置
});

function executeMultiSearch() {
  return elasticClient.msearch({
    body: [
      // 第一个查询的元数据
      { index: '*:logstash-prod-*', type: 'callEnd' },
      // 第一个查询体（按时间范围查询，取10000条结果）
      {
        size: 10000,
        query: {
          range: { "@timestamp": { "gte": "now-7d", "lte": "now" } }
        }
      },
      // 第二个查询的元数据
      { index: "INDEX_NAME_2", type: "TYPE_NAME_2" },
      // 第二个查询体
      { query: { match_all: {} } }
    ]
  });
}

// 调用函数并处理结果
executeMultiSearch()
  .then(results => {
    // results.responses是数组，每个元素对应一个查询的结果
    console.log("第一个查询结果:", results.responses[0]);
    console.log("第二个查询结果:", results.responses[1]);
  })
  .catch(err => {
    console.error("多查询出错:", err);
  });

进阶版（用async/await简化代码） #

如果你更喜欢同步风格的异步代码，用async/await会更易读：

const elasticClient = require('elasticsearch').Client({
  host: 'http://your-es-host:9200',
});

async function runMultiQueries() {
  try {
    const searchResults = await elasticClient.msearch({
      body: [
        { index: '*:logstash-prod-*', type: 'callEnd' },
        {
          size: 10000,
          query: {
            range: { "@timestamp": { "gte": "now-7d", "lte": "now" } }
          }
        },
        { index: "INDEX_NAME_2", type: "TYPE_NAME_2" },
        { query: { match_all: {} } }
      ]
    });

    // 遍历处理每个查询的结果
    searchResults.responses.forEach((res, index) => {
      console.log(`第${index+1}个查询命中总数:`, res.hits.total);
    });

    return searchResults.responses;
  } catch (error) {
    console.error("执行多查询失败:", error);
    throw error; // 可根据业务需求决定是否抛出错误
  }
}

// 调用async函数
runMultiQueries();

几个注意事项 #

• 如果你用的是Elasticsearch 7.x及以上版本，type参数已被废弃，元数据里可以直接去掉该字段，只保留index即可。
• msearch返回的responses数组顺序和你传入的查询顺序完全一致，不用担心结果乱序。
• 单个查询失败不会影响其他查询执行，失败的查询会在对应responses元素里返回错误信息。

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