如何解决如何在kubernetes中更改默认的kube-scheduler
This doc讲述了如何运行多个调度程序。但是我无法理解如何确定默认调度程序?它基于{{userFile?.file}}
选项吗?
我可以告诉Kubernetes使用my-custom-scheduler作为默认调度程序而不是kube-scheduler吗?
除了Pod / Deployment规范中的--leader-elect
之外,还有另一种方法可以指定调度程序。
解决方法
如何确定默认调度程序?它是否基于--leader-elect 选项?
不,它不是基于--leader-elect
的,后者是在启用了领导者选举的情况下运行同一调度程序的多个复制副本,因此在任何给定时间点只有一个副本充当领导者。
我可以告诉Kubernetes使用my-custom-scheduler作为默认调度程序吗 而不是kube-scheduler?
您无需在kubernetes集群级别更改默认调度程序,因为您可以告诉kubernetes在pod规范中使用自定义调度程序。下面的示例使用my-scheduler
代替default-scheduler
apiVersion: v1
kind: Pod
metadata:
name: pod-with-custom-scheduler
spec:
schedulerName: my-scheduler
containers:
- name: pod-with-custom-scheduler
image: k8s.gcr.io/pause:2.0
上方的窗格将由my-scheduler
而不是默认的kube-scheduler进行调度。如果您省略schedulerName
,则默认情况下会安排kube-scheduler
从doc
默认情况下,一个调度程序名称为default-scheduler的配置文件为 创建。此配置文件包括上述默认插件。 声明多个配置文件时,每个配置文件都有唯一的调度程序名称 其中是必需的。
如果Pod没有指定调度程序名称,则kube-apiserver会对其进行设置 默认调度程序。因此,具有此调度程序名称的配置文件 应该可以安排这些豆荚的时间
因此,您可以将现有的kube调度程序替换为名称为default-scheduler
的调度程序。
- 用
/etc/kubernetes/manifests/kube-scheduler.yaml
或 中的图像替换kube-scheduler的docker图像
- 编辑kube调度程序部署并更改映像
首先,请确保配置自定义调度程序,并确保禁用--leader-elect=false
。您可以像这样在规范部分的pod中使用它
spec:
containers:
- image: nginx
name: nginx
schedulerName: your-scheduler-name
,
我还需要用自定义的调度程序替换默认的 Kubernetes 调度程序。我是这样做的。
我认为这是答案的主要部分。我移动(或删除)文件 etc/kubernetes/manifests/kube-scheduler.yaml
。这将禁用(或删除)默认的 Kubernetes 调度程序。此外,您可以通过在删除文件前后运行 kubectl get po -n kube-system | grep -i scheduler
来检查它是否已被删除。
既然禁用了默认调度程序,我就有了一个执行调度的自定义调度程序(一个 python 脚本)。我只是运行它。这是下面的脚本。它不是很干净,但它应该可以工作。您可以根据需要对其进行调整。 请注意,我在清理脚本后并没有尝试运行它。可能存在小错误。
#!/usr/bin/env python
import time
import random
import json
from kubernetes import client,config,watch
config.load_kube_config()
v1 = client.CoreV1Api()
def get_request_time(hostname):
# You can do some magic here.
print("returning 1.2")
return 1.2
def best_request_time(nodes):
if not nodes:
return []
node_times = [get_request_time(hostname) for hostname in nodes]
best_node = nodes[node_times.index(min(node_times)) + 1]
print("Best node: " + best_node)
return best_node
def nodes_available():
ready_nodes = []
for n in v1.list_node().items:
# This loops over the nodes available. n is the node. We are trying to schedule the pod on one of those nodes.
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="<YOUR-NAMESPACE-HERE"): # You can use "default" as a namespace.
target=client.V1ObjectReference()
target.kind="Node"
target.apiVersion="v1"
target.name= node
meta=client.V1ObjectMeta()
meta.name=name
body=client.V1Binding(target=target)
body.metadata=meta
return v1.create_namespaced_binding(namespace,body,_preload_content=False)
def main():
w = watch.Watch()
for event in w.stream(v1.list_namespaced_pod,"<YOUR-NAMESPACE-HERE>"):
# We get an "event" whenever a pod needs to be scheduled
if event['object'].status.phase == "Pending": # and event['object'].spec.scheduler_name == scheduler_name:
try:
arg2 = best_request_time(nodes_available())
print("Scheduling " + event['object'].metadata.name)
res = scheduler(event['object'].metadata.name,arg2)
except client.rest.ApiException as e:
print("exception")
print(json.loads(e.body)['message'])
if __name__ == '__main__':
main()
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。