Este documento descreve como criar slots de replicação lógica no AlloyDB Omni. No PostgreSQL, a replicação lógica é um método para copiar mudanças de dados de um banco de dados de editor para um ou mais assinantes, que podem ser bancos de dados ou outros aplicativos. É possível ativar e configurar a replicação lógica em clusters criados usando o operador do AlloyDB Omni no Kubernetes.
As mudanças transmitidas podem ser atualizações, inserções ou exclusões de linhas individuais. Os assinantes se conectam ao editor por um slot de replicação exclusivo que garante uma conexão persistente. Uma conexão persistente mantém o estado de transmissão de dados. Portanto, se ocorrer uma interrupção, a transmissão será retomada de onde parou.
Para mais informações sobre a replicação lógica no PostgreSQL, consulte Replicação lógica.
Os snippets de código nesta página são exemplos que podem ser usados como modelos, substituindo os valores pelos dos seus recursos do AlloyDB Omni.
Antes de começar
Criar um cluster de editor
Antes de criar os slots de replicação, é necessário criar o cluster de editor com a replicação lógica ativada. Defina o parâmetro wal_level como logical no manifesto DBCluster.
Para criar um cluster de banco de dados de editor com a replicação lógica ativada, aplique o seguinte manifesto:
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_SIZESubstitua:
DB_CLUSTER_NAME: o nome do cluster de banco de dados, por exemplo,publisher.DB_CLUSTER_NAMESPACE(opcional): o namespace em que você quer criar o cluster de banco de dados, por exemplo,publisher-namespace.ENCODED_PASSWORD: a senha de login do banco de dados para a função do usuário padrãopostgrescodificada como uma string base64. Por exemplo,Q2hhbmdlTWUxMjM=paraChangeMe123.ALLOYDB_OMNI_VERSION: a versão do AlloyDB Omni,15.7.0ou mais recente.CPU_COUNT: o número de CPUs disponíveis para cada instância de banco de dados no cluster.MEMORY_SIZE: a quantidade de memória por instância de banco de dados deste cluster de banco de dados. Recomendamos definir isso como 8 gigabytes por CPU. Por exemplo, se você definircpucomo2anteriormente neste manifesto, recomendamos definirmemorycomo16Gi.DISK_SIZE: o tamanho do disco por instância de banco de dados, por exemplo,10Gi.
Criar um slot de replicação
Depois de criar o cluster de editor, é possível criar um slot de replicação lógica usando o recurso Replication no cluster de editor. Cada recurso Replication está associado a um recurso de cluster de banco de dados correspondente. Um cluster de banco de dados pode ter vários recursos de replicação lógica associados a ele.
Para configurar um slot de replicação no cluster de editor, aplique o seguinte manifesto:
$ 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
EOFSubstitua:
- REPLICATION_NAME: um nome para esse recurso
Replication, por exemplo,replication-1. - NAMESPACE: o namespace do Kubernetes para esse
Replicationrecurso. Ele precisa corresponder ao namespace do cluster de banco de dados. - DB_CLUSTER_NAME: o nome do cluster de banco de dados, que você atribuiu ao criá-lo.
- DECODER_PLUGIN: definido como o plug-in de decodificação, como
pgoutput, que você quer usar para replicação lógica. Para mais informações sobre vários plug-ins de decodificação, consulte Plug-ins de saída. - DATABASE_NAME: definido como o nome do banco de dados cujas mudanças você quer transmitir para o slot de replicação. Verifique se o banco de dados já foi criado no cluster de editor.
- APPLICATION_NAME (opcional): definido como o nome do aplicativo que vai se conectar ao slot de replicação. Esse campo é obrigatório quando o modo de transmissão é definido como síncrono.
- REPLICATION_MODE (opcional): definido como
falsepara replicação assíncrona. Se você quiser ativar a replicação síncrona, mas à custa da velocidade, defina esse valor comotrue. O valor padrão éfalse, se não for definido explicitamente. - REPLICATION_SLOT_NAME: o nome do slot de replicação que
será criado e usado pelo assinante, por exemplo,
logicalrepltestslot. - REPLICATION_USER (opcional): o nome do usuário que se conecta ao slot de replicação. Se você definir o usuário de replicação, será necessário definir o nome, o namespace e a senha do Secret.
- USER_PASSWORD_SECRET_NAME (opcional): o nome do Secret do Kubernetes do usuário do aplicativo. Obrigatório se o usuário do aplicativo estiver definido.
- USER_PASSWORD_SECRET_NAMESPACE (opcional): o namespace em que o Secret do Kubernetes para o usuário do aplicativo está localizado. Obrigatório se o usuário do aplicativo estiver definido.
Visualizar o status do slot de replicação
Para visualizar o status dos slots de replicação, execute o seguinte comando:
kubectl get replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACE -oyaml
O campo status, juntamente com outros detalhes, está incluído na resposta:
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_USERO DATABASE_ENDPOINT mostra o endereço IP usado para se conectar ao banco de dados. O status TRUE na coluna READY indica que o slot está pronto para transmissão. Quando o DBCluster ou o aplicativo do assinante se conecta ao slot de replicação, o status na coluna HEALTHY muda para TRUE.
Configurar o cluster de editor
Encontre o pod necessário.
$ 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"Conecte-se ao pod principal no cluster de editor usando
psql:psql -h IP_ADDRESS -U USERNAME -d DATABASE_NAMESubstitua:
- IP_ADDRESS: o endereço IP do pod principal do cluster de editor.
- USERNAME: o usuário postgres do banco de dados.
- DATABASE_NAME: o banco de dados ao qual o assinante quer se inscrever.
Se o
DATABASE_NAMEespecificado no recurso de replicação não existir, crie um banco de dados.CREATE DATABASE DATABASE_NAME;Opcional: para fins de teste, adicione uma tabela ao banco de dados e insira alguns dados. É possível usar esses dados para observar a replicação de dados do editor para o assinante.
$ 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)Substitua TABLE_NAME por uma tabela em que você quer armazenar os dados e a que o assinante se inscreve.
Conceda as permissões:
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;Crie a publicação executando o seguinte comando:
CREATE PUBLICATION PUBLICATION_NAME; ALTER PUBLICATION PUBLICATION_NAME ADD TABLE TABLE_NAME;Substitua:
- PUBLICATION_NAME: o nome da publicação que o assinante vai usar para se inscrever.
Depois de criar a publicação, é possível configurar o cluster de assinantes para replicação lógica ou configurar o aplicativo para iniciar a replicação.
Limitações
Não há suporte para atualizações na configuração do slot de replicação. Para atualizar a configuração, descarte o slot de replicação e recrie-o com a configuração atualizada.
Para descartar o slot de replicação, execute o seguinte comando:
kubectl delete replication.alloydbomni.dbadmin.goog REPLICATION_NAME -n NAMESPACESó é possível configurar o slot de replicação lógica no banco de dados do editor. A API de replicação não oferece suporte ao DBCluster ou a aplicativos de assinantes de replicação lógica.
Se o cluster de banco de dados referenciado pelo objeto de replicação estiver configurado para alta disponibilidade, o slot de replicação lógica será recriado no modo de espera promovido após um failover. Depois que o slot de replicação for recriado, a posição do stream no slot não estará mais disponível, e todos os aplicativos inscritos no stream precisarão se reconectar e reproduzir o stream.