Snowpark无法追加Pandas DataFrame至Snowflake表的问题求助

问题原因 #

你遇到的报错源于未提交的事务冲突：

• 之前执行的session.table(...).filter(...).to_pandas()等查询操作，在AUTOCOMMIT=false的会话环境下会自动开启未提交事务。
• 默认的write_pandas追加模式（overwrite=False）会尝试在该现有事务内执行，但Snowflake存储过程不允许存在未完成的事务，因此触发回滚报错。
• 而overwrite=True时，操作会先删除原表再重建，这个过程会隐式提交现有事务，所以能正常执行。

解决方案 #

以下三种方法任选其一即可解决问题：

1. 手动提交未完成事务

在调用write_pandas前，先提交之前查询开启的事务：

# 提交当前未完成的事务
session.sql("COMMIT;").collect()

# 执行追加写入
session.write_pandas(df=my_df, table_name='MY_TABLE_NAME')

2. 修改会话级AUTOCOMMIT为true

通过SQL语句临时修改当前会话的自动提交设置，后续所有操作都会自动提交事务：

# 设置会话自动提交为true
session.sql("ALTER SESSION SET AUTOCOMMIT = TRUE;").collect()

# 执行追加写入
session.write_pandas(df=my_df, table_name='MY_TABLE_NAME')

3. 给write_pandas指定auto_commit参数

直接在write_pandas调用中强制开启自动提交，忽略会话的AUTOCOMMIT设置：

session.write_pandas(df=my_df, table_name='MY_TABLE_NAME', auto_commit=True)

验证方法 #

可以在执行写入前检查是否存在未提交事务：

# 查看当前是否有活跃事务
session.sql("SELECT CURRENT_TRANSACTION();").show()

如果返回结果非NULL，说明存在未提交事务，提交后再执行写入即可。

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