Kubernetes Operator ģʽʵս

引言

Kubernetes Operator 是一种扩展 Kubernetes API 的模式，它允许开发者将运维知识编码成自动化程序。Operator 本质上是一个自定义控制器，通过监听自定义资源（CRD）的变化，自动执行复杂的运维任务。

二、Operator 核心原理

Operator 基于控制循环（Control Loop）模式工作：

1. 观察（Observe）：获取当前集群状态
2. 分析（Diff）：对比当前状态与期望状态
3. 行动（Act）：执行操作使当前状态趋近期望状态

这个循环不断运行，确保系统始终处于期望状态。

三、client-go 核心组件

• Informer：监听资源变化并维护本地缓存
• WorkQueue：解耦接收事件与处理事件
• Lister：从本地缓存读取数据，减轻 API Server 压力
• Indexer：为缓存添加自定义索引

四、Operator SDK 实战

func (r *MyAppReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
    // 1. 获取自定义资源
    var myApp myappv1.MyApp
    if err := r.Get(ctx, req.NamespacedName, &myApp); err != nil {
        return ctrl.Result{}, client.IgnoreNotFound(err)
    }
    
    // 2. 确保 Deployment 存在
    deploy := &appsv1.Deployment{}
    err := r.Get(ctx, types.NamespacedName{
        Name: myApp.Name, Namespace: myApp.Namespace,
    }, deploy)
    
    if apierrors.IsNotFound(err) {
        // 创建 Deployment
        newDeploy := r.constructDeployment(&myApp)
        if err = r.Create(ctx, newDeploy); err != nil {
            return ctrl.Result{}, err
        }
    }
    
    // 3. 更新状态
    myApp.Status.Ready = true
    if err = r.Status().Update(ctx, &myApp); err != nil {
        return ctrl.Result{}, err
    }
    
    return ctrl.Result{}, nil
}

五、调谐最佳实践

• 幂等性：确保 Reconcile 可以被安全地重复调用
• 错误处理：遇到临时错误使用 Requeue 重试
• 状态更新：使用 Status 子资源存储状态信息
• OwnerReference：设置资源归属关系便于级联删除

六、总结

Operator 模式将运维自动化提升到了声明式 API 的层面。通过结合 Kubernetes 的控制循环机制和 Go 语言的并发能力，开发者可以构建出高度可靠的自运维系统。