How to load data from aws s3 to snowflake using External Stage & Python | Snowflake tutorial скачать в хорошем качестве

How to load data from aws s3 to snowflake using External Stage & Python | Snowflake tutorial

A Silly Mistake in function definition. Please Forgive me for that. In the Video , Connection is given as input parameter but conn was used inside the function . Just Corrected it below. Prerequisite: Transfer Data from S3 bucket to Snowflake via pandas | Complete Code & Installation from Scratch    • Transfer Data from S3 bucket to Snowflake ...   Snowflake Code: --drop database if required drop database ramu; --Create Database create database if not exists ramu; --use the database use ramu; --Table Creation create table if not exists video (sepallength number(10,4),sepalwidth number(10,4),petallength number(10,4) , petalwidth number(10,4),classname varchar(200)); --file-format creation create or replace file format my_csv_format type = csv field_delimiter = ',' skip_header = 1 field_optionally_enclosed_by = '"' null_if = ('NULL', 'null') empty_field_as_null = true; --stage creation create or replace stage ramu.PUBLIC.snow_simple url="s3://demoshow" credentials=(aws_key_id='' aws_secret_key='') file_format = my_csv_format; --check the data present in S3 list @ramu.PUBLIC.snow_simple; --Execute the query select * from video; Python Code: import snowflake.connector as sf user="" password="" account=""; database="RAMU" warehouse="COMPUTE_WH" schema="PUBLIC" role="SYSADMIN" conn=sf.connect(user=user,password=password,account=account); def run_query(conn, query): cursor = conn.cursor(); cursor.execute(query); cursor.close(); statement_1='use warehouse '+warehouse; #statement2​='alter warehouse '+warehouse+" resume"; statement3="use database "+database; statement4="use role "+role; run_query(conn,statement_1) #run_query​(conn,statement2) run_query(conn,statement3) run_query(conn,statement4) sql_query="copy into ramu.PUBLIC.video from @ramu.PUBLIC.snow_simple FILE_FORMAT=(FORMAT_NAME=my_csv_format);" run_query(conn,sql_query);