Snowflake
Configuration
The Snowflake configurations are:
user: the username to your Snowflake accountpassword: the password to your Snowflake accountaccount: the account name for your Snowflake accountrole: the desired role for the connectionwarehouse: the desired warehouse for the connectiondatabase: the desired database for the connectionschema: the desired schema for the connection
<profile name here>: # change this!
adapters:
<snowflake adapter name here>: # change this!
type: snowflake
user:
password:
account:
role:
warehouse:
database:
schema:
Under the hood, Prism takes care of parsing the configuration variables and establishing a connection to your Snowflake account.
hooks.sql()
hooks.sql()You can run queries against the Snowflake connection using the hooks.sql function:
def run(self, tasks, hooks):
data = hooks.sql(
adapter_name="<snowflake adapter name>",
query="SELECT * FROM table"
)Note that when return_type = None, the result will be a list tuples containing the query data.