这里是一些示例样板,其中 cmets 用于从 Lambda 连接到 MS SQL Server 数据库(假设使用 NodeJS 作为您的语言)。
const sql = require('mssql');
exports.handler = async (event, context, callback) => {
let lookupValue = event.lookupValue;
// Take DB Config from environment variables set in Lambda config
const config = {
user: process.env.DB_USERNAME,
password: process.env.DB_PASSWORD,
server: process.env.DB_SERVER,
database: process.env.DB_DATABASE,
options: {
encrypt: true // Use this if you're on Windows Azure
}
}
try {
// Open DB Connection
let pool = await sql.connect(config)
// Query Database
let result = await pool.request()
.input('lookupValue', sql.Int, lookupValue)
.query('select * from exampleTable where id = @lookupValue');
// Close DB Connection
pool.close();
// The results of our query
console.log("Results:", result.recordset);
// Use callback if you need to return values from your lambda function.
// Callback takes (error, response?) as params.
callback(null, result.recordset);
} catch (err) {
// Error running our SQL Query
console.error("ERROR: Exception thrown running SQL", err);
}
sql.on('error', err => console.error(err, "ERROR: Error raised in MSSQL utility"));
}
注意:您需要将运行 mssql 所需的 node_modules 上传到您的函数。我发现执行此操作的最简单方法是压缩整个文件夹(您的主 [通常是 index.js] 函数文件,以及 package.json 和您的 node_modules 文件夹),然后使用 aws-cli 上传它:
aws lambda update-function-code --function-name your-function-name-here --zip-file your-zipped-project-directory.zip
最后,确保您的数据库能够接受来自 AWS Lambda 函数的连接。最好的方法是结合使用 AWS 的 VPC、NAT 和弹性 IP 设置 - 此博客文章中描述了其中的示例:https://medium.com/@matthewleak/aws-lambda-functions-with-a-static-ip-89a3ada0b471