Node.js编写AWS Lambda查询RDS MySQL返回null问题求助

看起来你的问题主要出在异步代码的处理方式上，再加上几个小语法和逻辑漏洞，导致Lambda在数据库查询完成前就结束了执行，所以返回了null。我帮你梳理下问题点和修复方案：

问题根源 #

1. Async Handler与回调函数冲突：你给handler标记了async，但内部还是用传统的回调函数处理数据库连接和查询。Lambda的async handler会返回一个Promise，当函数执行到末尾时如果Promise还没resolve，runtime会直接结束，导致回调里的结果根本没机会返回。
2. 语法错误：require(./config.json)少了引号，应该是require('./config.json')——这个可能已经导致模块加载失败了！
3. 错误处理缺失：pool.getConnection的err没有处理，如果连接失败，你的代码会直接卡住。
4. 连接泄漏风险：connection.release()放在查询回调里，如果查询出错，这段代码不会执行，会导致数据库连接一直被占用。

修复后的代码 #

我把代码改成了用async/await配合Promise的写法，这样能保证Lambda等到数据库操作完成后再返回结果：

var mysql = require('mysql');
var util = require('util');
var config = require('./config.json'); // 修复引号问题

var pool = mysql.createPool({
  host: config.dbhost,
  user: config.dbuser,
  password: config.dbpassword,
  database: config.dbname,
  port: 3306
});

// 将回调式的方法转为Promise，方便用async/await
pool.getConnection = util.promisify(pool.getConnection);
pool.query = util.promisify(pool.query);

exports.handler = async (event, context) => {
  context.callbackWaitsForEmptyEventLoop = false;
  let connection;

  try {
    // 获取数据库连接
    connection = await pool.getConnection();
    // 执行查询
    const results = await connection.query('SELECT emp_name FROM employee_info WHERE emp_id = 2');
    
    // 处理无结果的情况，避免results[0]报错
    if (results.length === 0) {
      return { 
        statusCode: 404, 
        body: JSON.stringify('No employee found with emp_id=2') 
      };
    }

    // 返回查询到的emp_name
    return {
      statusCode: 200,
      body: JSON.stringify(results[0].emp_name)
    };
  } catch (err) {
    // 捕获并打印错误，返回错误响应
    console.error('Database operation failed:', err);
    return {
      statusCode: 500,
      body: JSON.stringify(`Error: ${err.message}`)
    };
  } finally {
    // 无论成功失败，都释放连接，避免泄漏
    if (connection) {
      connection.release();
    }
  }
};

额外检查项 #

除了代码，还要确认这些配置是否正确：

• Lambda权限：确保你的Lambda角色有访问RDS的权限（比如添加AmazonRDSDataFullAccess政策，或者更细粒度的权限）。
• VPC配置：如果你的RDS实例在VPC里，Lambda必须配置到同一个VPC的子网中，并且RDS的安全组要允许Lambda所在安全组访问3306端口。
• config.json内容：确认dbhost、dbuser、dbpassword、dbname这些配置项都正确，没有拼写错误。

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