airflow.providers.amazon.aws.hooks.eks¶

使用 boto3 庫與 Amazon EKS 互動。

屬性¶

`DEFAULT_PAGINATION_TOKEN`
`STS_TOKEN_EXPIRES_IN`
`AUTHENTICATION_API_VERSION`
`COMMAND`

類¶

`ClusterStates`	包含 EKS 叢集的可能狀態值。
`FargateProfileStates`	包含 AWS Fargate 配置檔案的可能狀態值。
`NodegroupStates`	包含 EKS 託管節點組的可能狀態值。
`EksHook`	與 Amazon Elastic Kubernetes Service (EKS) 互動。

模組內容¶

airflow.providers.amazon.aws.hooks.eks.DEFAULT_PAGINATION_TOKEN = ''[source]¶

airflow.providers.amazon.aws.hooks.eks.STS_TOKEN_EXPIRES_IN = 60[source]¶

airflow.providers.amazon.aws.hooks.eks.AUTHENTICATION_API_VERSION = 'client.authentication.k8s.io/v1alpha1'[source]¶

class airflow.providers.amazon.aws.hooks.eks.ClusterStates[source]¶

基類: enum.Enum

包含 EKS 叢集的可能狀態值。

CREATING = 'CREATING'[source]¶

ACTIVE = 'ACTIVE'[source]¶

DELETING = 'DELETING'[source]¶

FAILED = 'FAILED'[source]¶

UPDATING = 'UPDATING'[source]¶

NONEXISTENT = 'NONEXISTENT'[source]¶

class airflow.providers.amazon.aws.hooks.eks.FargateProfileStates[source]¶

基類: enum.Enum

包含 AWS Fargate 配置檔案的可能狀態值。

CREATING = 'CREATING'[source]¶

ACTIVE = 'ACTIVE'[source]¶

DELETING = 'DELETING'[source]¶

CREATE_FAILED = 'CREATE_FAILED'[source]¶

DELETE_FAILED = 'DELETE_FAILED'[source]¶

NONEXISTENT = 'NONEXISTENT'[source]¶

class airflow.providers.amazon.aws.hooks.eks.NodegroupStates[source]¶

基類: enum.Enum

包含 EKS 託管節點組的可能狀態值。

CREATING = 'CREATING'[source]¶

ACTIVE = 'ACTIVE'[source]¶

UPDATING = 'UPDATING'[source]¶

DELETING = 'DELETING'[source]¶

CREATE_FAILED = 'CREATE_FAILED'[source]¶

DELETE_FAILED = 'DELETE_FAILED'[source]¶

DEGRADED = 'DEGRADED'[source]¶

NONEXISTENT = 'NONEXISTENT'[source]¶

airflow.providers.amazon.aws.hooks.eks.COMMAND = Multiline-String[source]¶

顯示值

"""
            output=$({python_executable} -m airflow.providers.amazon.aws.utils.eks_get_token                 --cluster-name {eks_cluster_name} {args} 2>&1)

            if [ $? -ne 0 ]; then
                echo "Error running the script"
                exit 1
            fi

            expiration_timestamp=$(echo "$output" | grep -oP 'expirationTimestamp: \K[^,]+')
            token=$(echo "$output" | grep -oP 'token: \K[^,]+')

            json_string=$(printf '{{"kind": "ExecCredential","apiVersion":                 "client.authentication.k8s.io/v1alpha1","spec": {{}},"status":                 {{"expirationTimestamp": "%s","token": "%s"}}}}' "$expiration_timestamp" "$token")
            echo $json_string
            """

class airflow.providers.amazon.aws.hooks.eks.EksHook(*args, **kwargs)[source]¶

基類: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 Amazon Elastic Kubernetes Service (EKS) 互動。

提供對 boto3.client("eks") 的輕量級包裝。

可以指定額外的引數（例如 aws_conn_id），並將這些引數傳遞給底層的 AwsBaseHook。

另請參閱

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

client_type = 'eks'[source]¶

create_cluster(name, roleArn, resourcesVpcConfig, **kwargs)[source]¶

建立一個 Amazon EKS 控制平面。

另請參閱

EKS.Client.create_cluster()

引數:

name (str) – 為您的 Amazon EKS 叢集指定的唯一名稱。
roleArn (str) – IAM 角色的 Amazon Resource Name (ARN)，該角色提供許可權使 Kubernetes 控制平面能夠代表您呼叫 AWS API 操作。
resourcesVpcConfig (dict) – 叢集控制平面使用的 VPC 配置。

返回:

返回有關已建立的 EKS 叢集的描述性資訊。

返回型別:

dict

create_nodegroup(clusterName, nodegroupName, subnets, nodeRole, *, tags=None, **kwargs)[source]¶

為 Amazon EKS 叢集建立一個 Amazon EKS 託管節點組。

另請參閱

EKS.Client.create_nodegroup()

引數:

clusterName (str) – 要在其內部建立 EKS 託管節點組的 Amazon EKS 叢集的名稱。
nodegroupName (str) – 為您的託管節點組指定的唯一名稱。
subnets (list[str]) – 用於為您的節點組建立的 Auto Scaling 組的子網。
nodeRole (str | None) – 要與您的節點組關聯的 IAM 角色的 Amazon Resource Name (ARN)。
tags (dict | None) – 可選的標籤，用於應用於您的節點組。

返回:

返回有關已建立的 EKS 託管節點組的描述性資訊。

返回型別:

dict

create_fargate_profile(clusterName, fargateProfileName, podExecutionRoleArn, selectors, **kwargs)[source]¶

為 Amazon EKS 叢集建立一個 AWS Fargate 配置檔案。

另請參閱

EKS.Client.create_fargate_profile()

引數:

clusterName (str) – 要應用 Fargate 配置檔案的 Amazon EKS 叢集的名稱。
fargateProfileName (str | None) – Fargate 配置檔案的名稱。
podExecutionRoleArn (str | None) – Pod 執行角色的 Amazon Resource Name (ARN)，用於與 Fargate 配置檔案中的選擇器匹配的 Pod。
selectors (list) – 用於匹配使用此 Fargate 配置檔案的 Pod 的選擇器。

返回: