airflow.contrib.hooks.snowflake_hook

Module Contents

class airflow.contrib.hooks.snowflake_hook.SnowflakeHook(*args, **kwargs)[source]

Bases: airflow.hooks.dbapi_hook.DbApiHook

Interact with Snowflake.

get_sqlalchemy_engine() depends on snowflake-sqlalchemy

conn_name_attr = snowflake_conn_id[source]
default_conn_name = snowflake_default[source]
supports_autocommit = True[source]
_get_conn_params(self)[source]

one method to fetch connection params as a dict used in get_uri() and get_connection()

get_uri(self)[source]

override DbApiHook get_uri method for get_sqlalchemy_engine()

get_conn(self)[source]

Returns a snowflake.connection object

_get_aws_credentials(self)[source]

returns aws_access_key_id, aws_secret_access_key from extra

intended to be used by external import and export statements

set_autocommit(self, conn, autocommit)[source]

Was this entry helpful?