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 物件。