airflow.providers.amazon.aws.sensors.eks

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

模块内容

类

EksBaseSensor

用于检查各种 EKS 状态的基类。

EksClusterStateSensor

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

EksFargateProfileStateSensor

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

EksNodegroupStateSensor

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

属性

DEFAULT_CONN_ID

CLUSTER_TERMINAL_STATES

FARGATE_TERMINAL_STATES

NODEGROUP_TERMINAL_STATES

airflow.providers.amazon.aws.sensors.eks.DEFAULT_CONN_ID = 'aws_default'[源代码]
airflow.providers.amazon.aws.sensors.eks.CLUSTER_TERMINAL_STATES[源代码]
airflow.providers.amazon.aws.sensors.eks.FARGATE_TERMINAL_STATES[源代码]
airflow.providers.amazon.aws.sensors.eks.NODEGROUP_TERMINAL_STATES[源代码]
class airflow.providers.amazon.aws.sensors.eks.EksBaseSensor(*, cluster_name, target_state, target_state_type, aws_conn_id=DEFAULT_CONN_ID, region=None, **kwargs)[源代码]

基类：airflow.sensors.base.BaseSensorOperator

用于检查各种 EKS 状态的基类。

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

参数
hook()[源代码]
poke(context)[源代码]

在派生此类时覆盖。

abstract get_state()[源代码]
abstract get_terminal_states()[源代码]
class airflow.providers.amazon.aws.sensors.eks.EksClusterStateSensor(*, target_state=ClusterStates.ACTIVE, **kwargs)[源代码]

基类：EksBaseSensor

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

另请参阅

有关如何使用此传感器的更多信息，请查看以下指南：等待 Amazon EKS 集群状态

参数

  • cluster_name – 要监视的集群的名称。（已模板化）

  • target_state (airflow.providers.amazon.aws.hooks.eks.ClusterStates) – 集群的目标状态。（已模板化）

  • region – 连接应使用的 AWS 区域。（已模板化）如果此值为 None 或空，则使用默认的 boto3 行为。

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

template_fields: collections.abc.Sequence[str] = ('cluster_name', 'target_state', 'aws_conn_id', 'region')[源代码]
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, target_state=FargateProfileStates.ACTIVE, **kwargs)[source]

基类：EksBaseSensor

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

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 AWS Fargate 配置文件状态

参数

  • cluster_name – AWS Fargate 配置文件所附加到的集群的名称。（可模板化）

  • fargate_profile_name (str) – 要监视的 Fargate 配置文件的名称。（可模板化）

  • target_state (airflow.providers.amazon.aws.hooks.eks.FargateProfileStates) – Fargate 配置文件的目标状态。（可模板化）

  • region – 连接应使用的 AWS 区域。（已模板化）如果此值为 None 或空，则使用默认的 boto3 行为。

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

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

基类：EksBaseSensor

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

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon EKS 托管节点组状态

参数

  • cluster_name – 节点组所附加到的集群的名称。（可模板化）

  • nodegroup_name (str) – 要监视的节点组的名称。（可模板化）

  • target_state (airflow.providers.amazon.aws.hooks.eks.NodegroupStates) – 节点组的目标状态。（可模板化）

  • region – 连接应使用的 AWS 区域。（已模板化）如果此值为 None 或空，则使用默认的 boto3 行为。

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

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

此条目是否有帮助？