关于kubernetes:kubernetes的Admission-Webhook探析

9次阅读

共计 3779 个字符，预计需要花费 10 分钟才能阅读完成。

Admission Webhook 是 kubernetes 中的准入控制器，用于在 apiserver 中，对 API Request 进行拦挡，而后对 API Request 进行特定的解决，解决操作包含：

Mutating: 批改 API Request 中的对象；
Validating: 校验 API Request 中的对象，若校验非法，则间接返回 client，不再持续；

apiserver 提供了 Admission Webhook 的扩大机制，容许用户自定义 webhook，而后注册到 apiserver 上就能够发挥作用了。

API Request 在 apiserver 中的处理过程：

认证：通常是 client 端提供证书；
鉴权：校验 client 是否有操作相应资源的权限，应用 rbac 实现;
MutatingAdmission:
- 对传入的资源对象进行批改；
- 用户能够注册自定义的 webhook；
Schema Validation: 对传入对象的 schema 进行校验；
ValiatingAdmission:
- 对传入的资源对象进行校验，若校验失败，则间接返回 client；
- 用户能够注册自定义的 webhook；
最初，将对象存入 etcd；

用户自定义的 webhook 通常应用 deploy 部署，同时部署对应的 service，在将 webhook 注册到 apiserver 时，提供 service 的名称以及拜访的 url path，这样 apiserver 就能够应用自定义 webhook 的性能逻辑了。

apiserver 与 webhook 之间的通信接口为 /api/admission/v1/AdmissionReview 构造。

apiserver 与自定义 webhook 之间通过 http 通信，其 Request 和 Response 均是 /api/admission/v1/AdmissionReview 构造，也就是说：

自定义 webhook 在解决 http 申请时，须要将 requestBody 反序列化为 AdmissionReview 构造；
自定义 webhook 在发送 http 响应后，须要结构 AdmissionReview 构造，将其序列化后发送进来；

AdmissionReview 构造既蕴含 Request，也蕴含 Response:

// AdmissionReview describes an admission review request/response.
type AdmissionReview struct {
    metav1.TypeMeta `json:",inline"`
    // Request describes the attributes for the admission request.
    // +optional
    Request *AdmissionRequest `json:"request,omitempty" protobuf:"bytes,1,opt,name=request"`
    // Response describes the attributes for the admission response.
    // +optional
    Response *AdmissionResponse `json:"response,omitempty" protobuf:"bytes,2,opt,name=response"`
}

AdmissionRequest 中封装了发送给 apiserver 的申请信息，蕴含咱们创立、更新、删除的 Deploy/Service/Pod 等信息，比方：

{
  "apiVersion": "admission.k8s.io/v1",
  "kind": "AdmissionReview",
  "request": {
    # Random uid uniquely identifying this admission call
    "uid": <random uid>,
    ...
    "object": {"apiVersion":"v1","kind":"Pod",...},
    ...
    }
}

AdmissionResponse 封装了准入管制的后果:

对于 Mutating: 须要返回批改对象的 Patch；
对于 Validating: 须要返回对象的校验后果，若校验失败，还要带上 errMsg；

比方，Mutating 的 AdmissionResponse:

{
  "apiVersion": "admission.k8s.io/v1",
  "kind": "AdmissionReview",
  "response": {
    "uid": "<value from request.uid>",
    "allowed": true/false,
    "status": {
      "code": <optional http status code, ex: 200/403>,
      "message": "optional message"
    },
    "patchType": "JSONPatch",
    "patch": <base64 encoded JSON patch>
  }
}

比方，Validating 的 AdmissionResponse:

{
  "apiVersion": "admission.k8s.io/v1",
  "kind": "AdmissionReview",
  "response": {
    "uid": "<value from request.uid>",
    "allowed": true/false,
    "status": {
      "code": <optional http status code, ex: 200/403>,
      "message": "optional message"
    }
  }
}

webhook 要注册到 apiserver 后能力失效。

webhook 注册到 apiserver 时，须要通知 apiserver:

webhook 的 svc 名称、命名空间；
webhook 的 URL Path；
webhook 作用的指标对象的筛选规定；
webhook 操作的指标对象及操作；

对于 Mutating，注册由 MutatingWebhookConfiguration 资源类型形容，创立该资源对象即意味着注册，比方：

apiVersion: admissionregistration.k8s.io/v1
kind: MutatingWebhookConfiguration
metadata:
  name: mutating-webhook-example-cfg
  labels:
    app: admission-webhook-example
webhooks:
  - name: mutating-example.com
    clientConfig:
      service:                                // webhook 的 svc
        name: admission-webhook-example-svc
        namespace: default
        path: "/mutate"                        // webhook 的 url path
      caBundle: ${CA_BUNDLE}
    rules:                                    // 操作的资源
      - operations: ["CREATE"]
        apiGroups: ["apps", ""]
        apiVersions: ["v1"]
        resources: ["deployments","services"]
    namespaceSelector:                        // 指标对象的筛选规定
      matchLabels:
        admission-webhook-example: enabled

对于 Validating，注册由 ValidatingWebhookConfiguration 资源类型形容，创立该资源对象即意味着注册：

apiVersion: admissionregistration.k8s.io/v1beta1
kind: ValidatingWebhookConfiguration
metadata:
  name: validation-webhook-example-cfg
  labels:
    app: admission-webhook-example
webhooks:
  - name: validating-example.com
    clientConfig:
      service:                                // webhook 的 svc
        name: admission-webhook-example-svc
        namespace: default
        path: "/validate"                    // webhook 的 url path
      caBundle: ${CA_BUNDLE}
    rules:                                    // 操作的资源
      - operations: ["CREATE"]
        apiGroups: ["apps", ""]
        apiVersions: ["v1"]
        resources: ["deployments","services"]
    namespaceSelector:                        // 指标对象的筛选规定
      matchLabels:
        admission-webhook-example: enabled

1.https://www.qikqiak.com/post/k8s-admission-webhook/
2.AdmissionReview 的构造：https://github.com/kubernetes/api/blob/master/admission/v1/types.go

正文完