airflow.providers.amazon.aws.hooks.redshift_sql
¶
Module Contents¶
Classes¶
Execute statements against Amazon Redshift, using redshift_connector |
- class airflow.providers.amazon.aws.hooks.redshift_sql.RedshiftSQLHook(*args, schema=None, log_sql=True, **kwargs)[source]¶
Bases:
airflow.providers.common.sql.hooks.sql.DbApiHook
Execute statements against Amazon Redshift, using redshift_connector
This hook requires the redshift_conn_id connection.
- Parameters
redshift_conn_id – reference to Amazon Redshift connection id
Note
get_sqlalchemy_engine() and get_uri() depend on sqlalchemy-amazon-redshift
- get_uri(self)[source]¶
Overrides DbApiHook get_uri to use redshift_connector sqlalchemy dialect as driver name
- get_sqlalchemy_engine(self, engine_kwargs=None)[source]¶
Overrides DbApiHook get_sqlalchemy_engine to pass redshift_connector specific kwargs