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

模块内容¶

类¶

`DmsTaskBaseSensor`	包含 DMS 任务的通用传感器行为。
`DmsTaskCompletedSensor`	轮询 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 配置（并且必须在每个工作节点上维护）。
region_name – AWS 区域名称。如果未指定，则使用默认的 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]¶

poke(context)[source]¶

在派生此类时重写。

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

基类：DmsTaskBaseSensor

轮询 DMS 任务直到完成。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：等待复制任务完成

参数

replication_task_arn – AWS DMS 复制任务 ARN
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此值为 None 或为空，则使用默认的 boto3 行为。如果在分布式方式下运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。
region_name – AWS 区域名称。如果未指定，则使用默认的 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

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

模块内容¶

类¶

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