Operadores en Kubernetes para aplicaciones con estado

Mientras Kubernetes destaca en la gestión de microservicios sin estado a través de Deployments y ReplicaSets estándar, Implementacionesyla gestión de aplicaciones con estado—como bases de datos, colas de mensajes y cachés distribuidas—introduce una complejidad significativa. Estas aplicaciones requieren identidades de red estables, almacenamiento persistente y despliegues y terminaciones ordenadas. Para resolver esto de forma automatizada y escalable, los equipos de ingeniería de alto rendimiento recurren al Patrón de Operadores., la gestión de aplicaciones con estado (como bases de datos, colas de mensajes y cachés distribuidas) introduce una complejidad significativa. Estas aplicaciones requieren identidades de red estables, almacenamiento persistente y un despliegue y terminación ordenados. Para resolver esto de forma automatizada y escalable, los equipos de ingeniería de alto rendimiento recurren al Patrón de Operador.

Este artículo detalla la implementación técnica de un operador de Kubernetes utilizando Go y Kubebuilder, específicamente diseñada para gestionar una carga de trabajo que requiere mantener el estado.

Servicios de Ingeniería de Productos

Colabore con nuestros gestores de proyectos, ingenieros de software y probadores de calidad, para desarrollar su nuevo producto de software personalizado o para apoyar su flujo de trabajo actual, siguiendo las metodologías Agile, DevOps y Lean.

Build with 4Geeks

El patrón del Operador: Automatización de las operaciones del Día 2

El patrón Operator codifica el conocimiento operativo en software. Extiende la API de Kubernetes utilizando <s1>Definiciones de Recursos Personalizadas (CRD)Definiciones de recursos personalizadas (CRD)ControladorControl. El controlador ejecuta un ciclo de conciliación, asegurando que el estado actual del sistema coincida con el estado deseado definido en el CRD.

Para aplicaciones que requieren un estado, esto significa que el operador gestiona la lógica que los recursos estándar de Kubernetes no pueden, como:

• Elección del líder: Manejo de la promoción primaria/de respaldo durante las conmutaciones.
• Reequilibrio de datos: Particionamiento de datos al escalar nodos.
• Copia de seguridad/Restauración: Automatización de procesos de instantáneas y restauración.

Implementación Técnica

Crearemos un esquema para desarrollar un operador para un KVStore hipotético (Almacén de Claves-Valores) que requiere almacenamiento persistente y un ordenamiento estricto.KVStore(Almacén de pares clave-valor) que requiere almacenamiento persistente y un ordenamiento estricto.

1. Marco de trabajo con Kubebuilder

Primero, inicialice el dominio y la API del proyecto.

kubebuilder init --domain 4geeks.io --repo github.com/4geeks/kvstore-operator
kubebuilder create api --group db --version v1 --kind KVStore

2. Definir el Recurso Personalizado (CRD)

La CRD define el esquema para nuestra aplicación. Para un servicio de estado, necesitamos especificar los requisitos de almacenamiento y el tamaño del clúster.

Modificar api/v1/kvstore_types.go ::

// KVStoreSpec defines the desired state of KVStore
type KVStoreSpec struct {
    // Size defines the number of replicas in the cluster
    // +kubebuilder:validation:Minimum=1
    Size int32 `json:"size"`

    // StorageSize defines the request size for Persistent Volume Claims
    StorageSize string `json:"storageSize"`

    // ContainerImage defines the specific version of the KVStore to run
    ContainerImage string `json:"containerImage"`
}

// KVStoreStatus defines the observed state of KVStore
type KVStoreStatus struct {
    // ReadyReplicas indicates how many nodes are fully synced
    ReadyReplicas int32 `json:"readyReplicas"`
}

Servicios de Ingeniería de Productos

Trabaje con nuestros gestores de proyectos, ingenieros de software y testers de control de calidad para desarrollar su nuevo producto de software personalizado o para apoyar su flujo de trabajo actual, siguiendo metodologías Agile, DevOps y Lean.

Build with 4Geeks

3. Implementar el bucle de conciliación

La función de conciliación es el núcleo del Operador. Se activa cada vez que se produce un cambio en el KVStoreo en los recursos que gestiona (como el StatefulSet.

Encontrollers/kvstore_controller.go, implementamos la lógica para gestionar unStatefulSet. A diferencia deDeployments, losStatefulSets mantienen una identidad persistente para cada Pod (kvstore-0,kvstore-1), lo cual es fundamental para la consistencia de los datos.

func (r *KVStoreReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
    log := log.FromContext(ctx)

    // 1. Fetch the KVStore CR instance
    kvStore := &dbv1.KVStore{}
    if err := r.Get(ctx, req.NamespacedName, kvStore); err != nil {
        return ctrl.Result{}, client.IgnoreNotFound(err)
    }

    // 2. Define the desired StatefulSet object
    desiredSts := r.desiredStatefulSet(kvStore)

    // 3. Check if the StatefulSet already exists
    foundSts := &appsv1.StatefulSet{}
    err := r.Get(ctx, types.NamespacedName{Name: desiredSts.Name, Namespace: kvStore.Namespace}, foundSts)

    if err != nil && errors.IsNotFound(err) {
        log.Info("Creating a new StatefulSet", "Namespace", desiredSts.Namespace, "Name", desiredSts.Name)
        err = r.Create(ctx, desiredSts)
        if err != nil {
            return ctrl.Result{}, err
        }
        // Requeue to verify creation
        return ctrl.Result{Requeue: true}, nil
    } else if err != nil {
        return ctrl.Result{}, err
    }

    // 4. Update Strategy: Check for drift in configuration (e.g., Scaling)
    if *foundSts.Spec.Replicas != kvStore.Spec.Size {
        foundSts.Spec.Replicas = &kvStore.Spec.Size
        log.Info("Updating replica count", "From", *foundSts.Spec.Replicas, "To", kvStore.Spec.Size)
        err = r.Update(ctx, foundSts)
        if err != nil {
            return ctrl.Result{}, err
        }
    }

    // 5. Update Status
    kvStore.Status.ReadyReplicas = foundSts.Status.ReadyReplicas
    if err := r.Status().Update(ctx, kvStore); err != nil {
        return ctrl.Result{}, err
    }

    return ctrl.Result{}, nil
}

4. Gestión del almacenamiento persistente con VolumeClaimTemplates

Las aplicaciones con estado requieren persistencia de datos a través de los reinicios del Pod. Al construir la estructura <s1>StatefulSetConjunto Stateful<s3>VolumeClaimTemplatesPlantillas de reclamación de volumen. Esto proporciona dinámicamente un <s4><s5>PersistentVolumeVolumen persistente (PV) para cada réplica utilizando el controlador de almacenamiento del proveedor de la nube subyacente (por ejemplo, EBS en AWS, PD en GCP).

func (r *KVStoreReconciler) desiredStatefulSet(kv *dbv1.KVStore) *appsv1.StatefulSet {
    // ... metadata setup ...
    return &appsv1.StatefulSet{
        // ...
        Spec: appsv1.StatefulSetSpec{
            // Headless Service is required for StatefulSets
            ServiceName: kv.Name + "-headless", 
            VolumeClaimTemplates: []corev1.PersistentVolumeClaim{
                {
                    ObjectMeta: metav1.ObjectMeta{Name: "data"},
                    Spec: corev1.PersistentVolumeClaimSpec{
                        AccessModes: []corev1.PersistentVolumeAccessMode{corev1.ReadWriteOnce},
                        Resources: corev1.ResourceRequirements{
                            Requests: corev1.ResourceList{
                                corev1.ResourceStorage: resource.MustParse(kv.Spec.StorageSize),
                            },
                        },
                    },
                },
            },
            // ... container spec ...
        },
    }
}

Consideraciones sobre la escalabilidad e infraestructura en la nube

Implementar operadores en producción requiere una infraestructura subyacente sólida. La complejidad de gestionar clases de almacenamiento, disponibilidad en múltiples zonas y redes seguras a menudo exige conocimientos especializados.

Para organizaciones que están expandiendo estas capacidades, 4Geeks ofrece servicios de ingeniería en la nube para equipos remotos. Su experiencia en arquitectura y automatización en la nube ayuda a las empresas a diseñar la base fiable necesaria para ejecutar cargas de trabajo complejas y complejas en Kubernetes. Tanto si está realizando una migración a la nube como si está implementando arquitecturas sin servidor, contar con un socio especializado garantiza que su estrategia de Kubernetes esté alineada con los objetivos generales de disponibilidad del negocio.

Conclusión

Los operadores son la solución definitiva para gestionar la complejidad de los sistemas con estado en Kubernetes. Al abstraer la gestión específica del ciclo de vida de las bases de datos y los sistemas de almacenamiento en un controlador personalizado, los equipos de ingeniería pueden lograr un mayor nivel de automatización y fiabilidad. Si bien la inversión inicial en la creación de un operador es mayor que la de un simple gráfico de Helm, los beneficios operativos a largo plazo (autocuración, escalado y mantenimiento) son sustanciales para cualquier empresa empresarial de nube seria.

Si busca acelerar la madurez de su infraestructura, considere cómo 4Geeks puede apoyar su camino con servicios de ingeniería y DevOps especializados en la nube.

Servicios de Ingeniería de Productos

Trabaje con nuestros gestores de proyectos, ingenieros de software y testers de calidad internos para desarrollar su nuevo producto de software personalizado o para apoyar su flujo de trabajo actual, siguiendo metodologías Agile, DevOps y Lean.

Build with 4Geeks

Preguntas frecuentes