| :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) |
| |
| |
| |
| |
