kubernetes - 如何使用Client-Go获取有关节点创建的AWS metdata

Question

我正在为kubernetes集群编写自定义 Controller ，它将监听节点事件并在节点上执行一些操作。我正在使用kubernetes客户端库，并且能够在连接或移除节点时捕获kubernetes事件。来自集群。但是是否可以获取已创建的kubernetes节点的AWS实例详细信息，例如实例ID，标签等？提前致谢。

PS:我已经使用kops安装了kubernetes集群

Answer 1

在AWS的Kubernetes节点上，您将填充一些东西作为节点标签的一部分以及节点元数据的其他各个部分:

kubectl get nodes -o json | jq '.items[].metadata.labels'

{
  "beta.kubernetes.io/arch": "amd64",
  "beta.kubernetes.io/instance-type": "c5.large",
  "beta.kubernetes.io/os": "linux",
  "failure-domain.beta.kubernetes.io/region": "us-east-1",
  "failure-domain.beta.kubernetes.io/zone": "us-east-1b",
  "kubernetes.io/hostname": "<hostname>",
  "kubernetes.io/role": "master",
  "manufacturer": "amazon_ec2",
  "node-role.kubernetes.io/master": "",
  "operatingsystem": "centos",
  "tier": "production",
  "virtual": "kvm"
}

节点信息使用client-go方法在node package here中的Get中。这是一个例子:

  client := kubernetes.NewForConfigOrDie(config)

  list, err := client.CoreV1().Nodes().List(metav1.ListOptions{})
  if err != nil {
    fmt.Fprintf(os.Stderr, "error listing nodes: %v", err)
    os.Exit(1)
  }

  for _, node := range list.Items {
    fmt.Printf("Node: %s\n", node.Name)
    node, err := client.CoreV1().Nodes().Get(node.Name, metav1.GetOptions{})
    if err != nil {
      fmt.Fprintf(os.Stderr, "error getting node: %v", err)
      os.Exit(1)
    }
    fmt.Println(node)
  }

但是，这实际上可能不是您要解决的方法。如果要在AWS的kops集群上运行此文件，则正在运行工作负载的节点已经可以访问AWS API，还可以访问查询节点数据所需的IAM role。

考虑到这一点，请考虑改为使用AWS Go SDK。您可以很容易地查询EC2，这是一个adapted example:

package main

import (
    "fmt"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/ec2"
)

func main() {
    // Load session from shared config
    sess := session.Must(session.NewSessionWithOptions(session.Options{
        SharedConfigState: session.SharedConfigEnable,
    }))

    // Create new EC2 client
    ec2Svc := ec2.New(sess)

    // Call to get detailed information on each instance
    result, err := ec2Svc.DescribeInstances(nil)
    if err != nil {
        fmt.Println("Error", err)
    } else {
        fmt.Println("Success", result)
    }
}