airflow.providers.amazon.aws.triggers.rds¶

类¶

`RdsDbAvailableTrigger`	异步等待数据库实例或集群变为可用状态的触发器。
`RdsDbDeletedTrigger`	异步等待数据库实例或集群被删除的触发器。
`RdsDbStoppedTrigger`	异步等待数据库实例或集群停止的触发器。

模块内容¶

class airflow.providers.amazon.aws.triggers.rds.RdsDbAvailableTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None)[源代码]¶

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

异步等待数据库实例或集群变为可用状态的触发器。

参数:

db_identifier (str) – 要轮询的数据库实例或集群的数据库标识符。
waiter_delay (int) – 每次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – 数据库所在的 AWS 区域，如果与默认区域不同。
response (dict[str, Any]) – 来自 RdsHook 的响应，将传回给 Operator。
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

hook()[源代码]¶

在子类中覆盖此方法以返回正确的 Hook。

class airflow.providers.amazon.aws.triggers.rds.RdsDbDeletedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None)[源代码]¶

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

异步等待数据库实例或集群被删除的触发器。

参数:

db_identifier (str) – 要轮询的数据库实例或集群的数据库标识符。
waiter_delay (int) – 每次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – 数据库所在的 AWS 区域，如果与默认区域不同。
response (dict[str, Any]) – 来自 RdsHook 的响应，将传回给 Operator。
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

hook()[源代码]¶

在子类中覆盖此方法以返回正确的 Hook。

class airflow.providers.amazon.aws.triggers.rds.RdsDbStoppedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None)[源代码]¶

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

异步等待数据库实例或集群停止的触发器。

参数:

db_identifier (str) – 要轮询的数据库实例或集群的数据库标识符。
waiter_delay (int) – 每次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – 数据库所在的 AWS 区域，如果与默认区域不同。
response (dict[str, Any]) – 来自 RdsHook 的响应，将传回给 Operator。
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

hook()[源代码]¶

在子类中覆盖此方法以返回正确的 Hook。