如何解决Kubernetes python 客户端相当于“kubectl wait --for”命令
我正在使用 kubernetes-client/python 并想编写一个方法,该方法将阻止控制,直到一组 Pod 处于就绪状态(运行状态)。我发现 kubernetes 支持 wait --for 命令通过命令做同样的事情。有人可以帮助我如何使用 kubernetes python 客户端实现相同的功能。
确切地说,我最感兴趣的是等效的-
kubectl wait --for condition=Ready pod -l 'app in (kafka,elasticsearch)'
解决方法
您可以使用客户端库中提供的 watch
功能。
from kubernetes import client,config,watch
config.load_kube_config()
w = watch.Watch()
core_v1 = client.CoreV1Api()
for event in w.stream(func=core_v1.list_namespaced_pod,namespace=namespace,label_selector=label,timeout_seconds=60):
if event["object"].status.phase == "Running":
w.stop()
end_time = time.time()
logger.info("%s started in %0.2f sec",full_name,end_time-start_time)
return
# event.type: ADDED,MODIFIED,DELETED
if event["type"] == "DELETED":
# Pod was deleted while we were waiting for it to start.
logger.debug("%s deleted before it started",full_name)
w.stop()
return
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。