Signaler l'achèvement du travail

Question

Je cherche un moyen de savoir (à partir d'un script) quand un Job Kubernetes s'est terminé. Je veux ensuite sortir les journaux des conteneurs et effectuer le nettoyage.

Quelle serait la meilleure façon de procéder ? La meilleure façon serait-elle d'exécuter kubectl describe job <job_name> et grep pour 1 Succeeded ou quelque chose de ce genre ?

Answer 1

Depuis la version 1.11, vous pouvez le faire :

kubectl wait --for=condition=complete job/myjob

et vous pouvez également définir un délai d'attente :

kubectl wait --for=condition=complete --timeout=30s job/myjob

Answer 2

Cette commande vous permet de suivre visuellement l'état d'un travail :

kubectl get jobs myjob -w

En -w surveille les changements. Vous recherchez l'option SUCCESSFUL colonne pour afficher 1 .

Pour attendre dans un shell script, j'utiliserais cette commande :

until kubectl get jobs myjob -o jsonpath='{.status.conditions[? 
    (@.type=="Complete")].status}' | grep True ; do sleep 1 ; done

Answer 3

Vous pouvez utiliser les documents officiels Python kubernetes-client .

https://github.com/kubernetes-client/python

Créer une nouvelle virtualenv Python :

virtualenv -p python3 kubernetes_venv l'activer avec

source kubernetes_venv/bin/activate

et installer le client kubernetes avec :

pip install kubernetes

Créez un nouveau script et exécutez-le :

from kubernetes import client, config

config.load_kube_config()

v1 = client.BatchV1Api()
ret = v1.list_namespaced_job(namespace='<YOUR-JOB-NAMESPACE>', watch=False)
for i in ret.items:
    print(i.status.succeeded)

N'oubliez pas de configurer votre kubeconfig en ~/.kube/config et une valeur valide pour votre espace de noms -> '<YOUR-JOB-NAMESPACE>'

Answer 4

J'utiliserais -w o --watch :

$ kubectl get jobs.batch --watch
NAME     COMPLETIONS   DURATION   AGE
python   0/1           3m4s       3m4s

Answer 5

L'une ou l'autre de ces requêtes avec kubectl

kubectl get job test-job -o jsonpath='{.status.succeeded}'

o

kubectl get job test-job -o jsonpath='{.status.conditions[?(@.type=="Complete")].status}'