Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
11-13-2024 10:42 AM
To load data from a DataFrame into a Snowflake table with an autoincrement ID column, you can follow these steps:
- First, ensure that your Snowflake table (test1) is created with an autoincrement ID column:
CREATE OR REPLACE TABLE test1 ( ID INT AUTOINCREMENT START 1 INCREMENT 1, c1 VARCHAR, c2 VARCHAR, c3 VARCHAR ); - Then, use the
write_pandasmethod from the Snowflake Connector for Python to load the data from your DataFrame into the Snowflake table. Here's how you can do it:import pandas as pd from snowflake.connector.pandas_tools import write_pandas # Assuming you have already established a connection to Snowflake # and have a cursor object named 'cursor' # Your DataFrame df = pd.DataFrame({ 'c1': ['value1', 'value2', 'value3'], 'c2': ['value4', 'value5', 'value6'], 'c3': ['value7', 'value8', 'value9'] }) # Write the DataFrame to Snowflake success, nchunks, nrows, _ = write_pandas( conn=cursor.connection, df=df, table_name='test1', database='your_database', schema='your_schema' ) if success: print(f"Successfully loaded {nrows} rows into {nchunks} chunks") else: print("Data load failed")