airflow.providers.amazon.aws.triggers.dms¶

类¶

`DmsReplicationTerminalStatusTrigger`	当 AWS DMS Serverless 复制处于终止状态时触发。
`DmsReplicationConfigDeletedTrigger`	当 AWS DMS Serverless 复制配置被删除时触发。
`DmsReplicationCompleteTrigger`	当 AWS DMS Serverless 复制完成时触发。
`DmsReplicationStoppedTrigger`	当 AWS DMS Serverless 复制停止时触发。
`DmsReplicationDeprovisionedTrigger`	当 AWS DMS Serverless 复制被取消配置时触发。

模块内容¶

类 airflow.providers.amazon.aws.triggers.dms.DmsReplicationTerminalStatusTrigger(replication_config_arn, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default')[源代码]¶

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

当 AWS DMS Serverless 复制处于终止状态时触发。

参数:

replication_config_arn (str) – 复制配置的 ARN。
waiter_delay (int) – 两次尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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

类 airflow.providers.amazon.aws.triggers.dms.DmsReplicationConfigDeletedTrigger(replication_config_arn, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default')[源代码]¶

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

当 AWS DMS Serverless 复制配置被删除时触发。

参数:

replication_config_arn (str) – 复制配置的 ARN。
waiter_delay (int) – 两次尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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

类 airflow.providers.amazon.aws.triggers.dms.DmsReplicationCompleteTrigger(replication_config_arn, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default')[源代码]¶

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

当 AWS DMS Serverless 复制完成时触发。

参数:

replication_config_arn (str) – 复制配置的 ARN。
waiter_delay (int) – 两次尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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

类 airflow.providers.amazon.aws.triggers.dms.DmsReplicationStoppedTrigger(replication_config_arn, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default')[源代码]¶

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

当 AWS DMS Serverless 复制停止时触发。

参数:

replication_config_arn (str) – 复制配置的 ARN。
waiter_delay (int) – 两次尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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

类 airflow.providers.amazon.aws.triggers.dms.DmsReplicationDeprovisionedTrigger(replication_config_arn, waiter_delay=30, waiter_max_attempts=60, aws_conn_id='aws_default')[源代码]¶

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

当 AWS DMS Serverless 复制被取消配置时触发。

参数:

replication_config_arn (str) – 复制配置的 ARN。
waiter_delay (int) – 两次尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源代码]¶

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