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

模块内容¶

类¶

`EcsBaseSensor`	包含弹性容器服务的通用传感器行为。
`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)[源代码]¶

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

包含弹性容器服务的通用传感器行为。

aws_hook_class[源代码]¶

client()[源代码]¶

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

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

基类：EcsBaseSensor

轮询集群状态，直到其达到终端状态；如果出现失败原因，则引发 AirflowException。

另请参阅

有关如何使用此操作符的更多信息，请查看指南： 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][源代码]¶

poke(context)[源代码]¶

在派生此类时覆盖。

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

基类：EcsBaseSensor

轮询任务定义，直到其达到终端状态；如果出现失败原因，则引发 AirflowException。

另请参阅

有关如何使用此操作符的更多信息，请查看指南： AWS ECS 任务定义状态传感器

参数

task_definition (str) – 最新 ACTIVE 修订的系列，系列和修订（系列:修订）用于系列中的特定修订，或任务定义的完整 Amazon 资源名称 (ARN)。
target_state (airflow.providers.amazon.aws.hooks.ecs.EcsTaskDefinitionStates | None) – 要监视的成功状态。（默认值：“ACTIVE”）

template_fields: collections.abc.Sequence[str][源代码]¶

poke(context)[源代码]¶

在派生此类时覆盖。

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

基类：EcsBaseSensor

轮询任务状态，直到其达到终端状态；如果出现失败原因，则引发 AirflowException。

另请参阅

有关如何使用此操作符的更多信息，请查看指南： AWS ECS 任务状态传感器

参数

cluster (str) – 托管任务的集群的简称或完整 Amazon 资源名称 (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][源代码]¶

poke(context)[源代码]¶

在派生此类时覆盖。

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

模块内容¶

类¶

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