Невозможно выполнить в модуле, используя kubernetes-cli в Python, даже после использования потокового API - PullRequest
Новая
       33

Невозможно выполнить в модуле, используя kubernetes-cli в Python, даже после использования потокового API

1 голос
/ 28 мая 2019

Я следую официальной документации и, к моему удивлению, запрос просто не сработает.

Я пытался прочитать несколько вопросов и ответов, но тщетно.Я установил stream api для использования, но ошибка не исчезла.

Мой код: 

from __future__ import print_function
import time
import kubernetes.client
from kubernetes.client.rest import ApiException
from pprint import pprint
from kubernetes import client, config, stream
stream = stream.stream

# Configure API key authorization: BearerToken
configuration = kubernetes.client.Configuration()
configuration.host = "https://my_aws_server.amazonaws.com"
configuration.verify_ssl = False
configuration.api_key['authorization'] = "some_token"
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
configuration.api_key_prefix['authorization'] = 'Bearer'
configuration.debug = True

api_instance = kubernetes.client.CoreV1Api(
    kubernetes.client.ApiClient(configuration))
name = 'jupyter-ankita'  # str | name of the PodExecOptions
namespace = 'jhub'  # str | object name and auth scope, such as for teams and projects
# str | Command is the remote command to execute. argv array. Not executed within a shell. (optional)
command = 'echo "hail aviral"'
# bool | Redirect the standard error stream of the pod for this call. Defaults to true. (optional)
stderr = True
# bool | Redirect the standard input stream of the pod for this call. Defaults to false. (optional)
stdin = True
# bool | Redirect the standard output stream of the pod for this call. Defaults to true. (optional)
stdout = True
# bool | TTY if true indicates that a tty will be allocated for the exec call. Defaults to false. (optional)
tty = True

try:
    api_response = stream(api_instance.connect_post_namespaced_pod_exec(
        name, namespace, command=command, stderr=stderr, stdin=stdin, stdout=stdout)
    )
    pprint(api_response)
except ApiException as e:
    print("Exception when calling CoreV1Api->connect_post_namespaced_pod_exec: %s\n" % e)

Я хочу выполнить команду, но вместо этого я сталкиваюсь с ошибкой: 

Exception when calling CoreV1Api->connect_post_namespaced_pod_exec: (400)
Reason: Bad Request
HTTP response headers: HTTPHeaderDict({'Audit-Id': '88df8863-61b1-4fe7-9d39-d0e6059ea993', 'Content-Type': 'application/json', 'Date': 'Tue, 28 May 2019 14:04:38 GMT', 'Content-Length': '139'})
HTTP response body: {"kind":"Status","apiVersion":"v1","metadata":{},"status":"Failure","message":"Upgrade request required","reason":"BadRequest","code":400}

Мой клиент SSL обновлен, я использую Python3.7 из brew на MacOS.

Также используется в Ubuntu, та же ошибка.

Версии: 

Client Version: version.Info{Major:"1", Minor:"12", GitVersion:"v1.12.3", GitCommit:"some_no", GitTreeState:"clean", BuildDate:"2018-11-27T01:14:37Z", GoVersion:"go1.11.2", Compiler:"gc", Platform:"darwin/amd64"}
Server Version: version.Info{Major:"1", Minor:"12+", GitVersion:"v1.12.6-eks-d69f1b", GitCommit:"some_no", GitTreeState:"clean", BuildDate:"2019-02-28T20:26:10Z", GoVersion:"go1.10.8", Compiler:"gc", Platform:"linux/amd64"}
  • ОБНОВЛЕНИЕ: я изменил свои функции на: 
api_response = stream( api_instance.connect_post_namespaced_pod_exec, name, namespace, command=command, stderr=stderr, stdin=stdin, stdout=stdout )

, и он смог выполнить.Но теперь я сталкиваюсь со следующей ошибкой: 

('rpc error: code = 2 desc = oci runtime error: exec failed: '
 'container_linux.go:262: starting container process caused "exec: \\"echo '
 '\\\\\\"hail aviral\\\\\\"\\": executable file not found in $PATH"\n'
 '\r\n')

Это говорит о том, что exec не удалось.

1 Ответ

0 голосов
/ 30 мая 2019

Отсутствует точка входа для удаленного выполнения команды. Попробуйте это: 

command = [
    '/bin/sh',
    '-c',
    'echo hail aviral']
...