Клиент kubernetes python был приостановлен при работе с методом watch.stream

Я пытаюсь просмотреть ресурс kubernetes, такой как pods, с клиентом kubernetes python (версия 9.0), но метод watch.stream() кажется приостановленным, когда я смотрю ресурс k8s через несколько минут.

v1 = client.CoreV1Api()
w = watch.Watch()
for resource in w.stream(v1.list_namespaced_pod):
    dosomething(resource)

как мне всегда продолжать смотреть модуль kebernetes

Почему в Python есть оператор "pass"?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Некоторые методы, о которых вы не знали, что они существуют в Python
Некоторые методы, о которых вы не знали, что они существуют в Python
Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...
Основы Python Часть I
Основы Python Часть I
Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:
Оптимизация кода с помощью тернарного оператора Python
Оптимизация кода с помощью тернарного оператора Python
И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это
Советы по эффективной веб-разработке с помощью Python
Советы по эффективной веб-разработке с помощью Python
Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.
1
0
488
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вероятно, вы нажимаете этот проблема, и в качестве обходного пути, упомянутого в этом комментарий, вы можете попробовать, как показано ниже:

from kubernetes import client, config, watch
from urllib3.exceptions import ProtocolError
config.load_kube_config()
api_instance = client.CoreV1Api()
while True:
  w = watch.Watch()
  try:
    for event in w.stream(api_instance.list_namespaced_pod, namespace = "default"):
      print("Event: %s %s %s" % (event['type'],event['object'].kind, event['object'].metadata.name))
  except ProtocolError:
    print("watchPodEvents ProtocolError, continuing..")

Надеюсь, поможет!

спасибо, но цикл while True не работает, может быть брандмауэр обрывает соединение, я собираюсь переустановить клиент kubernetes

joey132 23.05.2019 05:31

Готово, брандмауэр отключил соединение

joey132 23.05.2019 06:19

Другие вопросы по теме