airflow.providers.amazon.aws.sensors.ecs¶

类¶

`EcsBaseSensor`	包含 Elastic Container Service 的通用传感器行为。
`EcsClusterStateSensor`	轮询集群状态直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。
`EcsTaskDefinitionStateSensor`	轮询任务定义直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。
`EcsTaskStateSensor`	轮询任务状态直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。

模块内容¶

class airflow.providers.amazon.aws.sensors.ecs.EcsBaseSensor(*, aws_conn_id='aws_default', region_name=None, verify=None, botocore_config=None, region=NOTSET, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.ecs.EcsHook]

包含 Elastic Container Service 的通用传感器行为。

aws_hook_class[source]¶

property client: boto3.client[source]¶

创建并返回一个 EcsHook 客户端。

class airflow.providers.amazon.aws.sensors.ecs.EcsClusterStateSensor(*, cluster_name, target_state=EcsClusterStates.ACTIVE, failure_states=None, **kwargs)[source]¶

基类: EcsBaseSensor

轮询集群状态直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南：AWS ECS 集群状态传感器

参数:

cluster_name (str) – 集群的名称。
target_state (airflow.providers.amazon.aws.hooks.ecs.EcsClusterStates | None) – 要监测的成功状态。(默认值：“ACTIVE”)
failure_states (set[airflow.providers.amazon.aws.hooks.ecs.EcsClusterStates] | None) – 如果在达到成功状态之前达到任何这些状态，则视为失败。(默认值：“FAILED” 或 “INACTIVE”)

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

cluster_name[source]¶

target_state[source]¶

failure_states[source]¶

poke(context)[source]¶

派生此类时覆盖。

class airflow.providers.amazon.aws.sensors.ecs.EcsTaskDefinitionStateSensor(*, task_definition, target_state=EcsTaskDefinitionStates.ACTIVE, **kwargs)[source]¶

基类: EcsBaseSensor

轮询任务定义直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南：AWS ECS 任务定义状态传感器

参数:

task_definition (str) – 最新 ACTIVE 版本的族名称，族和版本 (family:revision) 用于指定族的特定版本，或任务定义的完整 Amazon Resource Name (ARN)。
target_state (airflow.providers.amazon.aws.hooks.ecs.EcsTaskDefinitionStates | None) – 要监测的成功状态。(默认值：“ACTIVE”)

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

task_definition[source]¶

target_state[source]¶

failure_states[source]¶

poke(context)[source]¶

派生此类时覆盖。

class airflow.providers.amazon.aws.sensors.ecs.EcsTaskStateSensor(*, cluster, task, target_state=EcsTaskStates.RUNNING, failure_states=None, **kwargs)[source]¶

基类: EcsBaseSensor

轮询任务状态直到达到终端状态；如果失败，则抛出 AirflowException 并附带失败原因。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南：AWS ECS 任务状态传感器

参数:

cluster (str) – 托管任务的集群的短名称或完整 Amazon Resource Name (ARN)。
task (str) – 要轮询的任务 ID 或完整 ARN。
target_state (airflow.providers.amazon.aws.hooks.ecs.EcsTaskStates | None) – 要监测的成功状态。(默认值：“ACTIVE”)
failure_states (set[airflow.providers.amazon.aws.hooks.ecs.EcsTaskStates] | None) – 如果在达到成功状态之前达到任何这些状态，则视为失败。(默认值：“STOPPED”)

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

cluster[source]¶

task[source]¶

target_state[source]¶

failure_states[source]¶

poke(context)[source]¶

派生此类时覆盖。