airflow.providers.amazon.aws.hooks.athena_sql
¶
Module Contents¶
Classes¶
Interact with Amazon Athena. |
- class airflow.providers.amazon.aws.hooks.athena_sql.AthenaSQLHook(athena_conn_id=default_conn_name, *args, **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
,airflow.providers.common.sql.hooks.sql.DbApiHook
Interact with Amazon Athena.
Provide wrapper around PyAthena library.
- Parameters
athena_conn_id (str) – Amazon Athena Connection.
Additional arguments (such as
aws_conn_id
) may be specified and are passed down to the underlying AwsBaseHook.You can specify
driver
inextra
of your connection in order to use a different driver than the defaultrest
.Also, aws_domain could be specified in
extra
of your connection.PyAthena and AWS Authentication parameters could be passed in extra field of
athena_conn_id
connection.Passing authentication parameters in
athena_conn_id
will override those inaws_conn_id
.See also
Note
get_uri() depends on SQLAlchemy and PyAthena.
- property conn: airflow.providers.amazon.aws.utils.connection_wrapper.AwsConnectionWrapper[source]¶
Get Aws Connection Wrapper object.