airflow.providers.amazon.aws.hooks.athena_sql¶

类¶

与 Amazon Athena 交互。

class airflow.providers.amazon.aws.hooks.athena_sql.AthenaSQLHook(athena_conn_id=default_conn_name, *args, **kwargs)[源代码]¶

与 Amazon Athena 交互。

提供 PyAthena 库的包装器。

可以指定附加参数（例如 aws_conn_id），这些参数将向下传递到底层的 AwsBaseHook。

您可以在连接的 extra 中指定 driver，以便使用与默认 rest 不同的驱动程序。

此外，可以在连接的 extra 中指定 aws_domain。

PyAthena 和 AWS 身份验证参数可以在 athena_conn_id 连接的 extra 字段中传递。

在 athena_conn_id 中传递身份验证参数将覆盖 aws_conn_id 中的参数。

另请参阅

注意

get_uri() 依赖于 SQLAlchemy 和 PyAthena。

classmethod get_ui_field_behaviour()[源代码]¶

返回 AWS Athena 连接的自定义 UI 字段行为。

获取 Airflow 连接对象并将其包装在帮助器中（已缓存）。

获取 Aws 连接包装器对象。

覆盖以使用 Athena 方言作为驱动程序名称。

获取一个 pyathena.Connection 对象。