`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 之外的其他驱动程序。

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

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

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

另请参阅

注意

get_uri() 依赖于 SQLAlchemy 和 PyAthena。

获取 Aws 连接包装器对象。

classmethod get_ui_field_behaviour()[源代码]¶

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

获取 Airflow Connection 对象并将其包装在 helper 中（已缓存）。

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

获取 pyathena.Connection 对象。