airflow.providers.amazon.aws.triggers.redshift_cluster¶

类¶

`RedshiftCreateClusterTrigger`	RedshiftCreateClusterOperator 的触发器。
`RedshiftPauseClusterTrigger`	RedshiftPauseClusterOperator 的触发器。
`RedshiftCreateClusterSnapshotTrigger`	RedshiftCreateClusterSnapshotOperator 的触发器。
`RedshiftResumeClusterTrigger`	RedshiftResumeClusterOperator 的触发器。
`RedshiftDeleteClusterTrigger`	RedshiftDeleteClusterOperator 的触发器。
`RedshiftClusterTrigger`	RedshiftClusterTrigger 作为延迟类触发，带有参数以在触发器工作器中运行任务。

模块内容¶

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftCreateClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

RedshiftCreateClusterOperator 的触发器。

此触发器将异步轮询 boto3 API，等待 Redshift 集群处于 available 状态。

参数:

cluster_identifier (str) – 集群的唯一标识符。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接 ID。

hook()[source]¶

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

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftPauseClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

RedshiftPauseClusterOperator 的触发器。

此触发器将异步轮询 boto3 API，等待 Redshift 集群处于 paused 状态。

参数:

cluster_identifier (str) – 集群的唯一标识符。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接 ID。

hook()[source]¶

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

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftCreateClusterSnapshotTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

RedshiftCreateClusterSnapshotOperator 的触发器。

此触发器将异步轮询 boto3 API，等待 Redshift 集群快照处于 available 状态。

参数:

cluster_identifier (str) – 集群的唯一标识符。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接 ID。

hook()[source]¶

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

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftResumeClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=15, waiter_max_attempts=999999)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

RedshiftResumeClusterOperator 的触发器。

此触发器将异步轮询 boto3 API，等待 Redshift 集群处于 available 状态。

参数:

cluster_identifier (str) – 集群的唯一标识符。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接 ID。

hook()[source]¶

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

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftDeleteClusterTrigger(cluster_identifier, aws_conn_id='aws_default', waiter_delay=30, waiter_max_attempts=30)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

RedshiftDeleteClusterOperator 的触发器。

参数:

cluster_identifier (str) – 集群的唯一标识符。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接 ID。
waiter_delay (int) – 两次尝试之间等待的时间（秒）。

hook()[source]¶

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

class airflow.providers.amazon.aws.triggers.redshift_cluster.RedshiftClusterTrigger(aws_conn_id, cluster_identifier, target_status, poke_interval)[source]¶

Bases: airflow.triggers.base.BaseTrigger

RedshiftClusterTrigger 作为延迟类触发，带有参数以在触发器工作器中运行任务。

参数:

aws_conn_id (str | None) – Redshift 的 AWS 连接 ID 引用
cluster_identifier (str) – 集群的唯一标识符
target_status (str) – 需要检查的状态引用
poke_interval (float) – 检查状态的轮询周期（秒）

aws_conn_id[source]¶

cluster_identifier[source]¶

target_status[source]¶

poke_interval[source]¶

serialize()[source]¶

序列化 RedshiftClusterTrigger 参数和 classpath。

async run()[source]¶

异步运行直到集群状态与目标状态匹配。