Azure Function写入Azure SQL表遇500错误，请求排查原因

以下是导致你遇到500错误的核心问题及修复方案：

1. function.json语法错误 #

你的绑定配置存在两处格式问题：

• 第一个httpTrigger节点中，"authLevel": "function"末尾缺少逗号，导致JSON解析失败
• 整个绑定列表未包裹在数组[]中，不符合Azure Functions绑定文件的规范

修正后的function.json：

[
    {
        "authLevel": "function",
        "type": "httpTrigger",
        "direction": "in",
        "name": "req",
        "methods": [
            "post"
        ]
    },
    {
        "type": "http",
        "direction": "out",
        "name": "$return"
    },
    {
        "name": "todoItems",
        "type": "sql",
        "direction": "out",
        "commandText": "dbo.ToDo",
        "connectionStringSetting": "SqlConnectionString"
    }
]

2. 请求体处理逻辑错误 #

你传入的是单个JSON对象，但代码中用map迭代req_body，这会遍历对象的键名而非整个对象，生成无效的SqlRow实例。需要区分单个对象和数组的场景处理。

3. 主键Id未赋值 #

数据库表的Id是UNIQUEIDENTIFIER类型主键，且未设置默认值，插入时必须提供有效值。两种解决方式：

方案A：修改表结构添加默认值 #

ALTER TABLE dbo.ToDo 
ALTER COLUMN Id UNIQUEIDENTIFIER PRIMARY KEY DEFAULT NEWID();

方案B：在代码中生成GUID #

处理请求体时为每个条目添加Id字段值。

4. 异常处理过于松散 #

原代码中except ValueError: pass会掩盖JSON解析失败的异常，无法记录错误细节，不利于排查。需要添加日志记录并返回明确的错误响应。

修正后的init.py代码 #

import logging
import azure.functions as func
import uuid


def main(req: func.HttpRequest, todoItems: func.Out[func.SqlRow]) -> func.HttpResponse:
    logging.info('Python HTTP trigger and SQL output binding function processed a request.')

    req_body = None
    try:
        req_body = req.get_json()
        # 兼容单个对象或数组格式的请求体
        if isinstance(req_body, list):
            for item in req_body:
                item["Id"] = str(uuid.uuid4())
            rows = func.SqlRowList(map(lambda r: func.SqlRow.from_dict(r), req_body))
        else:
            req_body["Id"] = str(uuid.uuid4())
            rows = func.SqlRowList([func.SqlRow.from_dict(req_body)])
    except ValueError as e:
        logging.error(f"JSON解析失败: {str(e)}")
        return func.HttpResponse(
            "请求体格式无效，请传入合法JSON",
            status_code=400
        )

    if req_body:
        try:
            todoItems.set(rows)
            return func.HttpResponse(
                rows.to_json(),
                status_code=200,
                mimetype="application/json"
            )
        except Exception as e:
            logging.error(f"SQL插入失败: {str(e)}")
            return func.HttpResponse(
                f"数据插入错误: {str(e)}",
                status_code=500
            )
    else:
        return func.HttpResponse(
            "无法读取请求体",
            status_code=400
        )

额外排查步骤 #

如果问题仍存在，可通过Azure门户查看函数日志：

• 进入函数应用 → 左侧菜单「监控」→「日志」
• 查看具体的错误堆栈信息，定位细节问题（如连接字符串错误、数据库权限问题等）

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