• 主页
• airflow.providers.amazon
• airflow.providers.amazon.aws
• airflow.providers.amazon.aws.hooks
• airflow.providers.amazon.aws.hooks.ecs

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，内存）有关。
should_retry_eni(exception)	检查异常是否与 ENI（弹性网络接口）有关。

airflow.providers.amazon.aws.hooks.ecs.should_retry(exception)

检查异常是否与 ECS 资源配额（CPU，内存）有关。

airflow.providers.amazon.aws.hooks.ecs.should_retry_eni(exception)

检查异常是否与 ENI（弹性网络接口）有关。

class airflow.providers.amazon.aws.hooks.ecs.EcsClusterStates

基类： airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 集群的可能状态值。

ACTIVE = 'ACTIVE'

PROVISIONING = 'PROVISIONING'

DEPROVISIONING = 'DEPROVISIONING'

FAILED = 'FAILED'

INACTIVE = 'INACTIVE'

class airflow.providers.amazon.aws.hooks.ecs.EcsTaskDefinitionStates

基类： airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 任务定义的可能状态值。

ACTIVE = 'ACTIVE'

INACTIVE = 'INACTIVE'

DELETE_IN_PROGRESS = 'DELETE_IN_PROGRESS'

class airflow.providers.amazon.aws.hooks.ecs.EcsTaskStates

基类： airflow.providers.amazon.aws.utils._StringCompareEnum

包含 ECS 任务的可能状态值。

PROVISIONING = 'PROVISIONING'

PENDING = 'PENDING'

ACTIVATING = 'ACTIVATING'

RUNNING = 'RUNNING'

DEACTIVATING = 'DEACTIVATING'

STOPPING = 'STOPPING'

DEPROVISIONING = 'DEPROVISIONING'

STOPPED = 'STOPPED'

NONE = 'NONE'

class airflow.providers.amazon.aws.hooks.ecs.EcsHook(*args, **kwargs)

基类： airflow.providers.amazon.aws.hooks.base_aws.AwsGenericHook

与 Amazon Elastic Container Service (ECS) 交互。

提供对 boto3.client("ecs") 的薄封装。

可以指定其他参数（例如 aws_conn_id），这些参数将传递给底层的 AwsBaseHook。

另请参阅

• airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

• Amazon 弹性容器服务

get_cluster_state(cluster_name)

获取 ECS 集群状态。

另请参阅

• ECS.Client.describe_clusters()

参数

cluster_name (str) – ECS 集群名称或完整的集群 Amazon 资源名称 (ARN) 条目。

get_task_definition_state(task_definition)

获取 ECS 任务定义状态。

另请参阅

• ECS.Client.describe_task_definition()

参数

task_definition (str) – 最新 ACTIVE 修订版的族系，族系和修订版（族系:修订版）用于描述族系中的特定修订版，或要描述的任务定义的完整 Amazon 资源名称 (ARN)。

get_task_state(cluster, task)

获取 ECS 任务状态。

另请参阅

• ECS.Client.describe_tasks()

参数

• cluster – 托管要描述的任务的集群的简称或完整的 Amazon 资源名称 (ARN)。

• task – 任务 ID 或完整的 ARN 条目。

class airflow.providers.amazon.aws.hooks.ecs.EcsProtocol

基类：airflow.typing_compat.Protocol

boto3.client('ecs') 的结构化协议。

这用于 EcsOperator.client() 上的类型提示。

另请参阅

• https://mypy.readthedocs.io/en/latest/protocols.html

• https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ecs.html

run_task(**kwargs)

运行任务。

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

get_waiter(x)

获取等待器。

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

describe_tasks(cluster, tasks)

描述任务。

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

stop_task(cluster, task, reason)

停止任务。

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

describe_task_definition(taskDefinition)

描述任务定义。

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

list_tasks(cluster, launchType, desiredStatus, family)

列出任务。

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

上一个 下一个

此条目是否有帮助？