2

该文档讲述了如何运行多个调度程序。但我无法理解默认调度程序是如何决定的？是基于--leader-elect期权吗？

我可以告诉 Kubernetes 使用 my-custom-scheduler 作为默认调度程序而不是 kube-scheduler 吗？schedulerName除了Pod/Deployment 规范之外，还有其他方法可以指定调度程序 。

4

3 回答 3

2

默认调度器是如何决定的？它是否基于 --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

上面的 pod 将由my-scheduler默认的 kube-scheduler 调度。如果你省略了，schedulerName那么它将默认被调度 kube-scheduler

从文档

默认情况下，会创建一个调度程序名称为 default-scheduler 的配置文件。此配置文件包括上述默认插件。当声明多个配置文件时，每个配置文件都需要一个唯一的调度程序名称。

如果 Pod 没有指定调度器名称，kube-apiserver 会将其设置为 default-scheduler。因此，应该存在具有此调度程序名称的配置文件来安排这些 pod

因此，您可以将现有的 kube 调度程序替换为带有 name 的调度程序default-scheduler。

  1. 将 kube-scheduler 的 docker 镜像替换为您的镜像/etc/kubernetes/manifests/kube-scheduler.yaml或
  2. 编辑 kube 调度器部署并更改镜像
于 2020-09-10T13:28:41.617 回答
1

首先确保配置自定义调度程序并确保禁用--leader-elect=false. 并且您可以像这样在规范部分下的 pod 中使用它

spec: 
  containers:
  - image: nginx
    name: nginx
  schedulerName: your-scheduler-name
于 2020-09-10T13:38:52.023 回答
1

我还需要用自定义的调度程序替换默认的 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()
于 2021-01-22T17:19:32.440 回答