airflow.providers.amazon.aws.sensors.rds

Module Contents

Classes

RdsSnapshotExistenceSensor

Waits for RDS snapshot with a specific status.

RdsExportTaskExistenceSensor

Waits for RDS export task with a specific status.

RdsDbSensor

Waits for an RDS instance or cluster to enter one of a number of states
class airflow.providers.amazon.aws.sensors.rds.RdsSnapshotExistenceSensor(*, db_type, db_snapshot_identifier, target_statuses=None, aws_conn_id='aws_conn_id', **kwargs)[source]

Bases: RdsBaseSensor

Waits for RDS snapshot with a specific status.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS snapshot status

Parameters

  • db_type (str) – Type of the DB - either “instance” or “cluster”

  • db_snapshot_identifier (str) – The identifier for the DB snapshot

  • target_statuses (list[str] | None) – Target status of snapshot

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

Function defined by the sensors while deriving this class should override.

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

Bases: RdsBaseSensor

Waits for RDS export task with a specific status.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS export task status

Parameters

  • export_task_identifier (str) – A unique identifier for the snapshot export task.

  • target_statuses (list[str] | None) – Target status of export task

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

Function defined by the sensors while deriving this class should override.

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

Bases: RdsBaseSensor

Waits for an RDS instance or cluster to enter one of a number of states

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon RDS instance or cluster status

Parameters

  • db_type (RdsDbType | str) – Type of the DB - either “instance” or “cluster” (default: ‘instance’)

  • db_identifier (str) – The AWS identifier for the DB

  • target_statuses (list[str] | None) – Target status of DB

template_fields :Sequence[str] = ['db_identifier', 'db_type', 'target_statuses'][source]
poke(context)[source]

Function defined by the sensors while deriving this class should override.

Was this entry helpful?