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

派生此類時覆蓋。