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.