PandasのDataFrameをSnowflakeに書き込む方法

事前準備

Pythonライブラリのインストール

snowflakeのPython用コネクタAPIは「snowflake-connector-python」という名前で公開されています。
pandasへの互換性をもたせる場合は次のように[pandas]を付けてインストールします。
pip install "snowflake-connector-python[pandas]"

実装例

テーブルへDataFrameを書き込むためのスクリプトの例を以下に示しています。

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

# DataFrameの作成
df = pd.read_csv('table.csv')

# Snowflakeへの接続
conn = snowflake.connector.connect(
    user='USER',
    password='PASSWORD',
    account='ACCOUNT',
    database='DATABASE',
    schema='SCHEMA'
)

# TABLEへのDataFrameの書き込み
success, nchunks, nrows, output = write_pandas(
    conn=conn,
    df=df,
    table_name='TABLE'
)​

DataFrameの作成

この例では、最初にcsvを読み込んで作成したDataFrameをdfという変数に保存しています。
もちろん、DataFrameの作成方法は自由です。ただし、カラムの型や値の欠損がテーブルの定義と矛盾しないように注意しましょう。

Snowflakeへの接続

この例では、パスワード認証により接続しています。
他の認証方法での接続など詳しくは以下をご確認ください。

https://docs.snowflake.com/ja/user-guide/python-connector-api.html#connect