如何在Azure Functions JavaScript v4中传递请求体至Azure SQL存储过程

问题描述 #

使用Azure Functions JavaScript/Node.js v4模型，尝试通过extraInputs的SQL绑定将POST请求的JSON体传递给SQL Server存储过程时，触发参数缺失错误。

现有实现代码 #

SQL输入绑定配置

const sp_location_insert = input.sql({
    commandText: 'dbo.sp_location_insert',
    parameters: '@Body={body}',
    commandType: 'StoredProcedure',
    connectionStringSetting: 'SqlConnectionString',
})

HTTP函数定义

app.http('locationPost', {
    methods: ['POST'],
    authLevel: 'anonymous',
    route: 'location',
    extraInputs: [sp_location_insert],
    handler: async (request, context) => {
        const body = await request.json()
        context.log(`body: ${JSON.stringify(body)}`)
        const response = context.extraInputs.get(sp_location_insert)
        const location_id = response[0]["location_id"]
        return {    
            status: 201,
            body: location_id
        }
    }
})

报错信息 #

Microsoft.Azure.WebJobs.Host: No value for named parameter 'body'.

问题根源 #

extraInputs中的SQL绑定会在handler执行前完成初始化并尝试获取参数值，但请求体需要通过await request.json()异步读取，此时绑定无法获取到body参数的有效内容，导致参数缺失错误。官方提供的默认方案仅支持简单文本请求体，无法适配JSON格式的复杂场景。

解决方案 #

方法一：手动使用mssql库调用存储过程（推荐） #

放弃SQL输入绑定，在handler内自行获取请求体后，通过mssql库直接调用存储过程，这种方式能灵活处理JSON参数，适配复杂场景。

1. 安装依赖包：

npm install mssql

2. 修改函数代码：

const sql = require('mssql');
// 从环境变量读取连接字符串
const connectionString = process.env.SqlConnectionString;

app.http('locationPost', {
    methods: ['POST'],
    authLevel: 'anonymous',
    route: 'location',
    handler: async (request, context) => {
        try {
            // 异步读取JSON请求体
            const requestBody = await request.json();
            context.log(`请求体: ${JSON.stringify(requestBody)}`);

            // 建立SQL连接并调用存储过程
            await sql.connect(connectionString);
            const result = await sql.query`
                EXEC dbo.sp_location_insert @Body = ${JSON.stringify(requestBody)}
            `;

            // 提取存储过程返回的location_id
            const locationId = result.recordset[0].location_id;
            return {
                status: 201,
                body: locationId
            };
        } catch (error) {
            context.error('调用存储过程失败:', error);
            return {
                status: 500,
                body: '内部服务错误'
            };
        } finally {
            // 确保关闭SQL连接
            await sql.close();
        }
    }
})

方法二：适配SQL绑定的替代方案（局限性大） #

若必须使用SQL绑定，需注意extraInputs无法直接获取异步的request body，只能通过将请求体转换为同步可访问的格式（如提前解析为字符串并存入context），但这种方式需要修改绑定逻辑，且仅适用于简单场景，不推荐用于复杂JSON处理。

注意：确保SQL Server存储过程支持接收JSON字符串参数，并在内部使用OPENJSON等函数正确解析JSON内容。

内容的提问来源于stack exchange，提问作者Ross Attrill