airflow.contrib.hooks.snowflake_hook

Module Contents

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

Bases: airflow.hooks.dbapi_hook.DbApiHook

Interact with Snowflake.

get_sqlalchemy_engine() depends on snowflake-sqlalchemy

conn_name_attr = snowflake_conn_id

default_conn_name = snowflake_default

supports_autocommit = True

_get_conn_params(self)

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

get_uri(self)

override DbApiHook get_uri method for get_sqlalchemy_engine()

get_conn(self)

Returns a snowflake.connection object

_get_aws_credentials(self)

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)