`airflow.providers.amazon.aws.triggers.athena`¶

模块内容¶

类¶

AthenaTrigger

AthenaOperator 的触发器。

class airflow.providers.amazon.aws.triggers.athena.AthenaTrigger(query_execution_id, waiter_delay, waiter_max_attempts, aws_conn_id, **kwargs)[源代码]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

AthenaOperator 的触发器。

此触发器将异步轮询 boto3 API

参数

query_execution_id (str) – 要监视的 Athena 查询执行的 ID
waiter_delay (int) – 两次尝试之间等待的时间（以秒为单位）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

在子类中覆盖以返回正确的钩子。

airflow.providers.amazon.aws.triggers.athena¶

模块内容¶

类¶

`airflow.providers.amazon.aws.triggers.athena`¶