监视 Kubernetes 任务的输出直到完成

以下是一个使用Python和Kubernetes Python客户端库监视Kubernetes任务输出直到完成的示例代码：

from kubernetes import client, config
from kubernetes.client import ApiException
import time

# 加载Kubernetes配置
config.load_kube_config()

# 创建Kubernetes API客户端
api_instance = client.BatchV1Api()

# 设置任务的命名空间和名称
namespace = "default"
job_name = "example-job"

# 获取任务的日志
def get_job_logs(api_instance, namespace, job_name):
    try:
        # 通过名称检索Job
        job = api_instance.read_namespaced_job(job_name, namespace)

        # 获取任务的Pod名称
        pod_name = job.status.active[0].pod_name

        # 循环获取Pod的日志直到任务完成
        while True:
            try:
                # 通过名称检索Pod
                pod = api_instance.read_namespaced_pod(pod_name, namespace)

                # 获取日志
                logs = api_instance.read_namespaced_pod_log(pod_name, namespace)

                # 打印日志
                print(logs)

                # 检查任务是否完成
                if pod.status.phase == "Succeeded" or pod.status.phase == "Failed":
                    break

            except ApiException as e:
                print("Exception when calling CoreV1Api->read_namespaced_pod_log: %s\n" % e)
            
            # 等待一段时间再次获取日志
            time.sleep(1)

    except ApiException as e:
        print("Exception when calling BatchV1Api->read_namespaced_job: %s\n" % e)

# 调用函数，监视任务输出直到完成
get_job_logs(api_instance, namespace, job_name)

请确保已安装kubernetes库。使用pip install kubernetes命令进行安装。

此代码示例假定您已经成功设置了Kubernetes配置，并且该任务在默认命名空间中存在。您可以根据需要修改命名空间和任务名称。