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]¶

從該類派生時重寫。