使用Python Connector无法向Snowflake表插入数据问题求助

我得先拆解你遇到的核心问题：明明在Snowflake控制台能正常执行的INSERT语句，放到Python的snowflake-connector里就报错，而且当前的错误捕获只返回模糊提示，根本没法定位具体问题。下面是我整理的几个高频原因和对应解决办法：

1. 事务未提交（最常见的坑） #

Snowflake的Python连接器默认不会自动提交事务，但控制台执行语句是自动提交的。如果Python里不手动触发提交，插入操作会被挂起，最终回滚，看起来就像没执行成功。

解决方法：
两种方式任选其一：

# 方式一：手动提交事务
snowcursor.execute(db_query)
snowconn.commit()  # 执行完INSERT后必须加这行

# 方式二：创建连接时开启自动提交
snowconn = snowflake.connector.connect(
    user='<username>',
    password='<password>',
    account='<locator>',
    autocommit=True  # 新增这个参数，后续执行语句自动提交
)

2. 错误捕获太宽泛，看不到具体报错信息 #

你现在的except块直接返回模糊的"error in inserting data"，完全不知道是语法错误、数据类型不匹配还是权限问题。这会让你彻底失去排查方向。

解决方法：
修改异常捕获逻辑，打印具体错误详情：

try:
    print(name, id, align, eye, hair, sex, alive, appearances, first_appearance[0], year)
    db_query = ("insert into SUPERHERO values('Spider-Man (Peter Parker)', 'Secret Identity', 'Good Characters', 'Hazel Eyes', 'Brown Hair', 'Male', 'Living', 4043.0, 'Aug-62', 1962.0);")
    snowcursor.execute(db_query)
    snowconn.commit()  # 别忘了提交
    return 'success'
except Exception as e:
    print(f"插入错误详情: {str(e)}")  # 打印具体错误信息
    return f'error in inserting data: {str(e)}'

这样你就能看到比如「数据类型不匹配」「字段顺序不符」「权限不足」等具体问题，精准定位根源。

3. 数据类型/字段顺序不匹配 #

虽然控制台能执行，但要确认Python里的语句是否和表结构完全对齐：比如表的字段顺序、数据类型（比如appearances是不是NUMERIC类型，year是不是FLOAT/INT）。

验证方法：
在Snowflake控制台执行DESCRIBE TABLE SUPERHERO;，对比字段顺序、类型和你INSERT语句里的值是否完全匹配。

4. 连接器版本兼容性问题 #

旧版本的snowflake-connector-python可能存在一些隐性bug，建议升级到最新版：

pip install --upgrade snowflake-connector-python

优化后的完整示例函数 #

这里给你调整后的函数，包含自动提交、详细错误捕获，还改用了更安全的参数化查询：

def insert_data(name, id, align, eye, hair, sex, alive, appearances, first_appearance, year):
    try:
        snowconn = snowflake.connector.connect(
            user='<username>',
            password='<password>',
            account='<locator>',
            autocommit=True  # 开启自动提交
        )
        snowcursor = snowconn.cursor()
    except Exception as e:
        return f'Error in connecting: {str(e)}'
    
    try:
        snowcursor.execute("use role ACCOUNTADMIN;")
        snowcursor.execute("use database DATA_INGESTION;")
        snowcursor.execute("use schema INGESTION_SCH;")
    except Exception as e:
        return f'error in roles/db/schema: {str(e)}'
    
    try:
        print(name, id, align, eye, hair, sex, alive, appearances, first_appearance[0], year)
        # 用参数化查询，避免SQL注入，也能自动处理字符串转义
        db_query = """
            INSERT INTO SUPERHERO 
            VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
        """
        snowcursor.execute(db_query, (
            'Spider-Man (Peter Parker)', 
            'Secret Identity', 
            'Good Characters', 
            'Hazel Eyes', 
            'Brown Hair', 
            'Male', 
            'Living', 
            4043.0, 
            'Aug-62', 
            1962.0
        ))
        return 'success'
    except Exception as e:
        print(f"插入错误详情: {str(e)}")
        return f'error in inserting data: {str(e)}'
    finally:
        # 确保关闭游标和连接，避免资源泄漏
        snowcursor.close()
        snowconn.close()

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