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]

此條目有幫助嗎？