AWS Lambda插入数据正常但无法发送SNS且超时问题求助

看起来你的Lambda函数遇到了超时+SNS发送失败的双重问题，我帮你拆解下核心原因，再给出具体的修复步骤：

核心问题：异步流程混乱+资源未正确释放 #

你的代码能正常插入数据，但会超时，主要是两个关键问题：

1. 数据库连接没关闭：你打开了RDS连接后，没有主动关闭，Lambda会一直持有这个连接，直到达到30秒的默认超时上限。
2. 异步操作未串联：SNS的publish是异步调用，但你没有把它和Lambda的结束回调关联起来，加上之前直接把Lambda的callback传给了数据库查询，导致函数提前触发回调，但实际还有操作在后台跑，最终超时。
   另外，你定义的用户存在校验逻辑根本没执行——只是写了input.test.validate函数，但从来没调用它，你之前觉得校验正常可能是巧合？

具体修复步骤 #

1. 重构异步流程，串联所有操作 #

把「参数校验→用户存在校验→插入数据→发送SNS→关闭连接→触发Lambda回调」改成串行的异步流程，确保每一步完成后再执行下一步，并且及时释放资源：

'use strict';
var AWS = require("aws-sdk");
var mysql = require("mysql");

// 把RDS配置抽出来，建议存在Lambda环境变量里，不要硬编码
var rdsConfig = {
  host: process.env.RDS_HOST,
  user: process.env.RDS_USER,
  password: process.env.RDS_PASSWORD,
  database: process.env.RDS_DB_NAME
};

exports.handler = function (event, context, callback) {
  // 先做参数校验
  if (!event.type || !event.username || event.username.trim() === "") {
    console.log("Missing required fields: username or type");
    return callback(null, { 
      level: "error", 
      message: "Missing required fields: username or type" 
    });
  }

  // 创建数据库连接
  const conn = mysql.createConnection(rdsConfig);

  conn.connect(err => {
    if (err) {
      console.error("Failed to connect to RDS:", err);
      conn.end(); // 连接失败也要关闭
      return callback(null, { 
        level: "error", 
        message: `DB connection failed: ${err.message}` 
      });
    }

    // 第一步：校验用户是否已存在（终于调用你的校验逻辑了！）
    const checkUserQuery = `SELECT * FROM users WHERE user_id = ?`;
    conn.query(checkUserQuery, [event.username], (err, rows) => {
      if (err) {
        console.error("Check user failed:", err);
        conn.end();
        return callback(null, { 
          level: "error", 
          message: `Check user failed: ${err.message}` 
        });
      }

      if (rows && rows.length > 0) {
        console.log(`User ${event.username} already exists`);
        conn.end();
        return callback(null, { 
          level: "error", 
          message: `User ${event.username} already exists` 
        });
      }

      // 第二步：插入新用户（用参数化查询防SQL注入！）
      const insertUserQuery = `INSERT INTO users(user_id, Type, Reason) VALUES (?, ?, ?)`;
      const insertParams = [event.username, event.type, event.reason || ""];
      
      conn.query(insertUserQuery, insertParams, (err, result) => {
        if (err) {
          console.error("Insert user failed:", err);
          conn.end();
          return callback(null, { 
            level: "error", 
            message: `Insert user failed: ${err.message}` 
          });
        }

        console.log(`User ${event.username} added successfully`);
        conn.end(); // 插入完成立即关闭DB连接

        // 第三步：发送SNS通知
        const sns = new AWS.SNS({ region: "us-east-1" });
        sns.publish({
          Message: `New user added: ${event.username}, type: ${event.type}`,
          TopicArn: "你的SNS Topic ARN" // 确保这个ARN正确
        }, (err, snsResult) => {
          if (err) {
            console.error("SNS publish failed:", err);
            return callback(null, {
              level: "info",
              message: `User ${event.username} added, but SNS notification failed`,
              snsError: err.message
            });
          }

          console.log("SNS publish successful:", snsResult);
          callback(null, {
            level: "info",
            message: `User ${event.username} added, SNS notification sent successfully`,
            snsData: snsResult
          });
        });
      });
    });
  });
};

2. 修复SNS权限问题 #

• 删掉硬编码的密钥：Lambda不需要手动写accessKeyId和secretAccessKey，你需要给Lambda的执行角色添加「允许发布到指定SNS Topic」的权限（可以用AmazonSNSFullAccess或者更精细的自定义权限），AWS SDK会自动从Lambda的执行角色获取凭证。
• 确认SNS Topic的ARN是正确的，并且Topic所在区域和代码里的region（这里是us-east-1）完全一致。

3. 调整Lambda配置 #

• 可以适当调整Lambda的超时时间（比如改成10秒），但只要修复了异步流程，正常情况下这些操作不会超过几秒。
• 可以把内存调高到256MB，Lambda的CPU性能和内存成正比，内存越高执行速度越快，反而可能降低计费（因为计费按内存×时间计算）。

额外优化建议 #

• 用参数化查询代替字符串拼接SQL，彻底避免SQL注入风险（原代码直接把event参数拼到SQL里，非常危险）。
• 可以改用mysql2库的Promise版本，配合async/await来写代码，避免回调地狱，可读性更好。
• 把敏感配置（比如RDS的账号密码）存在Lambda的环境变量里，不要硬编码在代码中。

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