Как уменьшить количество повторов для кластера kubernetes в kubernetes-client-python - PullRequest
Новая
       71

Как уменьшить количество повторов для кластера kubernetes в kubernetes-client-python

0 голосов
/ 23 сентября 2019

Мне нужно уменьшить количество повторов для недоступного / удаленного кластера kubernetes с использованием kubernetes-client-python, в настоящее время по умолчанию оно равно 3. 

WARNING Retrying (Retry(total=2, connect=None, read=None, redirect=None, status=None)) after connection broken by 'NewConnectionError('<urllib3.connection.VerifiedHTTPSConnection object at 0x00000000096E3860>: Failed to establish a new connection: [Errno 10060] A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond',)': /api/v1/pods

WARNING Retrying (Retry(total=1,....... /api/v1/pods

WARNING Retrying (Retry(total=0,....... /api/v1/pods

После 3 повторных попыток возникает исключение.

Есть ли способ уменьшить количество.

Пример кода 

from kubernetes import client, config

config.load_kube_config(config_file='location-for-kube-config')

v1 = client.CoreV1Api()
ret = v1.list_pod_for_all_namespaces()
for i in ret.items:
    print("%s\t%s\t%s" % (i.status.pod_ip, i.metadata.namespace, i.metadata.name))

1 Ответ

0 голосов
/ 23 сентября 2019

К сожалению, кажется, что это невозможно, потому что:

Python-клиент использует urlib3 PoolManager для отправки запросов, как вы можете видеть там

https://github.com/kubernetes-client/python/blob/master/kubernetes/client/rest.py#L162

r = self.pool_manager.request(method, url,
                              body=request_body,
                              preload_content=_preload_content,
                              timeout=timeout,
                              headers=headers)

ипод ней он использует urlopen с параметрами по умолчанию, как вы можете видеть

https://urllib3.readthedocs.io/en/1.2.1/pools.html#urllib3.connectionpool.HTTPConnectionPool.urlopen

urlopen(..., retries=3, ...)

, так что теперь есть способ передать другое значение - вы должны форкофициальная библиотека для этого.

...