airflow.providers.amazon.aws.hooks.ecs¶

類¶

`EcsClusterStates`	包含 ECS 叢集可能的狀態值。
`EcsTaskDefinitionStates`	包含 ECS 任務定義可能的狀態值。
`EcsTaskStates`	包含 ECS 任務可能的狀態值。
`EcsHook`	與 Amazon Elastic Container Service (ECS) 互動。
`EcsProtocol`	`boto3.client('ecs')` 的結構化協議。

函式¶

`should_retry`(exception)	檢查異常是否與 ECS 資源配額 (CPU, MEM) 相關。
`should_retry_eni`(exception)	檢查異常是否與 ENI (彈性網路介面) 相關。

模組內容¶

airflow.providers.amazon.aws.hooks.ecs.should_retry(exception)[source]¶

檢查異常是否與 ECS 資源配額 (CPU, MEM) 相關。

airflow.providers.amazon.aws.hooks.ecs.should_retry_eni(exception)[source]¶

檢查異常是否與 ENI (彈性網路介面) 相關。

class airflow.providers.amazon.aws.hooks.ecs.EcsClusterStates[source]¶

Bases: airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 叢集可能的狀態值。

ACTIVE = 'ACTIVE'[source]¶

PROVISIONING = 'PROVISIONING'[source]¶

DEPROVISIONING = 'DEPROVISIONING'[source]¶

FAILED = 'FAILED'[source]¶

INACTIVE = 'INACTIVE'[source]¶

class airflow.providers.amazon.aws.hooks.ecs.EcsTaskDefinitionStates[source]¶

Bases: airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 任務定義可能的狀態值。

ACTIVE = 'ACTIVE'[source]¶

INACTIVE = 'INACTIVE'[source]¶

DELETE_IN_PROGRESS = 'DELETE_IN_PROGRESS'[source]¶

class airflow.providers.amazon.aws.hooks.ecs.EcsTaskStates[source]¶

Bases: airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 任務可能的狀態值。

PROVISIONING = 'PROVISIONING'[source]¶

PENDING = 'PENDING'[source]¶

ACTIVATING = 'ACTIVATING'[source]¶

RUNNING = 'RUNNING'[source]¶

DEACTIVATING = 'DEACTIVATING'[source]¶

STOPPING = 'STOPPING'[source]¶

DEPROVISIONING = 'DEPROVISIONING'[source]¶

STOPPED = 'STOPPED'[source]¶

NONE = 'NONE'[source]¶

class airflow.providers.amazon.aws.hooks.ecs.EcsHook(*args, **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsGenericHook

與 Amazon Elastic Container Service (ECS) 互動。

為 boto3.client("ecs") 提供精簡封裝。

可以指定其他引數（例如 aws_conn_id），這些引數將傳遞給底層的 AwsBaseHook。

另請參閱

get_cluster_state(cluster_name)[source]¶

獲取 ECS 叢集狀態。

另請參閱

ECS.Client.describe_clusters()

引數:: cluster_name (str) – ECS 叢集名稱或完整的叢集 Amazon Resource Name (ARN) 條目。

get_task_definition_state(task_definition)[source]¶

獲取 ECS 任務定義狀態。

另請參閱

ECS.Client.describe_task_definition()

引數:: task_definition (str) – 最新 ACTIVE 版本的族，或特定版本的族和版本（family:revision），或要描述的任務定義的完整 Amazon Resource Name (ARN)。

get_task_state(cluster, task)[source]¶

獲取 ECS 任務狀態。

另請參閱

ECS.Client.describe_tasks()

引數:

cluster – 託管要描述的一個或多個任務的叢集的短名稱或完整 Amazon Resource Name (ARN)。
task – 任務 ID 或完整的 ARN 條目。

class airflow.providers.amazon.aws.hooks.ecs.EcsProtocol[source]¶

Bases: Protocol

boto3.client('ecs') 的結構化協議。

用於 EcsOperator.client() 的型別提示。

另請參閱

run_task(**kwargs)[source]¶

執行一個任務。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.run_task

get_waiter(x)[source]¶

獲取一個 waiter。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.get_waiter

describe_tasks(cluster, tasks)[source]¶

描述任務。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.describe_tasks

stop_task(cluster, task, reason)[source]¶

停止一個任務。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.stop_task

describe_task_definition(taskDefinition)[source]¶

描述任務定義。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.describe_task_definition

list_tasks(cluster, launchType, desiredStatus, family)[source]¶

列出任務。

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html#ECS.Client.list_tasks