AWS Lambda：如何按顺序调用MySQL查询？

看起来你遇到的超时问题大概率和数据库连接未正确关闭有关——Lambda函数会一直等待连接释放，直到达到超时阈值（就是你看到的3秒）。另外，虽然你用Promise链式调用实现了顺序查询，但可以用更直观的async/await写法让代码更像“同步调用”的逻辑，同时彻底解决超时问题。

问题分析 #

你的Promise链式调用逻辑本身没问题，但遗漏了关键步骤：查询完成后没有主动关闭数据库连接。Lambda的执行环境不会自动帮你释放数据库连接，导致进程一直挂起，最终触发超时错误。

修正后的代码（用async/await实现类同步调用） #

exports.handler = async function (event, context) {
  try {
    // 按顺序执行第一个查询，await会等待Promise完成
    const result1 = await getNumber();
    // 这里可以使用result1做后续处理，比如传递参数给下一个查询
    console.log("第一个查询结果:", result1);

    // 执行第二个查询
    const result2 = await getNumber1();
    console.log("第二个查询结果:", result2);

    // 关键：查询完成后关闭数据库连接，避免Lambda超时
    await new Promise((resolve, reject) => {
      connection.end((err) => {
        if (err) reject(err);
        else resolve();
      });
    });

    return "OK";
  } catch (error) {
    console.error("查询出错:", error);
    // 即使出错也要关闭连接，防止资源泄漏
    if (connection) {
      await new Promise((resolve) => {
        connection.end(resolve);
      });
    }
    return "OK";
  }
};

// 封装查询为Promise的逻辑保持不变
function getNumber() {
  return new Promise(function(resolve, reject) {
    connection.query("SELECT 1+1 as test ", (error, data) => {
      if (error) reject(error);
      else resolve(data);
    });
  });
}

function getNumber1() {
  return new Promise(function(resolve, reject) {
    connection.query("SELECT 1+2 as test ", (error, data) => {
      if (error) reject(error);
      else resolve(data);
    });
  });
}

额外优化建议 #

1. 调整Lambda超时时间：如果你的实际查询逻辑比较复杂，3秒可能不够，可以在Lambda控制台把超时时间适当调大（比如5-10秒）。
2. 使用数据库连接池：如果你的函数需要处理多次查询，建议用连接池（比如mysql库的createPool）代替单个连接，连接池会自动管理连接的创建和释放，更高效也更不容易出资源泄漏问题。
3. 避免阻塞式同步调用：Node.js生态里几乎没有推荐的阻塞式SQL查询库，async/await是最符合Node.js异步模型的“类同步”写法，既保持性能又保证代码可读性。

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