Azure Function更新Snowflake报错：HTTP请求无有效JSON数据

一、正确的测试方法与数据输入位置 #

优先用Postman/Azure Function测试工具验证Function，暂不绑定Power App：

• 构造请求URL：需包含schema和table两个查询参数，格式为：

  https://<你的Function域名>/api/<Function名称>?schema=你的Schema名&table=TABLENAME
  

• 设置请求方法为POST，请求体选择raw -> JSON格式，在输入框中填入数组格式的JSON数据（单条更新也要放在数组里），示例：

  [
    {
      "ID": 1,
      "NAME": "更新后的名称",
      "AGE": 30
    }
  ]
  

• 发送请求后，查看返回结果与Azure Portal中Function的监控日志，定位问题。

二、代码中的核心问题分析 #

你的Function代码存在多处语法逻辑错误，这是导致JSON错误与功能失效的主要原因：

• 缩进错误：while (i < len(data))循环后的代码缩进错误，列处理逻辑不在循环内，变量i永远为0，且data格式异常时直接抛出未捕获的错误。
• 未捕获JSON解析异常：req.get_json()若遇到非法JSON会直接抛出异常，代码未处理该异常，导致返回错误的成功响应。
• SQL拼接逻辑错误：列循环缩进错误导致只拼接第一个字段，逗号位置错误生成无效SQL；直接拼接字符串值存在SQL注入风险，特殊字符（如单引号）会导致SQL执行失败。
• 错误的响应逻辑：finally块中无论是否异常都返回成功响应，无法正确反馈错误信息。

三、修正后的Function代码 #

import logging
import azure.functions as func
import snowflake.connector
import simplejson as json

func.HttpResponse.mimetype = 'application/json'
func.HttpResponse.charset = 'utf-8'

def get_connection():
    return snowflake.connector.connect(
        user='user@domain.com', 
        password='password', 
        account='account.account.azure', 
        warehouse='WAREHOUSE_NAME'
    )

def main(req: func.HttpRequest) -> func.HttpResponse:
    logger = logging.getLogger('azure')
    logger.setLevel(logging.ERROR)
    logging.info('Python HTTP trigger function processed a request.') 

    # 获取查询参数
    table = req.params.get('table')
    schema = req.params.get('schema')
    
    # 校验必填参数
    if not (schema and table):
        response = {"Message": "缺少schema或table参数", "Status Code": 400}
        return func.HttpResponse(json.dumps(response), status_code=400)

    try:
        # 解析JSON请求体，捕获解析异常
        data = req.get_json()
        if not isinstance(data, list):
            response = {"Message": "请求体必须是数组格式", "Status Code": 400}
            return func.HttpResponse(json.dumps(response), status_code=400)

        # 建立Snowflake连接
        ctx = get_connection()
        cursor = ctx.cursor()

        if table == "TABLENAME":
            for item in data:
                # 确保ID字段存在
                if 'ID' not in item:
                    response = {"Message": "每条数据必须包含ID字段", "Status Code": 400}
                    return func.HttpResponse(json.dumps(response), status_code=400)
                
                # 提取除ID外的更新字段
                update_fields = [k for k in item.keys() if k != 'ID']
                if not update_fields:
                    response = {"Message": "没有需要更新的字段", "Status Code": 400}
                    return func.HttpResponse(json.dumps(response), status_code=400)
                
                # 构建参数化SQL，避免SQL注入
                set_clause = ", ".join([f"{field} = %s" for field in update_fields])
                query = f"UPDATE DATABASE.{schema}.TABLENAME SET {set_clause} WHERE ID = %s"
                
                # 准备参数值
                values = [item[field] for field in update_fields]
                values.append(item['ID'])
                
                logging.info(f"执行SQL: {query}")
                cursor.execute(query, values)
            # 提交事务确保更新生效
            ctx.commit()
            response = {"Message": "更新成功", "Status Code": 200}
            return func.HttpResponse(json.dumps(response), status_code=200)
        else:
            response = {"Message": "不支持的表名", "Status Code": 400}
            return func.HttpResponse(json.dumps(response), status_code=400)

    except json.JSONDecodeError:
        response = {"Message": "HTTP请求不包含有效的JSON数据", "Status Code": 400}
        return func.HttpResponse(json.dumps(response), status_code=400)
    except Exception as e:
        logging.error(f"执行错误: {str(e)}")
        response = {"Message": f"更新失败: {str(e)}", "Status Code": 500}
        return func.HttpResponse(json.dumps(response), status_code=500)
    finally:
        # 确保连接关闭
        if 'cursor' in locals():
            cursor.close()
        if 'ctx' in locals():
            ctx.close()

四、关键优化点说明 #

• 异常捕获：新增JSON解析异常捕获，明确返回"无效JSON"错误，便于排查。
• 参数化SQL：使用%s占位符拼接SQL，避免SQL注入，自动处理特殊字符转义。
• 逻辑校验：增加请求体格式、ID字段、更新字段的前置校验，提前返回错误。
• 事务提交：添加ctx.commit()确保Snowflake更新生效。
• 正确响应：根据场景返回对应状态码和错误信息，方便Power App端处理。

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