Lambda通过RDS Data API连接MySQL的执行错误排查求助

我来帮你逐个解决这三个问题，都是使用RDS Data API和Lambda时常见的坑，我自己也踩过不少：

问题1：指定RDS实例endpoint导致Lambda超时 #

这个问题的核心是你搞错了RDS Data Service的endpoint用途。RDS Data API有自己专属的服务endpoint，不是你RDS MySQL实例的连接地址！你填的是RDS实例的集群地址，但Data Service是AWS的托管服务，它的endpoint格式是rds-data.<region>.amazonaws.com（比如us-west-2区域就是rds-data.us-west-2.amazonaws.com）。

另外，Lambda超时还有可能和VPC配置有关：

• 如果你的Lambda部署在VPC内，需要确保安全组允许出站访问RDS Data API（可以通过配置VPC端点，或者允许到公网的出站流量）
• 最简单可靠的解决方案是直接去掉endpoint参数，让AWS SDK自动根据Lambda的区域配置（或SDK默认区域）解析正确的Data Service endpoint，这样就能彻底解决超时问题。

问题2：路径参数id未被标记为必填，访问/user/无报错 #

你的serverless.yml配置写法有误，正确的路径参数必填配置应该是：

request:
  parameters:
    paths:
      id:
        required: true

不过即使配置了这个，API Gateway的校验有时候不会主动返回明确的400错误，最稳妥的方式是在代码层面手动做参数校验，比如在函数开头加上：

const req_id = event.pathParameters?.id;
if (!req_id || req_id.trim() === '') {
  return callback(null, {
    statusCode: 400,
    body: JSON.stringify({ message: 'User ID is required' })
  });
}

这样不管配置是否生效，都能拦截非法请求，给用户明确的错误提示。

问题3：参数格式错误导致UnexpectedParameter #

这是RDS Data API最容易踩的参数格式坑！你写的parameters: [ { id: req_id }, ]完全不符合AWS SDK的要求。RDS Data API的参数需要明确指定参数名和值的类型（比如字符串用stringValue，数字用longValue），正确的写法应该是：

parameters: [
  {
    name: 'id', // 对应SQL里的`:id`占位符
    value: { 
      stringValue: req_id // 请根据你的user_id字段类型调整，比如数字类型用longValue
    }
  }
]

另外，你代码里还有个笔误：实例化的是const RDS = new AWS.RDSDataService()，但调用时用的是rdsDataService.executeStatement，这里要改成RDS.executeStatement，不然会报rdsDataService is not defined的错误！

最后，你的catch块只打印了错误但没有给客户端返回响应，会导致客户端一直等待，建议在catch里补充错误响应：

catch (error) {
  console.log('Error Received', error);
  callback(null, {
    statusCode: 500,
    body: JSON.stringify({ 
      message: 'Failed to fetch data', 
      error: error.message 
    })
  });
}

修正后的完整Handler代码 #

'use strict';
const AWS = require('aws-sdk');
// 去掉错误的endpoint，让SDK自动解析正确的Data Service地址
const RDS = new AWS.RDSDataService();

module.exports.fetchById = async (event, context, callback) => {
  const req_id = event.pathParameters?.id;
  
  // 主动校验参数
  if (!req_id || req_id.trim() === '') {
    return callback(null, {
      statusCode: 400,
      body: JSON.stringify({ message: 'User ID is required' })
    });
  }

  try {
    const params = {
      resourceArn: 'arn:aws:rds:us-west-2:***********',
      secretArn: 'arn:aws:secretsmanager********',
      sql: `SELECT * FROM user WHERE user_id = :id`,
      database: '*********',
      includeResultMetadata: true,
      parameters: [
        {
          name: 'id',
          value: { stringValue: req_id } // 根据字段类型调整值的类型
        }
      ]
    };
    // 修正笔误，使用正确的实例调用方法
    const db_res = await RDS.executeStatement(params).promise();
    
    // 可选：把Data API返回的结构化records转换成更易读的JSON格式
    const formattedData = db_res.records.map(record => {
      return db_res.columnMetadata.reduce((acc, col, index) => {
        const value = record[index];
        acc[col.name] = Object.values(value)[0];
        return acc;
      }, {});
    });

    const response = {
      statusCode: 200,
      body: JSON.stringify({ 
        message: 'Data fetched!!', 
        data: formattedData 
      })
    };
    callback(null, response);
  } catch (error) {
    console.log('Error Received', error);
    callback(null, {
      statusCode: 500,
      body: JSON.stringify({ 
        message: 'Failed to fetch data', 
        error: error.message 
      })
    });
  }
};

修正后的serverless.yml函数配置 #

functions:
  fetchById: # 建议函数名和handler保持一致，避免混淆
    handler: handler.fetchById
    events:
      - http:
          path: user/{id}
          method: get
          authorizer:
            name: cognito-authorizer
            arn: arn:aws:***********
          request:
            parameters:
              paths:
                id:
                  required: true # 正确的必填参数配置

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