airflow.providers.amazon.aws.sensors.eks¶
跟踪 Amazon EKS 集群、Amazon EKS 托管节点组和 AWS Fargate 配置文件的状态。
属性¶
类¶
检查各种 EKS 状态的基类。 |
|
检查 Amazon EKS 集群的状态,直到其达到目标状态或另一个终端状态。 |
|
检查 AWS Fargate 配置文件的状态,直到其达到目标状态或另一个终端状态。 |
|
检查 EKS 托管节点组的状态,直到其达到目标状态或另一个终端状态。 |
模块内容¶
- 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 方法。
- 参数:
cluster_name (str) – 集群的名称
target_state (airflow.providers.amazon.aws.hooks.eks.ClusterStates | airflow.providers.amazon.aws.hooks.eks.NodegroupStates | airflow.providers.amazon.aws.hooks.eks.FargateProfileStates) – 当达到该状态时将成功返回。
target_state_type (type) – 包含状态的枚举,如果需要从字符串转换,将用于转换目标状态。
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
- 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
- 参数:
cluster_name – 要监视的集群名称。(templated)
target_state (airflow.providers.amazon.aws.hooks.eks.ClusterStates) – 集群的目标状态。(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]¶
- 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]¶
- 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]¶