问题标签 [kubernetes-python-client]

Cloud Composer 文档明确指出：

由于 Kubernetes Python 客户端库存在问题，您的 Kubernetes pod 应设计为运行时间不超过一小时。

但是，它没有提供比这更多的上下文，而且我在 Kubernetes Python 客户端项目上找不到明确相关的问题。

为了测试它，我运行了一个 pod 两个小时，没有发现任何问题。什么问题造成了这种限制，它是如何体现的？

当我在 Airflow 1.10 版中使用KubernetesPodOperator运行 docker 映像时

一旦 pod 成功完成任务，airflow 会尝试通过 k8s 流客户端与 pod 建立连接来获取 xcom 值。

以下是我遇到的错误：

我为此使用 K8s 服务帐户

DAG 配置

xcom=真，

get_logs=真，

in_cluster=true

我一直在尝试将kubectl cp命令转换为它的等效kubernetes python client程序。我有以下代码：

上面的代码给了我以下错误：

我正在使用Python 3.6.3和kubernetes 1.13版本。

我正在 kubernetes python 客户端中创建一个程序，它在 pod 内卷曲一个 url 并期望输出json为str. 以下是我的程序：

上述程序返回以下输出：

正如您可以清楚地看到返回值的类型，str因此我无法使用 json 工具正确解析它。dict任何人都可以帮助我str以dict.

我想从 python 以编程方式将 SparkApplication 提交到Kubernetes 集群。

job.yaml像这样的工作定义

使用 运行没有问题kubectl apply -f job.yaml，但我不知道是否以及如何使用kubernetes-client以编程方式开始这项工作。

有谁知道如何做到这一点？

我尝试在 Google Kubernetes (GKE) 中以自动方式创建角色。

为此，我使用 python 客户端库，但我不想对 kubectl 和 kubeconfig 或 gcloud 有任何依赖，

我使用一个服务帐户（带有来自 GCP 的 json 密钥文件），它有权在命名空间中创建角色（它是一个集群管理员）。当我使用此命令给出的访问令牌时：

有用。

但是当我尝试自己生成令牌时，我可以创建命名空间和其他标准资源，但在角色方面出现此错误：

我使用的是同一个服务帐户，所以我猜 gcloud 所做的不仅仅是我的脚本。

这是我用来生成令牌的python代码：

以及创建角色的函数（生成 403 错误）：

如果我用从 gcloud 中提取的令牌短路 _get_token 方法，它就可以工作。

我想这与我创建令牌的方式有关（缺少范围？），但我没有找到任何关于它的文档。

回答 ：

添加范围就可以了！非常感谢 ：

I have the following CSR object in Kubernetes:

And I would like to approve it using the Python API client:

Now, the contents of the csr object are:

I would like to approve this cert programmatically, if I use kubectl to do it with (-v=10 will make kubectl output the http trafffic):

I get to see the PUT operation used to Approve my certificate:

So I need to PUT to the /approval resource of the certificate object. Now, how do I do it with the Python Kubernetes client?

我正在尝试将 python API 用于 kubernetes，但我似乎无法执行该请求。我认为管道对我来说并不清楚。

我正在按照这里的步骤操作：Kubernetes python 客户端：身份验证问题

在远程服务器上：

• 我设置了我的服务帐户并生成了链接中描述的秘密
• 我将令牌添加到我的代码中

我被拒绝连接。

• 我应该将集群中的任何信息导入本地客户端吗？
• 港口好吗？

输出：

当前本地客户端 kubectl 配置视图：

我已经设置了官方 Kubernetes Python 客户端（https://github.com/kubernetes-client/python）。

我正在运行 Python 代码以连接到 Kubernetes 集群，但它抛出了一个错误：

urllib3.exceptions.MaxRetryError: HTTPSConnectionPool(host='****', port=6443): url: /api/v1/namespaces/default/pods 超过最大重试次数（由 NewConnectionError(': 无法建立新的连接：[Errno 110] 连接超时'，））

安装要求：

kubectl在相同的配置$HOME/.kube/config和相同的代理设置下工作正常。

下面是我的代码：

我正在通过 Kubernetes API 代理动词从 pod 的 Web 服务器请求一些 JSON 数据。那是：

调用成功并返回一个str包含来自我的 pod 的 Web 服务的序列化 JSON 数据。不幸的是，res现在看起来像这样......这根本不是有效的 JSON，所以json.loads(res)拒绝解析它：

如您所见，字符串化响应看起来像 Python 字典，而不是有效的 JSON。关于如何安全地转换回正确的 JSON 或正确的 Python 的任何建议dict？