Python用Pandas DataFrame创建Snowflake表时遇仓库选择错误

这个报错的核心是你的Snowflake会话没有指定可用的计算仓库——创建表结构不需要仓库，但写入DataFrame数据时需要仓库执行计算操作，所以会抛出错误，同时只生成空表。下面是三种可行的解决方式：

方法1：在连接字符串中直接指定仓库 #

修改连接字符串，添加仓库参数，一次性完成配置：

account_identifier = '<account_identifier>'
user = '<user_login_name>'
password = '<password>'
database_name = '<database_name>'
schema_name = '<schema_name>'
warehouse_name = '<your_warehouse_name>'  # 替换为你的仓库名称

conn_string = f"snowflake://{user}:{password}@{account_identifier}/{database_name}/{schema_name}?warehouse={warehouse_name}"
engine = create_engine(conn_string)

方法2：建立连接后先执行激活仓库命令 #

在写入数据前，先执行SQL命令指定仓库：

with engine.connect() as con:
    # 先激活目标仓库
    con.execute("USE WAREHOUSE your_warehouse_name;")
    # 再执行数据写入
    df.to_sql(name=table_name.lower(), con=con, if_exists=if_exists, method=pd_writer)

方法3：通过SQLAlchemy的connect_args参数指定仓库 #

创建engine时，用connect_args传入仓库信息：

conn_string = f"snowflake://{user}:{password}@{account_identifier}/{database_name}/{schema_name}"
engine = create_engine(conn_string, connect_args={"warehouse": "<your_warehouse_name>"})

三种方法都能解决会话无激活仓库的问题，推荐用方法1，避免后续重复配置。

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