RDS 触发器的 Lambda 函数访问导致连接丢失

Question

我在 RDS aurora 中创建了 2 个表：

1. test-table 在极光数据库中，值为 id(PK)、tasknumber、status、contactid(FK)
2. contact-table 在同一个数据库中，值为 contactid(PK)、电子邮件、电话

我在“测试表”中创建了一个触发器，每当“状态”发生变化时，触发器都应该调用 AWS-Lambda ARN。

Lambda 函数和 Aurora 具有所有权限，并且已清除安全性，但仍在从 Lambda 进行测试时出现以下图像错误，并在 aurora 中手动更新“状态”字段（通过 Workbench Sql 查询），它显示：

操作失败：将 SQL 脚本应用到数据库时出错。

ERROR 2013: 2013: 在查询期间丢失与 MySQL 服务器的连接

我也附上了我的 Lambda Node.Js 代码。

var AWS = require('aws-sdk');
AWS.config.update({ region: 'us-east-1' });
const mysql = require('mysql');

var con = mysql.createConnection({

  host: 'correct value',
  user: 'root',
  password: 'correct value',
  port: correct value,
  database: 'correct value'

});
exports.handler = (event, context, callback) => {
  context.callbackWaitsForEmptyEventLoop = false;
  var fk = event.contact_id;
  console.log('FOREIGN KEY=', fk)

  con.connect(function(err) {
    if (err) throw err;
    var sql = `SELECT * FROM db.contacts where contact_id=${fk}`

    con.query(sql, function(err, result) {
     if (err) throw err;
     var email = result[0].email;
     console.log(email);

     var sns = new AWS.SNS();
    var params = {
     Message: email,
      Subject: "Test SNS From Lambda",
     TopicArn: "arn:correct value"
   };

      sns.publish(params, function(err, data) {
        if (err) console.log(err, err.stack); 
        else {
          console.log(data);
          callback(null, 'Success');
        }
      });

    });
  });
};

• Image1ErrorMySqlWorkbench
• Image2ErrorLambdaaws

同样适用于 NodeJs 包：https://github.com/isaacs

Answer 1

如果你想要即时响应，你必须关闭连接，否则关闭连接需要默认时间，如果有意义请告诉我