广深运维三档技能完整分析报告

// 中级标准配置：Jenkins Pipeline 构建→镜像→K8s 部署→失败自动回滚
pipeline {
    agent { label 'k8s-agent' }
    environment {
        REGISTRY = 'harbor.company.com'
        IMAGE     = "${REGISTRY}/app/${env.JOB_NAME}:${env.BUILD_NUMBER}"
    }
    stages {
        stage('单元测试') {
            steps { sh 'pytest tests/ --cov=app --cov-fail-under=70' } // 覆盖率低于70%直接失败
        }
        stage('镜像构建 & 扫描') {
            steps {
                sh 'docker build -t ${IMAGE} .'
                sh 'trivy image --exit-code 1 --severity CRITICAL ${IMAGE}' // CRITICAL 漏洞拦截
                sh 'docker push ${IMAGE}'
            }
        }
        stage('灰度部署 10%') {
            steps {
                sh 'helm upgrade --install app-canary ./chart \'
                    '--set image.tag=${BUILD_NUMBER} \'
                    '--set replicaCount=1 -n production'
                sh 'sleep 60 && kubectl rollout status deploy/app-canary -n production'
            }
        }
        stage('全量发布') {
            steps { sh 'helm upgrade app ./chart --set image.tag=${BUILD_NUMBER} -n production' }
        }
    }
    post {
        failure {
            sh 'helm rollback app -n production' // 失败自动回滚上一版
            dingTalk message: "❌ 发布失败：${env.JOB_NAME} #${env.BUILD_NUMBER}"
        }
        success { dingTalk message: "✅ 发布成功：${env.JOB_NAME} #${env.BUILD_NUMBER}" }
    }
}

// 高级岗核心能力：Go 开发 K8s Operator（controller-runtime 框架）
package main

import (
    "context"
    "fmt"
    appsv1 "k8s.io/api/apps/v1"
    corev1 "k8s.io/api/core/v1"
    "sigs.k8s.io/controller-runtime/pkg/client"
    "sigs.k8s.io/controller-runtime/pkg/reconcile"
)

// Reconcile 是控制器核心：持续对比「期望状态」与「实际状态」，做出调整
func (r *AppReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error) {
    // 1. 从缓存读取自定义资源（走 Informer 缓存，不直接打 apiserver）
    app := &v1.MyApp{}
    if err := r.Get(ctx, req.NamespacedName, app); err != nil {
        return reconcile.Result{}, client.IgnoreNotFound(err) // 资源已删除，忽略
    }

    // 2. 防止 finalizer 导致删除卡住（生产必须处理）
    if !app.DeletionTimestamp.IsZero() {
        return r.handleDeletion(ctx, app)
    }

    // 3. 对比期望 vs 实际，差异调整（幂等！重复调谐不产生副作用）
    deploy := &appsv1.Deployment{}
    if err := r.Get(ctx, req.NamespacedName, deploy); err != nil {
        return reconcile.Result{}, r.createDeployment(ctx, app) // 不存在则创建
    }

    // 4. 更新 Status 子资源（记录观察状态，供 kubectl get 查看）
    app.Status.AvailableReplicas = deploy.Status.AvailableReplicas
    _ = r.Status().Update(ctx, app)

    fmt.Printf("✅ Reconciled: %s/%s\n", app.Namespace, app.Name)
    return reconcile.Result{}, nil
}