如何安装snowflake.connector.pandas_tools并使用write_pandas写入DataFrame？解决报错

一、正确安装依赖 #

不要单独安装pandas_tools，它是snowflake-connector-python的内置组件，需安装包含pandas支持的完整版本：

1. 先卸载现有版本（避免冲突）：

   pip uninstall -y snowflake-connector-python
   

2. 安装带pandas依赖的connector：

   pip install "snowflake-connector-python[pandas]"
   

   若使用Anaconda环境，先激活目标环境再执行上述命令，也可通过conda安装：

   conda activate 你的环境名
   conda install -c conda-forge snowflake-connector-python pandas
   

二、版本适配的导入方式 #

write_pandas的导入路径随connector版本变化：

• 查看当前版本：

  import snowflake.connector
  print(snowflake.connector.__version__)
  

• 版本≥2.4.0：使用新路径导入

  from snowflake.connector.pandas_tools import write_pandas
  

• 版本<2.4.0：使用旧路径导入

  from snowflake.connector import write_pandas
  

三、write_pandas使用示例 #

import pandas as pd
from snowflake.connector.pandas_tools import write_pandas
import snowflake.connector

# 建立Snowflake连接
conn = snowflake.connector.connect(
    user='你的用户名',
    password='你的密码',
    account='你的账户标识（如xxx.us-west-2）',
    warehouse='你的仓库名',
    database='目标数据库',
    schema='目标模式'
)

# 示例DataFrame
df = pd.DataFrame({
    'ID': [1, 2, 3],
    'USER_NAME': ['Alice', 'Bob', 'Charlie']
})

# 写入数据到Snowflake表
success, _, nrows, _ = write_pandas(
    conn=conn,
    df=df,
    table_name='目标表名',
    schema='目标模式（可选，若已在连接中指定可省略）'
)

conn.close()
print(f"写入状态：{'成功' if success else '失败'}，共写入{nrows}行")

四、排查要点 #

• 确认操作的Python环境与运行代码的环境一致：用where python（Windows）或which python（Linux/macOS）查看当前Python路径，再用pip list检查snowflake-connector-python的安装情况。
• 若仍报错，清理缓存后重新安装：

  pip cache purge
  pip install --force-reinstall "snowflake-connector-python[pandas]"
  

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