python - Kubernetes Python 客户端错误 create_namespaced_binding: (409) 原因:冲突
问题描述
我正在使用 k8 v1.7 和Python Client v2.0。我的自定义调度程序检测到一个挂起的 pod 并成功调度它。但是,在将 pod 分配给节点后,它会抱怨该 pod 已分配给节点,尽管它只是由调度程序本身分配的。这有什么要担心的吗?或者我该如何解决这个问题?
错误信息
create_namespaced_binding: (409)
Reason: Conflict
HTTP response headers: HTTPHeaderDict({'Date': 'Tue, 19 Jun 2018 16:14:57 GMT', 'Content-Length': '289', 'Content-Type': 'application/json'})
HTTP response body: {"kind":"Status","apiVersion":"v1","metadata":{},"status":"Failure","message":"Operation cannot be fulfilled on pods/binding \"ps0-16-r935x\": pod ps0-16-r935x is already assigned to node \"blipp65\"","reason":"Conflict","details":{"name":"ps0-16-r935x","kind":"pods/binding"},"code":409}
调度程序.py
from kubernetes import client, config, watch
from kubernetes.client.rest import ApiException
config.load_kube_config()
v1 = client.CoreV1Api()
scheduler_name = 'my-custom-scheduler-v1'
def nodes_available():
ready_nodes = []
for n in v1.list_node().items:
for status in n.status.conditions:
if status.status == 'True' and status.type == 'Ready':
ready_nodes.append(n.metadata.name)
return ready_nodes
def scheduler(name, node, namespace='default'):
body = client.V1Binding()
target = client.V1ObjectReference()
target.kind = 'Node'
target.apiVersion = 'v1'
target.name = node
meta = client.V1ObjectMeta()
meta.name = name
body.target = target
body.metadata = meta
return v1.create_namespaced_binding_binding(name, namespace, body)
def main():
w = watch.Watch()
for event in w.stream(v1.list_namespaced_pod, 'default'):
if event['object'].status.phase == 'Pending' and event['object'].spec.scheduler_name == scheduler_name:
print "Pending Found"
try:
res = scheduler(event['object'].metadata.name,random.choice(nodes_available()))
print "success"
except Exception as a:
print ("Exception when calling CoreV1Api->create_namespaced_binding: %s\n" % a)
POD YML 文件
apiVersion: v1
kind: Pod
metadata:
name: shoeb-pod
spec:
schedulerName: my-custom-scheduler-v1
containers:
- name: redis
image: redis
更新于 2019-06-03
我刚刚添加了更新的 main 方法(根据@VAS 的回答,谢谢)以找到PENDING
尚未安排好的正确 pod。请看我的回答。
解决方案
创建 pod 时,调度程序会收到三个“待处理”事件:
- Pod 尚未安排 (
'node_name': None, 'status': {'conditions': None,...}
) - Pod 已安排 (
'node_name': 'some_node_name','status': {'conditions': [...,'status': True, 'type':'PodScheduled'],...}
) - Pod 已初始化但尚未准备好 (
'node_name': 'minikube','status': {'conditions': [...,'status': True, 'type':'Initialized'], ... ,'status': False, 'type':'Ready']}
)
因此,您的自定义调度程序应该在第一个事件时将 pod 绑定到节点,检查 pod 的状态并确保在第二个事件出现时调度它,然后在第三个事件出现时检查 pod 是否已初始化。
如果出现问题,调度程序可能需要考虑之前的错误,并可能尝试将 pod 调度到不同的节点。
在您的情况下,您的调度程序会像第一个一样威胁所有三个事件,并一次又一次地尝试调度 pod。这就是为什么您会看到“ pod xxx is already assigned to node yyy
”错误。
推荐阅读
- unicode - “凸起的先生标志”未正确呈现
- php - 如何从字符串javascript中获取价值?
- javascript - 具有“获取”功能的 Javascript 无法在 Android 5.1.1 上运行
- migration - 部分事件源应用程序,以及从常规到事件源应用程序的路线图
- rust - Rust - 所有权和借款
- javascript - 我们应该更喜欢 Chai 的 `to.be.an('undefined')` 还是 `to.equal(undefined)`?
- middleware - 如何使用 Adaptive Autosar 传输视频数据
- teamcity - 带有 AWS cloudformation 的 TeamCity 卡在 AgentService 上
- python - 如何在 Django 2.1 中使用多个表单?
- angular - Angular ERROR TypeError:无法读取 null 的属性“isd_code”