从 Azure Functions in JS 连接到 Azure SQL DB

Question

我正在尝试从用nodeJS编写的Azure函数连接到我的Azure SQL DB。我已经在应用程序设置中设置了连接字符串，但它仍然不起作用。我使用 ODBC 密钥进行连接设置。有人试过这个吗？下面是我的函数的示例代码

var Connection = require('tedious').Connection;
var Request = require('tedious').Request;
// Create connection to database
const config = process.env["sqldb_connection"];
var connection = new Connection(config);
// Attempt to connect and execute queries if connection goes through
connection.on('connect', function(err)
{
if (err)
{
console.log(err)
}
else
{
queryDatabase()
}
}
);
function queryDatabase()
{ console.log('Reading rows from the Table...');
// Read all rows from table
request = new Request(
"SELECT ORG_ID,ORG_NAME FROM org",
function(err, rowCount, rows)
{
console.log(rowCount + ' row(s) returned');
process.exit();
}
);
request.on('row', function(columns) {
columns.forEach(function(column) {
console.log("%st%s", column.metadata.colName, column.value);
});
});
connection.execSql(request);
}

我收到一条错误消息，说

Exception while executing function: Functions.HttpTriggerJS2. mscorlib: The given key was not present in the dictionary.

Answer 1

1. 在Kudu 远程执行控制台的D:homesitewwwroot下运行npm install tedious命令。

2. 在 Azure 函数中，所有代码都应放在module.exports函数中。

3. 您应该使用context.log()而不是console.log()。

4. 您实际上不必在函数的应用程序设置中设置连接设置字符串。

5. 您应该通过调用context.done()来通知运行时代码何时完成。

以下代码对我有用：

var Connection = require('tedious').Connection;
var Request = require('tedious').Request;
module.exports = function (context, req) {
context.log('JavaScript HTTP trigger function processed a request.');
var config = {
userName: '<userName>',
password: '<password>',
server: '<AzureSQLDBName>.database.windows.net',
// If you're on Windows Azure, you will need this:
options:
{
database: 'your DB',
encrypt: true
}
};
var connection = new Connection(config);
connection.on('connect', function(err) {
if (err) {
context.log(err);
context.res = {
status: 500,
body: "Unable to establish a connection."
};
context.done();
} else {
executeStatement();
}
});
function executeStatement() {
request = new Request("select 42, 'hello world'", function(err, rowCount) {
if (err) {
context.log(err);
context.res = {
status: 500,
body: "Failed to connect to execute statement."
};
context.done();
} else {
context.log(rowCount + ' rows');
}
});
request.on('row', function(columns) {
columns.forEach(function(column) {
context.log(column.value);
});
context.done();
});
connection.execSql(request);
}
};

有关详细信息，请参阅 Azure Functions JavaScript 开发人员指南。