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)[源代码]

基类: 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 的响应，将传递回操作符。

  • db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

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)[源代码]

基类: 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 的响应，将传递回操作符。

  • db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

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)[源代码]

基类: 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 的响应，将传递回操作符。

  • db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型：实例或集群。

hook()[源代码]

在子类中重写以返回正确的钩子。

此条目是否有帮助？