通过Firestore可调用函数实现的Elasticsearch查询为何异常？

核心问题1：await与.then()混用导致searchRes未定义 #

你在使用await等待client.search()异步结果的同时，链式调用了.then()，但.then()的回调函数没有返回任何值，这会让await拿到的searchRes变成undefined。后续访问searchRes.hits.hits自然会触发未定义错误。

原示例仅用await接收异步返回值，而你的.then()相当于把原本的查询结果替换成了undefined（回调无return）。

核心问题2：错误处理逻辑无效 #

你用.catch()捕获了错误，但只打印日志却没有抛出错误，导致函数在出错后仍会继续执行后续代码，进一步引发searchRes未定义的问题。

额外问题：查询字段不匹配 #

你的查询指定了fields: ["text"]，但如果users索引中不存在text字段，查询结果会为空，这也是拿不到用户数据的原因之一。

额外问题：响应结构访问错误 #

原示例中Elasticsearch的查询结果数据在searchRes.body下，但你直接写了searchRes.hits.hits，漏掉了body层级，即便searchRes有值，这一步也会报错。

修复后的代码 #

exports.searchUsers = functions.https.onCall(async (data, context) => {
  console.log("on search users");
  const query = data.query;
  console.log("my query: ", query);

  try {
    // 移除多余的.then()/.catch()，用try/catch统一处理错误
    const searchRes = await client.search({
      index: "users",
      body: {
        query: {
          query_string: {
            query: `*${query}*`,
            // 替换为users索引实际存在的字段，比如name、email等
            fields: ["name", "email"]
          }
        }
      }
    });

    console.log("how does it look like: ", searchRes);
    // 修正响应结构访问路径
    const hits = searchRes.body.hits.hits;
    const users = hits.map(h => h["_source"]);
    console.log("how users looks like: ", users);
    return {
      users: users
    };
  } catch (error) {
    console.log("what is my actual error: ", error);
    // 抛出标准HttpsError，让客户端能收到明确错误提示
    throw new functions.https.HttpsError('internal', '搜索用户失败', error);
  }
});

关键修复点说明 #

• 移除.then()和.catch()，改用try/catch配合await处理异步操作，确保能正确获取client.search()的返回值。
• 修正Elasticsearch响应的访问路径，从searchRes.hits.hits改为searchRes.body.hits.hits。
• 将fields替换为users索引实际存在的字段，保证查询能匹配到数据。
• 在catch块中抛出HttpsError，避免静默失败，让客户端收到明确的错误反馈。

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