用webhook+flask完成一个插件，在k8s集群中，master部署一个pod，调度到了node1上，node1弹出提示让用户选择y/n，来继续调度或者拒绝并停止调度

Webhook是一种HTTP POST请求，常用于系统集成、事件通知等场景，而Flask是一个轻量级的Python Web服务器框架，可以用来创建API服务。为了在Kubernetes(K8s)环境中通过Webhook和Flask实现这个功能，你需要做以下几个步骤：

1. **设置Flask应用**:
创建一个简单的Flask应用程序，监听特定端口，例如`5000`，用于接收来自K8s的Webhook请求。

from flask import Flask, request, jsonify

app = Flask(__name__)

@app.route('/hook', methods=['POST'])
def webhook_handler():
    # 在这里处理接收到的请求数据
    data = request.get_json()
    user_choice = prompt_user(data['namespace'], data['pod_name'])  # 调用模拟用户输入的函数
    if user_choice == 'y':
        response = {'status': 'approved'}
    else:
        response = {'status': 'rejected'}
    return jsonify(response)

def prompt_user(namespace, pod_name):
    # 这里需要模拟用户交互，实际生产环境可能会用到前端界面或者其他交互方式
    print(f"Namespace: {namespace}, Pod Name: {pod_name} - Do you want to approve (y/n)?")
    user_input = input().lower()  # 获取用户的输入
    return user_input

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000)

2. **配置K8s webhook**:
需要在K8s集群中创建一个`MutatingWebhookConfiguration`资源，指定Flask应用作为Webhook服务，并提供必要的认证信息（如有需要）。

3. **部署Webhook到K8s**:
将上面的Flask应用打包成Docker镜像，并创建Deployment或者StatefulSet来部署。同时，需要创建对应的Service来暴露Webhook的访问端点。

4. **关联到Pod调度**:
当有新的Pod需要调度并且设置了相应的Webhook策略时，K8s会向你的Flask应用发送POST请求，其中包含有关Pod的信息。根据用户的响应，你可以修改Pod的状态（如继续调度或拒绝）。