如何在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的调度程序。

1. 用/etc/kubernetes/manifests/kube-scheduler.yaml或
中的图像替换kube-scheduler的docker图像
2. 编辑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()