如何用纯Python方式读取Azure Kubernetes Service(AKS)中Pod内的文件？

没问题！用Kubernetes官方的Python客户端完全可以实现这个需求，不需要依赖kubectl命令行或者本地预先配置好Azure环境，纯Python就能搞定。我给你一步步拆解怎么做：

先装依赖 #

首先得把需要的Python库装上：

• 基础的Kubernetes客户端：pip install kubernetes
• 如果你的脚本需要通过Azure AD认证访问AKS（比如本地机器没手动配置过kubeconfig），还得装Azure身份认证库：pip install azure-identity

核心思路 #

其实咱没必要完全模拟手动操作的三步（exec进Pod→cd目录→cat文件），可以把这几个操作合并成一条shell命令，通过Kubernetes的exec API直接执行，这样更高效也更符合编程逻辑。

代码示例 #

基础版（基于已配置的kubeconfig） #

如果你的机器已经通过az aks get-credentials配置好了AKS的kubeconfig，直接用这个版本就行：

from kubernetes import client, config
from kubernetes.stream import stream

# 加载kubeconfig（默认读取~/.kube/config，也可以指定路径：config.load_kube_config(config_file="/path/to/your/kubeconfig")）
config.load_kube_config()

# 创建CoreV1API实例，用来调用Kubernetes API
v1 = client.CoreV1Api()

# 替换成你自己的参数
namespace = "your-namespace"       # Pod所在的命名空间
pod_name = "target-pod-name"       # 要访问的Pod名称
container_name = "container-name"  # 如果Pod只有一个容器，可以删掉这个参数
target_dir = "/app/logs"           # 文件所在的目录
file_name = "app.log"              # 要读取的文件名

# 构建复合命令：cd到目标目录并查看文件内容
command = [
    '/bin/sh',
    '-c',
    f'cd {target_dir} && cat {file_name}'
]

try:
    # 执行exec操作，捕获标准输出和错误输出
    exec_response = stream(
        v1.connect_get_namespaced_pod_exec,
        name=pod_name,
        namespace=namespace,
        command=command,
        container=container_name,
        stderr=True, stdin=False,
        stdout=True, tty=False
    )
    
    # 打印文件内容
    print("文件内容：")
    print(exec_response)
except client.exceptions.ApiException as e:
    print(f"执行出错啦：{e}")

AKS Azure AD认证版（无预先配置kubeconfig） #

如果你的机器没手动配置过kubeconfig，想用Azure AD自动认证，试试这个版本：

from kubernetes import client, config
from kubernetes.stream import stream
from azure.identity import DefaultAzureCredential

# 用Azure默认身份认证获取token（支持本地开发、Azure VM、服务主体等多种场景）
credential = DefaultAzureCredential()
# 获取AKS的认证token
token = credential.get_token("https://management.azure.com/.default").token

# 加载kubeconfig（可以先通过`az aks get-credentials`导出到本地，或者用代码动态获取）
config.load_kube_config()
# 更新配置，用Azure AD token作为认证凭据
kube_config = client.Configuration.get_default_copy()
kube_config.api_key["authorization"] = token
kube_config.api_key_prefix["authorization"] = "Bearer"
client.Configuration.set_default(kube_config)

# 下面的代码和基础版完全一样，替换参数后执行即可
v1 = client.CoreV1Api()
namespace = "your-namespace"
pod_name = "target-pod-name"
container_name = "container-name"
target_dir = "/app/logs"
file_name = "app.log"

command = ['/bin/sh', '-c', f'cd {target_dir} && cat {file_name}']

try:
    exec_response = stream(
        v1.connect_get_namespaced_pod_exec,
        name=pod_name,
        namespace=namespace,
        command=command,
        container=container_name,
        stderr=True, stdin=False,
        stdout=True, tty=False
    )
    print("文件内容：")
    print(exec_response)
except client.exceptions.ApiException as e:
    print(f"执行出错啦：{e}")

一些注意事项 #

• 如果你的Pod用的是alpine这类轻量镜像，shell可能是/bin/ash而不是/bin/sh，记得把命令里的shell路径改掉
• 确保运行脚本的身份有访问该Pod的RBAC权限（至少需要pods/get和pods/exec权限）
• 如果目标文件特别大，建议分块读取流输出，而不是直接获取全部内容（上面的代码适合小文件，大文件可以参考Kubernetes客户端的流处理文档）

备注：内容来源于stack exchange，提问作者anon-explorer