`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]¶

基类: 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 连接。

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]¶

基类: 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 连接。

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]¶

基类: 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 连接。

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]¶

基类: 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 连接。

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]¶

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

用于 RedshiftDeleteClusterOperator 的触发器。

参数

cluster_identifier (str) – 集群的唯一标识符。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。
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]¶

基类: airflow.triggers.base.BaseTrigger

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

参数

aws_conn_id (str | None) – redshift 的 AWS 连接 ID 的引用
cluster_identifier (str) – 集群的唯一标识符
target_status (str) – 需要检查的状态的引用
poke_interval (float) – 轮询检查状态的间隔时间，单位为秒

serialize()[源代码]¶

序列化 RedshiftClusterTrigger 的参数和类路径。

async run()[源代码]¶

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

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

模块内容¶

类¶

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