En este documento, se describe cómo crear ranuras de replicación lógica en AlloyDB Omni. En PostgreSQL, la replicación lógica es un método para copiar cambios de datos de una base de datos del publicador a uno o más suscriptores, que pueden ser bases de datos o aplicaciones. Puedes habilitar y configurar la replicación lógica en los clústeres que creas con el operador de Kubernetes de AlloyDB Omni.
Los cambios transmitidos pueden ser actualizaciones, inserciones o eliminaciones de filas individuales. Los suscriptores se conectan al publicador a través de un espacio de replicación único que garantiza una conexión persistente. Una conexión persistente mantiene el estado de transmisión de datos, por lo que, si se produce una interrupción, la transmisión se reanuda desde donde se detuvo.
Para obtener más información sobre la replicación lógica en PostgreSQL, consulta Replicación lógico.
Los fragmentos de código de esta página son ejemplos que puedes usar como modelos y reemplazar los valores por los de tus recursos de AlloyDB Omni.
Antes de comenzar
Crea un clúster de publicador
Antes de crear los intervalos de replicación, debes crear el clúster de publicador con la replicación lógica habilitada. Debes configurar el parámetro wal_level en logical en el manifiesto DBCluster.
Para crear un clúster de bases de datos del publicador con la replicación lógica habilitada, aplica el siguiente manifiesto:
apiVersion: v1
kind: Secret
metadata:
name: db-pw-DB_CLUSTER_NAME
namespace: DB_CLUSTER_NAMESPACE
type: Opaque
data:
DB_CLUSTER_NAME: "ENCODED_PASSWORD"
---
apiVersion: alloydbomni.dbadmin.goog/v1
kind: DBCluster
metadata:
name: DB_CLUSTER_NAME
namespace: DB_CLUSTER_NAMESPACE
spec:
databaseVersion: "ALLOYDB_OMNI_VERSION"
spec:
availability:
numberOfStandbys: 1
primarySpec:
parameters:
wal_level: "logical"
adminUser:
passwordRef:
name: db-pw-DB_CLUSTER_NAME
resources:
cpu: CPU_COUNT
memory: MEMORY_SIZE
disks:
- name: DataDisk
size: DISK_SIZEReemplaza lo siguiente:
DB_CLUSTER_NAME: Es el nombre de este clúster de bases de datos, por ejemplo,publisher.DB_CLUSTER_NAMESPACE(opcional): Es el espacio de nombres en el que deseas crear el clúster de bases de datos, por ejemplo,publisher-namespace.ENCODED_PASSWORD: La contraseña de acceso a la base de datos para el rol de usuariopostgrespredeterminado, codificada como una cadena base64, por ejemplo,Q2hhbmdlTWUxMjM=paraChangeMe123.ALLOYDB_OMNI_VERSION: La versión de AlloyDB Omni,15.7.0o posterior.CPU_COUNT: Es la cantidad de CPUs disponibles para cada instancia de base de datos en este clúster de bases de datos.MEMORY_SIZE: Es la cantidad de memoria por instancia de base de datos de este clúster de bases de datos. Te recomendamos que establezcas este valor en 8 gigabytes por CPU. Por ejemplo, si configurastecpucomo2antes en este manifiesto, te recomendamos que configuresmemorycomo16Gi.DISK_SIZE: El tamaño del disco por instancia de base de datos, por ejemplo,10Gi.
Crea una ranura de replicación
Después de crear el clúster de publicador, puedes crear un espacio de replicación lógico con el recurso Replication en el clúster de publicador. Cada recurso Replication está asociado con un recurso de clúster de base de datos correspondiente. Un clúster de bases de datos puede tener varios recursos de replicación lógico asociados.
Para configurar un espacio de replicación en tu clúster de publicador, aplica el siguiente manifiesto:
$ cat << EOF | kubectl apply -f -
apiVersion: v1
kind: Secret
metadata:
name: USER_PASSWORD_SECRET_NAME
namespace: USER_PASSWORD_SECRET_NAMESPACE
type: Opaque
---
apiVersion: alloydbomni.dbadmin.goog/v1
kind: Replication
metadata:
name: REPLICATION_NAME
namespace: NAMESPACE
spec:
dbcluster:
name: DB_CLUSTER_NAME
upstream:
logicalReplication:
pluginName: DECODER_PLUGIN
databaseName: DATABASE_NAME
applicationName: APPLICATION_NAME
replicationSlotName: REPLICATION_SLOT_NAME
synchronous: "REPLICATION_MODE"
username: APPLICATION_USER
password:
name: USER_PASSWORD_SECRET_NAME
namespace: USER_PASSWORD_SECRET_NAMESPACE
EOFReemplaza lo siguiente:
- REPLICATION_NAME: Es un nombre para este recurso
Replication, por ejemplo,replication-1. - NAMESPACE: El espacio de nombres de Kubernetes para este recurso
Replication. Debe coincidir con el espacio de nombres del clúster de bases de datos. - DB_CLUSTER_NAME: Es el nombre del clúster de bases de datos que asignaste cuando lo creaste.
- DECODER_PLUGIN: Se establece en el complemento de decodificación, como
pgoutput, que deseas usar para la replicación lógica. Para obtener más información sobre varios complementos de decodificación, consulta Complementos de salida. - DATABASE_NAME: Se establece en el nombre de la base de datos cuyos cambios quieres transmitir al espacio de replicación. Asegúrate de que la base de datos ya se haya creado en el clúster del publicador.
- APPLICATION_NAME (opcional): Establece el nombre de la aplicación que se conectará a la ranura de replicación. Este campo es obligatorio cuando el modo de transmisión se establece en síncrono.
- REPLICATION_MODE (opcional): Se establece en
falsepara la replicación asíncrona. Si deseas habilitar la replicación síncrona, pero a costa de la velocidad, establece este valor comotrue. El valor predeterminado esfalse, si no se configura de forma explícita. - REPLICATION_SLOT_NAME: Es el nombre del espacio de replicación que creará y usará el suscriptor, por ejemplo,
logicalrepltestslot. - REPLICATION_USER (opcional): Es el nombre del usuario que se conecta al espacio de replicación. Si configuras el usuario de replicación, es obligatorio configurar el nombre, el espacio de nombres y la contraseña del secreto.
- USER_PASSWORD_SECRET_NAME (opcional): Es el nombre del Secret de Kubernetes del usuario de la aplicación. Obligatorio si se configura el usuario de la aplicación.
- USER_PASSWORD_SECRET_NAMESPACE (opcional): Es el espacio de nombres en el que se encuentra el Secret de Kubernetes para el usuario de la aplicación. Es obligatorio si se configura el usuario de la aplicación.
Consulta el estado del espacio de replicación
Para ver el estado de los intervalos de replicación, ejecuta el siguiente comando:
kubectl get replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACE -oyaml
El campo status, junto con otros detalles, se incluye en la respuesta:
apiVersion: alloydbomni.dbadmin.goog/v1
kind: Replication
metadata:
name: REPLICATION_NAME
namespace: NAMESPACE
...
...
status:
conditions:
- lastTransitionTime: "2025-01-25T06:49:25Z"
message: Ready for replication
reason: Ready
status: "True"
type: Ready
- lastTransitionTime: "2025-01-25T06:49:25Z"
message: Replication slot is not being used
reason: Unhealthy
status: "False"
type: Healthy
observedGeneration: 2
upstream:
host: DATABASE_ENDPOINT
password:
name: USER_PASSWORD_SECRET_NAME
namespace: USER_PASSWORD_SECRET_NAMESPACE
port: DATABASE_PORT
replicationSlotName: REPLICATION_SLOT_NAME
username: APPLICATION_USERDATABASE_ENDPOINT muestra la dirección IP que usas para conectarte a la base de datos. El estado TRUE en la columna READY indica que el espacio está
listo para transmitir. Cuando el DBCluster o la aplicación del suscriptor se conectan al espacio de replicación, el estado en la columna HEALTHY cambia a TRUE.
Configura el clúster de publicador
Busca el grupo de pods que necesitas.
$ kubectl get pod -l "alloydbomni.internal.dbadmin.goog/dbcluster=DB_CLUSTER_NAME, alloydbomni.internal.dbadmin.goog/task-type=database, dbs.internal.dbadmin.goog/ha-role=Primary"Conéctate al pod principal en el clúster del publicador con
psql:psql -h IP_ADDRESS -U USERNAME -d DATABASE_NAMEReemplaza lo siguiente:
- IP_ADDRESS: Es la dirección IP del pod principal del clúster del publicador.
- USERNAME: Es el usuario postgres de la base de datos.
- DATABASE_NAME: La base de datos a la que el suscriptor desea suscribirse.
Si el
DATABASE_NAMEespecificado en el recurso de replicación no existe, crea una base de datos.CREATE DATABASE DATABASE_NAME;Opcional: Para fines de prueba, agrega una tabla a la base de datos y, luego, inserta algunos datos. Puedes usar estos datos para observar la replicación de datos del publicador al suscriptor.
$ psql -h localhost -U postgres DATABASE_NAME customer=# CREATE TABLE TABLE_NAME( customer(# ID INT PRIMARY KEY NOT NULL, customer(# NAME TEXT NOT NULL, customer(# AGE INT NOT NULL, customer(# SALARY REAL customer(# ); CREATE TABLE customer=# INSERT INTO TABLE_NAME (ID,NAME,AGE,SALARY) VALUES customer-# (1, 'Quinn', 25, 65000.00), customer-# (2, 'Kim', 22, 72250.00), customer-# (3, 'Bola', 31, 53000.00), customer-# (4, 'Sasha', 33, 105000.00), customer-# (5, 'Yuri', 27, 85000.00); INSERT 0 5 customer=# \dt List of relations Schema | Name | Type | Owner --------+---------+-------+---------- public | company | table | postgres (1 row) customer=# select * from TABLE_NAME; id | name | age | salary ----+-------+-----+-------- 1 | Quinn | 25 | 65000 2 | Kim | 22 | 72250 3 | Bola | 31 | 53000 4 | Sasha | 33 | 105000 5 | Yuri | 27 | 85000 (5 rows)Reemplaza TABLE_NAME por una tabla en la que deseas almacenar los datos y a la que se suscribe el suscriptor.
Otorga los permisos:
GRANT SELECT ON ALL TABLES IN SCHEMA public TO REPLICATION_USER; GRANT USAGE ON SCHEMA public TO REPLICATION_USER; ALTER DEFAULT PRIVILEGES IN SCHEMA public GRANT SELECT ON TABLES TO REPLICATION_USER;Ejecuta el siguiente comando para crear la publicación:
CREATE PUBLICATION PUBLICATION_NAME; ALTER PUBLICATION PUBLICATION_NAME ADD TABLE TABLE_NAME;Reemplaza lo siguiente:
- PUBLICATION_NAME: Es el nombre de la publicación que usará el suscriptor para suscribirse.
Después de crear la publicación, puedes configurar tu clúster de suscriptores para la replicación lógica o configurar tu aplicación para que comience a replicarse.
Limitaciones
No se admiten actualizaciones de la configuración del espacio de replicación. Para actualizar la configuración, suelta el espacio de replicación y vuelve a crearlo con la configuración actualizada.
Para soltar el espacio de réplica, ejecuta el siguiente comando:
kubectl delete replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACESolo puedes configurar la ranura de replicación lógica en la base de datos del publicador. La API de replicación no admite aplicaciones ni DBCluster de suscriptores de replicación lógica.
Si el clúster de bases de datos al que hace referencia el objeto de replicación está configurado para la alta disponibilidad, el espacio de replicación lógica se vuelve a crear en el estado de espera promovido después de una conmutación por error. Después de que se vuelva a crear la ranura de replicación, la posición de la transmisión en la ranura ya no estará disponible, y las aplicaciones que se suscriban a la transmisión deberán volver a conectarse y reproducirla.