`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?