Kubebuilder开发MLflow实验跟踪控制器
前面文章讲了client-go, go-restful开发Kubernetes应用平台，今天给大家看看在这个应用平台中添加一个自定义资源控制器的开发。 需求场景： 在多租户机器学习平台中，开发一个Kubernetes控制器，实现CRD(自定义资源) TrackingServer的调谐，完成Kubernetes中对应的PersistentVolumeClaim, TLS Secret, Service, Ingress, Deployment资源管理。 功能描述： 1，当CR实例的参数中指定了VolumeSize和StorageClassName，则创建对应的PersistentVolumeClaim用于MLflow的local database sqllite的数据存储目录。当未指定时，不创建或者删除已经创建的PersistentVolumeClaim。 2，当CR实例的参数中指定了Cert和Key数据，则创建对应的TLS类型的Secret，用于Ingress的TLS证书。当未指定时，不创建或删除对应Secret。 3，查找对应命名空间和名称的Secret，如果有Ingress配置对应的TLS证书。 4，根据CR实例的参数管理Service和Deployment的创建和修改。 5，删除CR实例后，对应清理K8S资源。当删除资源时，判断被删除资源是否为CR实例的附属资源。 代码实现： 整个业务代码开发分为几个大的步骤： 1，Kubebuilder生成代码和部署文件 2，在Controller Manager中注册控制器 3，在控制器调谐代码中，实现业务逻辑 Kubebuilder中创建API 指定GVK，这里TrackingServer为我们需要的MLflow资源。 kubebuilder create api --group experiment --version v1alpha2 --kind TrackingServer kubebuilder create api --group experiment --version v1alpha2 --kind JupyterNotebook kubebuilder create api --group experiment --version v1alpha2 --kind CodeServer 自定义资源TrackingServer定义 定义VolumeSize, Cert, Key字段为omitempty，表示非必须字段。 +genclient表示代码生成器生成clientset，informer, lister代码。 printcolumn表示kubectl get资源时展示字段 // TrackingServerSpec defines the desired state of TrackingServer type TrackingServerSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "make" to regenerate code after modifying this file Size int32 `json:"size"` Image string `json:"image"` S3_ENDPOINT_URL string `json:"s3_endpoint_url"` AWS_ACCESS_KEY string `json:"aws_access_key"` AWS_SECRET_KEY string `json:"aws_secret_key"` ARTIFACT_ROOT string `json:"artifact_root"` BACKEND_URI string `json:"backend_uri"` URL string `json:"url"` VolumeSize string `json:"volumeSize,omitempty"` StorageClassName string `json:"storageClassName,omitempty"` Cert string `json:"cert,omitempty"` Key string `json:"key,omitempty"` } // TrackingServerStatus defines the observed state of TrackingServer type TrackingServerStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "make" to regenerate code after modifying this file } // +genclient // +kubebuilder:object:root=true // +kubebuilder:subresource:status // +kubebuilder:printcolumn:name="S3_ENDPOINT_URL",type="string",JSONPath=".
