Сервер Kubernetes API, обслуживающий логи

Question

Запросы REST API, GET , POST , PUT и т.д. к серверу Kubernetes API относятся запросы, ответы и простые для понимания, такие как kubectl create <something>, Интересно, как сервер API обслуживает журналы pod, когда я делаю kubectl logs -f <pod-name> (и подобные операции, такие как kubectl attach <pod>), Это просто http ответ на GET в цикле?

Answer 1

Да, похоже, что в настоящее время это просто HTTP GET, что kubectl использует, когда смотрит на источник logs.go, хотя, кажется, есть желание объединить и обновить пару команд (exec, port-forward, logsи т. д.) в WebSockets.

Показаны отличные предложения Мачей в действии:

$ kubectl run test --image centos:7 \
                      -- sh -c "while true ; do echo Work ; sleep 2 ; done"
$ kubectl get po
NAME                    READY   STATUS    RESTARTS   AGE
test-769f6f8c9f-2nx7m   1/1     Running   0          2m

$ kubectl logs -v9  -f test-769f6f8c9f-2nx7m
I1019 13:49:34.282007   71247 loader.go:359] Config loaded from file /Users/mhausenblas/.kube/config
I1019 13:49:34.284698   71247 loader.go:359] Config loaded from file /Users/mhausenblas/.kube/config
I1019 13:49:34.292620   71247 loader.go:359] Config loaded from file /Users/mhausenblas/.kube/config
I1019 13:49:34.293136   71247 round_trippers.go:386] curl -k -v -XGET  -H "Accept: application/json, */*" -H "User-Agent: kubectl/v1.12.0 (darwin/amd64) kubernetes/0ed3388" 'https://192.168.64.13:8443/api/v1/namespaces/default/pods/test-769f6f8c9f-2nx7m'
I1019 13:49:34.305016   71247 round_trippers.go:405] GET https://192.168.64.13:8443/api/v1/namespaces/default/pods/test-769f6f8c9f-2nx7m 200 OK in 11 milliseconds
I1019 13:49:34.305039   71247 round_trippers.go:411] Response Headers:
I1019 13:49:34.305047   71247 round_trippers.go:414]     Date: Fri, 19 Oct 2018 12:49:34 GMT
I1019 13:49:34.305054   71247 round_trippers.go:414]     Content-Type: application/json
I1019 13:49:34.305062   71247 round_trippers.go:414]     Content-Length: 2390
I1019 13:49:34.305125   71247 request.go:942] Response Body: {"kind":"Pod","apiVersion":"v1","metadata":{"name":"test-769f6f8c9f-2nx7m","generateName":"test-769f6f8c9f-","namespace":"default","selfLink":"/api/v1/namespaces/default/pods/test-769f6f8c9f-2nx7m","uid":"0581b0fa-d39d-11e8-9827-42a64713caf8","resourceVersion":"892912","creationTimestamp":"2018-10-19T12:46:39Z","labels":{"pod-template-hash":"3259294759","run":"test"},"ownerReferences":[{"apiVersion":"apps/v1","kind":"ReplicaSet","name":"test-769f6f8c9f","uid":"057f3ad4-d39d-11e8-9827-42a64713caf8","controller":true,"blockOwnerDeletion":true}]},"spec":{"volumes":[{"name":"default-token-fbx4m","secret":{"secretName":"default-token-fbx4m","defaultMode":420}}],"containers":[{"name":"test","image":"centos:7","args":["sh","-c","while true ; do echo Work ; sleep 2 ; done"],"resources":{},"volumeMounts":[{"name":"default-token-fbx4m","readOnly":true,"mountPath":"/var/run/secrets/kubernetes.io/serviceaccount"}],"terminationMessagePath":"/dev/termination-log","terminationMessagePolicy":"File","imagePullPolicy":"IfNotPresent"}],"restartPolicy":"Always","terminationGracePeriodSeconds":30,"dnsPolicy":"ClusterFirst","serviceAccountName":"default","serviceAccount":"default","nodeName":"minikube","securityContext":{},"schedulerName":"default-scheduler","tolerations":[{"key":"node.kubernetes.io/not-ready","operator":"Exists","effect":"NoExecute","tolerationSeconds":300},{"key":"node.kubernetes.io/unreachable","operator":"Exists","effect":"NoExecute","tolerationSeconds":300}]},"status":{"phase":"Running","conditions":[{"type":"Initialized","status":"True","lastProbeTime":null,"lastTransitionTime":"2018-10-19T12:46:39Z"},{"type":"Ready","status":"True","lastProbeTime":null,"lastTransitionTime":"2018-10-19T12:46:40Z"},{"type":"ContainersReady","status":"True","lastProbeTime":null,"lastTransitionTime":null},{"type":"PodScheduled","status":"True","lastProbeTime":null,"lastTransitionTime":"2018-10-19T12:46:39Z"}],"hostIP":"192.168.64.13","podIP":"172.17.0.11","startTime":"2018-10-19T12:46:39Z","containerStatuses":[{"name":"test","state":{"running":{"startedAt":"2018-10-19T12:46:39Z"}},"lastState":{},"ready":true,"restartCount":0,"image":"centos:7","imageID":"docker-pullable://centos@sha256:67dad89757a55bfdfabec8abd0e22f8c7c12a1856514726470228063ed86593b","containerID":"docker://5c25f5fce576d68d743afc9b46a9ea66f3cd245f5075aa95def623b6c2d93256"}],"qosClass":"BestEffort"}}
I1019 13:49:34.316531   71247 loader.go:359] Config loaded from file /Users/mhausenblas/.kube/config
I1019 13:49:34.317000   71247 round_trippers.go:386] curl -k -v -XGET  -H "Accept: application/json, */*" -H "User-Agent: kubectl/v1.12.0 (darwin/amd64) kubernetes/0ed3388" 'https://192.168.64.13:8443/api/v1/namespaces/default/pods/test-769f6f8c9f-2nx7m/log?follow=true'
I1019 13:49:34.339341   71247 round_trippers.go:405] GET https://192.168.64.13:8443/api/v1/namespaces/default/pods/test-769f6f8c9f-2nx7m/log?follow=true 200 OK in 22 milliseconds
I1019 13:49:34.339380   71247 round_trippers.go:411] Response Headers:
I1019 13:49:34.339390   71247 round_trippers.go:414]     Content-Type: text/plain
I1019 13:49:34.339407   71247 round_trippers.go:414]     Date: Fri, 19 Oct 2018 12:49:34 GMT
Work
Work
Work
^C

Answer 2

Мой совет всегда проверять, что kubectl делает под прикрытием, и для этого использования -v=9 с вашей командой. Он предоставит вам полный запрос и ответы, которые идут между клиентом и сервером.

Answer 3

Если вы извлекаете любой объект Kubernetes, используя kubectl на самом высоком уровне отладки -v 9 с возможностью потоковой передачи -fкак например kubectl logs -f <pod-name> -v 9, вы можете понять, что kubectl прохождение follow=true Пометить запрос API, получив соответствующие журналы от целевого модуля Pod, а также направить их на выход:

curl -k -v -XGET -H "Принять: application / json, /" -H "Пользователь-агент: kubectl / v1.12.1 (linux / amd64) kubernetes / 4ed3216" ' https://api_server_ip/api/v1/namespaces/default/pods/Pod-name/log?follow=true'

Вы можете рассмотреть возможность запуска собственных запросов API, выполнив следующие шаги:

Получить токен для авторизации:

 MY_TOKEN="$(kubectl get secret <default-secret> -o jsonpath='{$.data.token}' | base64 -d)"

Затем вы можете вручную получить необходимые данные с сервера API напрямую:

curl -k -v -H "Authorization : Bearer $MY_TOKEN" https://API_server_IP/api/v1/namespaces/default/pods