-
Notifications
You must be signed in to change notification settings - Fork 0
Python Snowflake Process
ArunGMR0411 edited this page Jun 6, 2023
·
3 revisions
- pd.read_sql(query, connection)
- snowflake_obj.fetch_pandas_all("query") Here, a. snowflake_obj is Object created for the Snowflake Class which has made connection to Snowflake. b. fetch_pandas_all is the function to execute the select statement passed as argument and provide us back the resultset as Pandas Dataframe. This is 6x faster than the normal pd.read_sql_query() function.
- write_pandas() -> This Function can be used to write our pandas df into snowflake table that we specify.