如何使用Python客户端观察/验证pod驱逐调用是否完成？

Question

使用 python 客户端，我编写了一个函数来逐出节点上的所有 pod。我如何监控/观察所有 Pod 是否被完全驱逐？

我使用 create_namespaced_pod_eviction 方法逐出单个节点上的所有 pod。虽然这有效，但它不会等待该过程完成才继续。在继续我的脚本之前，我需要 100% 完成驱逐过程。我如何监控此进程的状态？与 kubectl 类似，我希望我的函数在返回之前等待每个 pod 被驱逐。

# passes list of pods to evict function
def drain_node(self):
    print("Draining node", self._node_name)
    self.cordon_node()
    pods = self._get_pods()
    response = []
    for pod in pods:
      response.append(self._evict_pod(pod))
    return response

# calls the eviction api on each pod
def _evict_pod(self, pod, delete_options=None):
    name = pod.metadata.name
    namespace = pod.metadata.namespace
    body = client.V1beta1Eviction(metadata=client.V1ObjectMeta(name=name, namespace=namespace))
    response = self._api.create_namespaced_pod_eviction(name, namespace, body)
    return response

# gets list of pods to evict
def _get_pods(self):
    all_pods = self._api.list_pod_for_all_namespaces(watch=True, field_selector='spec.nodeName=' + self._node_name)
    user_pods = [p for p in all_pods.items
                  if (p.metadata.namespace != 'kube-system')]
    return user_pods

Answer 1

如本链接中所示，

create_namespaced_pod_eviction

调用返回

V1Beta1Eviction

对象。它有

ObjectMeta

对象，其中包含

deletion_timestamp

字段。也许您可以使用它来确定 pod 是否已被删除。或者轮询 pod 状态可能会给出相同的 ObjectMeta。

Answer 2

聚会已经很晚了，但对于未来的读者，我会添加：

尝试这样的事情：

import time
# after evicting the pods
while self._get_pods():
    time.sleep(5)