:mod:`airflow.contrib.hooks.snowflake_hook` =========================================== .. py:module:: airflow.contrib.hooks.snowflake_hook Module Contents --------------- .. py:class:: SnowflakeHook(*args, **kwargs) Bases: :class:`airflow.hooks.dbapi_hook.DbApiHook` Interact with Snowflake. get_sqlalchemy_engine() depends on snowflake-sqlalchemy .. attribute:: conn_name_attr :annotation: = snowflake_conn_id .. attribute:: default_conn_name :annotation: = snowflake_default .. attribute:: supports_autocommit :annotation: = True .. method:: _get_conn_params(self) one method to fetch connection params as a dict used in get_uri() and get_connection() .. method:: get_uri(self) override DbApiHook get_uri method for get_sqlalchemy_engine() .. method:: get_conn(self) Returns a snowflake.connection object .. method:: _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 .. method:: set_autocommit(self, conn, autocommit)