如何创建一个lambda函数来获得mysql池连接并将其提供给其他lambda函数?

wvt8vs2t  于 2021-06-25  发布在  Mysql
关注(0)|答案(1)|浏览(315)

我在node.js中有十几个lambda函数,它们主要用于mysql数据库查询。
目前,我正在这些函数中打开和关闭与数据库的连接。
有没有可能有一个函数只创建连接(最好是池连接)并将其提供给其他函数?
另外,我使用参数存储来存储我的秘密。我现在要做的是:

const AWS = require('aws-sdk');
var mysql = require('mysql');
var ssm = new AWS.SSM({ apiVersion: '2014-11-06' });

exports.handler = (event, context, callback) => {

    var databaseName;
    var databaseHost;
    var databaseUser;
    var databasePassword;

    var params = {
        Names: ['/databaseName', '/databaseHost', '/databaseUser', '/databasePassword'],
        WithDecryption: true
    };

    ssm.getParameters(params, function (err, data) {
        if (err) {
            callback(err);
        } else {
            var parameters = data.Parameters;
            parameters.forEach(function (value) {
                switch (value.Name) {
                case "/databaseName":
                    databaseName = value.Value;
                    break;
                case "/databaseHost":
                    databaseHost = value.Value;
                    break;
                case "/databaseUser":
                    databaseUser = value.Value;
                    break;
                case "/databasePassword":
                    databasePassword = value.Value;
                    break;
                }
            });

            var pool = mysql.createPool({
                host: databaseHost,
                user: databaseUser,
                password: databasePassword,
                database: databaseName,
                connectionLimit: 20
            });

            pool.getConnection(function (err, connection) {
                if (err) {
                    callback(err);
                } else {
                    var sql = "...";
                    var inserts = [...];

                    connection.query(sql, inserts, function (error, results, fields) {

                        connection.release();

                        if (error) {
                            callback(error);
                        } else {
                            callback(null, results);
                        }
                    });
                }
            });

        }
    });
};

我希望数据库连接位于单独的lambda函数中,并提供池连接,而无需每次调用该函数时打开和关闭连接。

wnrlj8wa

wnrlj8wa1#

当谈到aws lambda函数时,在设计解决方案之前,应该记住这些要点
函数的执行发生在它们自己的沙盒容器中
执行环境没有必要一直熬夜
因此,从第一点,我们可以得出结论,资源不能在两个函数之间共享,甚至同一个函数的两个执行也不能共享,从第二点,我们可以得出这样的结论:即使您创建了一个连接池(我不建议这样做),当该容器停止服务任何请求时,它也会被销毁。

相关问题