airflow.providers.amazon.aws.sensors.rds¶

类¶

`RdsSnapshotExistenceSensor`	等待具有特定状态的 RDS 快照。
`RdsExportTaskExistenceSensor`	等待具有特定状态的 RDS 导出任务。
`RdsDbSensor`	等待 RDS 实例或集群进入其中一个状态。

模块内容¶

class airflow.providers.amazon.aws.sensors.rds.RdsSnapshotExistenceSensor(*, db_type, db_snapshot_identifier, target_statuses=None, **kwargs)[source]¶

Bases: RdsBaseSensor

等待具有特定状态的 RDS 快照。

另请参阅

有关如何使用此 sensor 的更多信息，请参阅指南：等待 Amazon RDS 快照状态

参数:

db_type (str) – 数据库类型 - “实例” 或 “集群”
db_snapshot_identifier (str) – 数据库快照的标识符
target_statuses (list[str] | None) – 快照的目标状态
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此项为 None 或为空，则使用默认的 boto3 行为。如果在分布式模式下运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个 worker 节点上维护）。
region_name – AWS region_name。如果未指定，则使用默认的 boto3 行为。
verify – 是否验证 SSL 证书。请参阅：https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客户端的配置字典（键值对）。请参阅：https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

template_fields: collections.abc.Sequence[str][source]¶

db_type[source]¶

db_snapshot_identifier[source]¶

target_statuses = ['available'][source]¶

poke(context)[source]¶

从该类派生时重写。

class airflow.providers.amazon.aws.sensors.rds.RdsExportTaskExistenceSensor(*, export_task_identifier, target_statuses=None, error_statuses=None, **kwargs)[source]¶

Bases: RdsBaseSensor

等待具有特定状态的 RDS 导出任务。

另请参阅

有关如何使用此 sensor 的更多信息，请参阅指南：等待 Amazon RDS 导出任务状态

参数:

export_task_identifier (str) – 快照导出任务的唯一标识符。
target_statuses (list[str] | None) – 导出任务的目标状态
error_statuses (list[str] | None) – 导出任务的错误状态，导致 sensor 失败

template_fields: collections.abc.Sequence[str][source]¶

export_task_identifier[source]¶

target_statuses = ['starting', 'in_progress', 'complete', 'canceling', 'canceled'][source]¶

error_statuses = ['failed'][source]¶

poke(context)[source]¶

从该类派生时重写。

class airflow.providers.amazon.aws.sensors.rds.RdsDbSensor(*, db_identifier, db_type=RdsDbType.INSTANCE, target_statuses=None, **kwargs)[source]¶

Bases: RdsBaseSensor

等待 RDS 实例或集群进入其中一个状态。

另请参阅

有关如何使用此 sensor 的更多信息，请参阅指南：等待 Amazon RDS 实例或集群状态

参数:

db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型 - “实例” 或 “集群” (默认: ‘instance’)
db_identifier (str) – 数据库的 AWS 标识符
target_statuses (list[str] | None) – 数据库的目标状态

template_fields: collections.abc.Sequence[str][source]¶

db_identifier[source]¶

target_statuses = ['available'][source]¶

db_type[source]¶

poke(context)[source]¶

从该类派生时重写。