airflow.providers.amazon.aws.sensors.dms¶

類¶

`DmsTaskBaseSensor`	包含 DMS 任務的通用感測器行為。
`DmsTaskCompletedSensor`	Poke DMS 任務直到完成。

模組內容¶

class airflow.providers.amazon.aws.sensors.dms.DmsTaskBaseSensor(replication_task_arn, target_statuses=None, termination_statuses=None, **kwargs)[source]¶

基類: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.dms.DmsHook]

包含 DMS 任務的通用感測器行為。

子類應設定 target_statuses 和 termination_statuses 欄位。

引數:

replication_task_arn (str) – AWS DMS 複製任務 ARN
target_statuses (collections.abc.Iterable[str] | None) – 目標狀態，感測器將等待直到任務達到其中任一狀態
termination_statuses (collections.abc.Iterable[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

aws_hook_class[source]¶

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

replication_task_arn[source]¶

target_statuses: collections.abc.Iterable[str] = [][source]¶

termination_statuses: collections.abc.Iterable[str] = [][source]¶

poke(context)[source]¶

派生此類時重寫。

class airflow.providers.amazon.aws.sensors.dms.DmsTaskCompletedSensor(**kwargs)[source]¶

基類: DmsTaskBaseSensor

Poke DMS 任務直到完成。

請參閱

有關如何使用此感測器的更多資訊，請參閱指南：等待複製任務完成

引數:

replication_task_arn – AWS DMS 複製任務 ARN
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