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, aws_conn_id='aws_conn_id', **kwargs)[source]

基类: RdsBaseSensor

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

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon RDS 快照状态

参数

  • db_type (str) – 数据库类型 - “instance” 或 “cluster”

  • db_snapshot_identifier (str) – 数据库快照的标识符

  • target_statuses (list[str] | None) – 快照的目标状态

template_fields: collections.abc.Sequence[str] = ('db_snapshot_identifier', 'target_statuses')[source]
poke(context)[source]

在派生此类时重写。

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

基类: RdsBaseSensor

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

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon RDS 导出任务状态

参数

  • export_task_identifier (str) – 快照导出任务的唯一标识符。

  • target_statuses (list[str] | None) – 导出任务的目标状态

template_fields: collections.abc.Sequence[str] = ('export_task_identifier', 'target_statuses')[source]
poke(context)[source]

在派生此类时重写。

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

基类: RdsBaseSensor

等待 RDS 实例或集群进入多个状态之一。

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon RDS 实例或集群状态

参数
template_fields: collections.abc.Sequence[str] = ('db_identifier', 'db_type', 'target_statuses')[source]
poke(context)[源代码]

在派生此类时重写。

此条目是否有帮助？