问题描述
我正在尝试通过 Node.js 函数访问 Azure Synapse sql 池。我以此 article 作为基础并将身份验证方法切换为“azure-active-directory-msi-app-service”。
如果我运行该函数,我可以在函数 cmd 中看到 quertyText context.log,但不幸的是没有其他任何事情发生。它在没有任何输出的情况下运行。
我看不到任何其他 context.log 或从该函数获得任何响应。
const Request = require('tedious').Request;
const TYPES = require('tedious').TYPES;
const test = require('lodash')
module.exports = function (context,req) {
//get the Query Parameter
// Create connection to database
const config = {
authentication: {
type: "azure-active-directory-msi-app-service"
},server: "database.sql.azuresynapse.net",options: {
database: "database",encrypt: true,port: 1433
}
};
const connection = new Connection(config);
// Create array to store the query results
let result = [];
let rowData = {};
// req.query.color will be passed as a Query variable in the URL
//const payload = [req.query.color];
// Create query to execute against the database
const queryText = "SELECT TOP (10) [id],[column1],[culomn2] FROM [dbo].[Table]";
context.log(queryText);
// Create Request object
request = new Request(queryText,function(err) {
context.log("Request")
if (err) {
// Error in executing query
context.log.error(err);
context.res.status = 500;
context.res.body = "Error executing the query";
} else {
context.res = {
status: 200,isRaw: true,body: result,headers: {
'Content-Type': 'application/json'
}
}
}
context.done();
});
// Manipulate the results and create JSON
request.on('row',function(columns) {
rowData = {};
columns.forEach(function(column) {
// IMPORTANT: Change the conversion logic here to adjust JSON format
rowData[column.Metadata.colName] = column.value;
});
result.push(rowData);
});
connection.on('connect',function(err) {
if (err) {
// Error in connecting
context.log.error(err);
context.res.status = 500;
context.res.body = "Error connecting to Azure Synapase";
context.done();
} else {
// Connection succeeded
connection.execsql(request);
}
});
}```
解决方法
这应该有效...
const Connection = require('tedious').Connection;
const Request = require('tedious').Request;
const TYPES = require('tedious').TYPES;
const config = {
server: "SQL pool endpoint goes here",authentication: {
type: "azure-active-directory-msi-app-service"
},options: {
encrypt: true,database: "pool name goes here",port: 1433
}
}
var connection = new Connection(config);
这假设您已将托管标识适当地分配为 SQL 池中的外部用户。我也有此更改的 PR,您可以跟踪 here