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

Interact with Amazon EKS, using the boto3 library.

Attributes¶

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

Classes¶

`ClusterStates`	Contains the possible State values of an EKS Cluster.
`FargateProfileStates`	Contains the possible State values of an AWS Fargate profile.
`NodegroupStates`	Contains the possible State values of an EKS Managed Nodegroup.
`EksHook`	Interact with Amazon Elastic Kubernetes Service (EKS).

Module Contents¶

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]¶

Bases: enum.Enum

Contains the possible State values of an EKS Cluster.

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]¶

Bases: enum.Enum

Contains the possible State values of an AWS Fargate profile.

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]¶

Bases: enum.Enum

Contains the possible State values of an EKS Managed Nodegroup.

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]¶

Show Value

"""
            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]¶

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

Interact with Amazon Elastic Kubernetes Service (EKS).

Provide thin wrapper around boto3.client("eks").

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

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

client_type = 'eks'[source]¶

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

Create an Amazon EKS control plane.

See also

EKS.Client.create_cluster()

Parameters:

name (str) – The unique name to give to your Amazon EKS Cluster.
roleArn (str) – The Amazon Resource Name (ARN) of the IAM role that provides permissions for the Kubernetes control plane to make calls to AWS API operations on your behalf.
resourcesVpcConfig (dict) – The VPC configuration used by the cluster control plane.

Returns:

Returns descriptive information about the created EKS Cluster.

Return type:

dict

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

Create an Amazon EKS managed node group for an Amazon EKS Cluster.

See also

EKS.Client.create_nodegroup()

Parameters:

clusterName (str) – The name of the Amazon EKS cluster to create the EKS Managed Nodegroup in.
nodegroupName (str) – The unique name to give your managed nodegroup.
subnets (list[str]) – The subnets to use for the Auto Scaling group that is created for your nodegroup.
nodeRole (str | None) – The Amazon Resource Name (ARN) of the IAM role to associate with your nodegroup.
tags (dict | None) – Optional tags to apply to your nodegroup.

Returns:

Returns descriptive information about the created EKS Managed Nodegroup.

Return type:

dict

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

Create an AWS Fargate profile for an Amazon EKS cluster.

See also

EKS.Client.create_fargate_profile()

Parameters:

clusterName (str) – The name of the Amazon EKS cluster to apply the Fargate profile to.
fargateProfileName (str | None) – The name of the Fargate profile.
podExecutionRoleArn (str | None) – The Amazon Resource Name (ARN) of the pod execution role to use for pods that match the selectors in the Fargate profile.
selectors (list) – The selectors to match for pods to use this Fargate profile.

Returns:

Returns descriptive information about the created Fargate profile.

Return type:

dict

delete_cluster(name)[source]¶

Delete the Amazon EKS Cluster control plane.

See also

EKS.Client.delete_cluster()

Parameters:: name (str) – The name of the cluster to delete.
Returns:: Returns descriptive information about the deleted EKS Cluster.
Return type:: dict

delete_nodegroup(clusterName, nodegroupName)[source]¶

Delete an Amazon EKS managed node group from a specified cluster.

See also

EKS.Client.delete_nodegroup()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster that is associated with your nodegroup.
nodegroupName (str) – The name of the nodegroup to delete.

Returns:

Returns descriptive information about the deleted EKS Managed Nodegroup.

Return type:

dict

delete_fargate_profile(clusterName, fargateProfileName)[source]¶

Delete an AWS Fargate profile from a specified Amazon EKS cluster.

See also

EKS.Client.delete_fargate_profile()

Parameters:

clusterName (str) – The name of the Amazon EKS cluster associated with the Fargate profile to delete.
fargateProfileName (str) – The name of the Fargate profile to delete.

Returns:

Returns descriptive information about the deleted Fargate profile.

Return type:

dict

describe_cluster(name, verbose=False)[source]¶

Return descriptive information about an Amazon EKS Cluster.

See also

EKS.Client.describe_cluster()

Parameters:

name (str) – The name of the cluster to describe.
verbose (bool) – Provides additional logging if set to True. Defaults to False.

Returns:

Returns descriptive information about a specific EKS Cluster.

Return type:

dict

describe_nodegroup(clusterName, nodegroupName, verbose=False)[source]¶

Return descriptive information about an Amazon EKS managed node group.

See also

EKS.Client.describe_nodegroup()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster associated with the nodegroup.
nodegroupName (str) – The name of the nodegroup to describe.
verbose (bool) – Provides additional logging if set to True. Defaults to False.

Returns:

Returns descriptive information about a specific EKS Nodegroup.

Return type:

dict

describe_fargate_profile(clusterName, fargateProfileName, verbose=False)[source]¶

Return descriptive information about an AWS Fargate profile.

See also

EKS.Client.describe_fargate_profile()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster associated with the Fargate profile.
fargateProfileName (str) – The name of the Fargate profile to describe.
verbose (bool) – Provides additional logging if set to True. Defaults to False.

Returns:

Returns descriptive information about an AWS Fargate profile.

Return type:

dict

get_cluster_state(clusterName)[source]¶

Return the current status of a given Amazon EKS Cluster.

See also

EKS.Client.describe_cluster()

Parameters:: clusterName (str) – The name of the cluster to check.
Returns:: Returns the current status of a given Amazon EKS Cluster.
Return type:: ClusterStates

get_fargate_profile_state(clusterName, fargateProfileName)[source]¶

Return the current status of a given AWS Fargate profile.

See also

EKS.Client.describe_fargate_profile()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster associated with the Fargate profile.
fargateProfileName (str) – The name of the Fargate profile to check.

Returns:

Returns the current status of a given AWS Fargate profile.

Return type:

FargateProfileStates

get_nodegroup_state(clusterName, nodegroupName)[source]¶

Return the current status of a given Amazon EKS managed node group.

See also

EKS.Client.describe_nodegroup()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster associated with the nodegroup.
nodegroupName (str) – The name of the nodegroup to check.

Returns:

Returns the current status of a given Amazon EKS Nodegroup.

Return type:

NodegroupStates

list_clusters(verbose=False)[source]¶

List all Amazon EKS Clusters in your AWS account.

See also

EKS.Client.list_clusters()

Parameters:: verbose (bool) – Provides additional logging if set to True. Defaults to False.
Returns:: A List containing the cluster names.
Return type:: list

list_nodegroups(clusterName, verbose=False)[source]¶

List all Amazon EKS managed node groups associated with the specified cluster.

See also

EKS.Client.list_nodegroups()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster containing nodegroups to list.
verbose (bool) – Provides additional logging if set to True. Defaults to False.

Returns:

A List of nodegroup names within the given cluster.

Return type:

list

list_fargate_profiles(clusterName, verbose=False)[source]¶

List all AWS Fargate profiles associated with the specified cluster.

See also

EKS.Client.list_fargate_profiles()

Parameters:

clusterName (str) – The name of the Amazon EKS Cluster containing Fargate profiles to list.
verbose (bool) – Provides additional logging if set to True. Defaults to False.

Returns:

A list of Fargate profile names within a given cluster.

Return type:

list

generate_config_file(eks_cluster_name, pod_namespace)[source]¶

Write the kubeconfig file given an EKS Cluster.

Parameters:

eks_cluster_name (str) – The name of the cluster to generate kubeconfig file for.
pod_namespace (str | None) – The namespace to run within kubernetes.

fetch_access_token_for_cluster(eks_cluster_name)[source]¶