airflow.providers.amazon.aws.sensors.eks

跟踪 Amazon EKS 集群、Amazon EKS 托管节点组和 AWS Fargate 配置文件的状态。

属性

DEFAULT_CONN_ID

CLUSTER_TERMINAL_STATES

FARGATE_TERMINAL_STATES

NODEGROUP_TERMINAL_STATES

类

EksBaseSensor

检查各种 EKS 状态的基类。

EksClusterStateSensor

检查 Amazon EKS 集群的状态，直到其达到目标状态或另一个终端状态。

EksFargateProfileStateSensor

检查 AWS Fargate 配置文件的状态，直到其达到目标状态或另一个终端状态。

EksNodegroupStateSensor

检查 EKS 托管节点组的状态，直到其达到目标状态或另一个终端状态。

模块内容

airflow.providers.amazon.aws.sensors.eks.DEFAULT_CONN_ID = 'aws_default'[source]
airflow.providers.amazon.aws.sensors.eks.CLUSTER_TERMINAL_STATES[source]
airflow.providers.amazon.aws.sensors.eks.FARGATE_TERMINAL_STATES[source]
airflow.providers.amazon.aws.sensors.eks.NODEGROUP_TERMINAL_STATES[source]
class airflow.providers.amazon.aws.sensors.eks.EksBaseSensor(*, cluster_name, target_state, target_state_type, **kwargs)[source]

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor

检查各种 EKS 状态的基类。

子类需要实现 get_state 和 get_terminal_states 方法。

参数:
aws_hook_class[source]
cluster_name[source]
target_state[source]
poke(context)[source]

派生此类时重写。

abstract get_state()[source]
abstract get_terminal_states()[source]
class airflow.providers.amazon.aws.sensors.eks.EksClusterStateSensor(*, target_state=ClusterStates.ACTIVE, region=None, **kwargs)[source]

Bases: EksBaseSensor

检查 Amazon EKS 集群的状态，直到其达到目标状态或另一个终端状态。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：Wait on an Amazon EKS cluster state

参数:
template_fields: collections.abc.Sequence[str][source]
ui_color = '#ff9900'[source]
ui_fgcolor = '#232F3E'[source]
get_state()[source]
get_terminal_states()[source]
class airflow.providers.amazon.aws.sensors.eks.EksFargateProfileStateSensor(*, fargate_profile_name, region=None, target_state=FargateProfileStates.ACTIVE, **kwargs)[source]

Bases: EksBaseSensor

检查 AWS Fargate 配置文件的状态，直到其达到目标状态或另一个终端状态。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：Wait on an AWS Fargate profile state

参数:

  • cluster_name – AWS Fargate 配置文件附加到的集群名称。(templated)

  • fargate_profile_name (str) – 要监视的 Fargate 配置文件名称。(templated)

  • target_state (airflow.providers.amazon.aws.hooks.eks.FargateProfileStates) – Fargate 配置文件的目标状态。(templated)

  • aws_conn_id – 用于 AWS 凭据的 Airflow 连接。如果为 None 或为空，则使用默认的 boto3 行为。如果以分布式方式运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（且必须在每个工作节点上维护）。

  • region_name – AWS 区域名称。如果未指定，则使用默认的 boto3 行为。

  • verify – 是否验证 SSL 证书。参见：https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

template_fields: collections.abc.Sequence[str][source]
ui_color = '#ff9900'[source]
ui_fgcolor = '#232F3E'[source]
fargate_profile_name[source]
get_state()[source]
get_terminal_states()[source]
class airflow.providers.amazon.aws.sensors.eks.EksNodegroupStateSensor(*, nodegroup_name, target_state=NodegroupStates.ACTIVE, region=None, **kwargs)[source]

Bases: EksBaseSensor

检查 EKS 托管节点组的状态，直到其达到目标状态或另一个终端状态。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南：Wait on an Amazon EKS managed node group state

参数:

  • cluster_name – 节点组附加到的集群名称。(templated)

  • nodegroup_name (str) – 要监视的节点组名称。(templated)

  • target_state (airflow.providers.amazon.aws.hooks.eks.NodegroupStates) – 节点组的目标状态。(templated)

  • aws_conn_id – 用于 AWS 凭据的 Airflow 连接。如果为 None 或为空，则使用默认的 boto3 行为。如果以分布式方式运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（且必须在每个工作节点上维护）。

  • region_name – AWS 区域名称。如果未指定，则使用默认的 boto3 行为。

  • verify – 是否验证 SSL 证书。参见：https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

template_fields: collections.abc.Sequence[str][source]
ui_color = '#ff9900'[source]
ui_fgcolor = '#232F3E'[source]
nodegroup_name[source]
get_state()[source]
get_terminal_states()[source]

此条目有帮助吗？