从 Pod 访问 Kubernetes API
本指南演示如何从 Pod 中访问 Kubernetes API。
准备工作
你需要拥有一个 Kubernetes 集群,并且 kubectl 命令行工具已被配置为与你的集群通信。建议在本教程中使用一个至少包含两个非控制平面主机节点的集群。如果你还没有集群,可以使用 minikube 创建一个,或者你可以使用以下 Kubernetes 练兵场之一:
从 Pod 中访问 API
从 Pod 中访问 API 时,查找 API 服务器并对其进行认证与外部客户端情况略有不同。
从 Pod 中使用 Kubernetes API 的最简单方法是使用官方客户端库之一。这些库可以自动发现 API 服务器并进行认证。
使用官方客户端库
从 Pod 中连接到 Kubernetes API 的推荐方法是:
对于 Go 客户端,使用官方的 Go 客户端库。
rest.InClusterConfig()
函数会自动处理 API 主机发现和认证。请参阅这里的示例。对于 Python 客户端,使用官方的 Python 客户端库。
config.load_incluster_config()
函数会自动处理 API 主机发现和认证。请参阅这里的示例。还有许多其他库可用,请参阅客户端库页面。
在每种情况下,都使用 Pod 的服务账号凭据与 API 服务器安全地通信。
直接访问 REST API
在 Pod 中运行时,容器可以通过获取 KUBERNETES_SERVICE_HOST
和 KUBERNETES_SERVICE_PORT_HTTPS
环境变量来创建 Kubernetes API 服务器的 HTTPS URL。API 服务器的集群内地址也发布到 default
命名空间中名为 kubernetes
的 Service,以便 Pod 可以将 kubernetes.default.svc
作为本地 API 服务器的 DNS 名称来引用。
说明
Kubernetes 不保证 API 服务器为主机名kubernetes.default.svc
具有有效的证书;但是,期望控制平面为 $KUBERNETES_SERVICE_HOST
所代表的主机名或 IP 地址提供有效的证书。向 API 服务器进行认证的推荐方法是使用服务账号凭据。默认情况下,Pod 会关联到一个服务账号,该服务账号的凭据(令牌)会被放置到该 Pod 中每个容器的文件系统树中,路径为 /var/run/secrets/kubernetes.io/serviceaccount/token
。
如果可用,证书包会被放置到每个容器的文件系统树中,路径为 /var/run/secrets/kubernetes.io/serviceaccount/ca.crt
,应使用该证书包来验证 API 服务器的服务证书。
最后,用于命名空间 API 操作的默认命名空间会被放置到每个容器中,路径为 /var/run/secrets/kubernetes.io/serviceaccount/namespace
。
使用 kubectl proxy
如果不想使用官方客户端库查询 API,可以在 Pod 中将 kubectl proxy
作为新 sidecar 容器的命令运行。这样,kubectl proxy
将对 API 进行认证,并将其暴露在 Pod 的 localhost
接口上,以便 Pod 中的其他容器可以直接使用它。
不使用代理
可以通过将认证令牌直接传递给 API 服务器来避免使用 kubectl proxy。内部证书可保证连接安全。
# Point to the internal API server hostname
APISERVER=https://kubernetes.default.svc
# Path to ServiceAccount token
SERVICEACCOUNT=/var/run/secrets/kubernetes.io/serviceaccount
# Read this Pod's namespace
NAMESPACE=$(cat ${SERVICEACCOUNT}/namespace)
# Read the ServiceAccount bearer token
TOKEN=$(cat ${SERVICEACCOUNT}/token)
# Reference the internal certificate authority (CA)
CACERT=${SERVICEACCOUNT}/ca.crt
# Explore the API with TOKEN
curl --cacert ${CACERT} --header "Authorization: Bearer ${TOKEN}" -X GET ${APISERVER}/api
输出将类似于这样:
{
"kind": "APIVersions",
"versions": ["v1"],
"serverAddressByClientCIDRs": [
{
"clientCIDR": "0.0.0.0/0",
"serverAddress": "10.0.1.149:443"
}
]
}