Se usó la API de Cloud Translation para traducir esta página.

Configura una base de datos de AlloyDB para PostgreSQL

En las siguientes secciones, se explica cómo configurar una base de datos de AlloyDB para PostgreSQL.

Configura la conectividad entre Datastream y AlloyDB

Para permitir que DataStream se conecte a la instancia de AlloyDB, debes configurar un proxy TCP en el proyecto del consumidor. La imagen de proxy TCP está disponible de forma pública para todos los clientes.

Inicia el contenedor del proxy:

Activar Cloud Shell en el proyecto de consumidor
Ejecuta la siguiente secuencia de comandos para crear el proxy TCP y, luego, inhabilitar el puente las herramientas de redes para evitar problemas de conectividad:

gcloud compute instances create-with-container \
  --zone=REGION_ID VM_NAME \
  --container-image gcr.io/dms-images/tcp-proxy \
  --tags=dms-tcp-proxy \
  --container-env=SOURCE_CONFIG=ALLOYDB_IP:ALLOYDB_PORT \
  --can-ip-forward \
  --network=SOURCE_AND_DEST_VPC \
  --machine-type=VM_TIER \
  --metadata=startup-script='#! /bin/bash
  mkdir -p /etc/docker
  cat <<EOF > /etc/docker/daemon.json
  {"bridge":"none"}
  EOF
  systemctl restart docker'

Reemplaza lo siguiente:

REGION_ID: Es la región en la que deseas crear el proxy TCP.
VM_NAME: Es el nombre de la máquina virtual.
ALLOYDB_IP: La dirección IP de la instancia de AlloyDB para PostgreSQL.
ALLOYDB_PORT: Es el número de puerto de la instancia de AlloyDB para PostgreSQL.
SOURCE_AND_DEST_VPC: La red de VPC a la que se conectan el origen y el destino están conectados.
VM_TIER: Es el tipo de tu máquina virtual.

Un comando de ejemplo con parámetros actualizados:

gcloud compute instances create-with-container \
  --zone=us-central1-c ds-tcp-proxy \
  --container-image gcr.io/dms-images/tcp-proxy \
  --tags=ds-tcp-proxy \
  --container-env=SOURCE_CONFIG=10.16.0.5:5432 \
  --can-ip-forward \
  --network=default \
  --machine-type=e2-micro
  --metadata=startup-script='#! /bin/bash
  mkdir -p /etc/docker
  cat <<EOF > /etc/docker/daemon.json
  {"bridge":"none"}
  EOF
  systemctl restart docker'

Ejecuta la secuencia de comandos para imprimir la dirección IP del proxy TCP con las siguientes entradas:
```
gcloud compute instances describe VM_NAME \
  --format="yaml(networkInterfaces[].networkIP)" \
  --zone=REGION_ID
```
Reemplaza lo siguiente:
- VM_NAME: Es el nombre de tu máquina virtual.
- REGION_ID: Es la región en la que creaste el proxy TCP.
Usa esta dirección IP en la configuración del perfil de conexión de Datastream.
(Opcional) Crea una regla de firewall para limitar el tráfico de entrada al proxy TCP:
```
gcloud compute firewall-rules create FIREWALL_RULE_NAME \
  --direction=INGRESS \
  --priority=1000 \
  --target-tags=dms-tcp-proxy \
  --network=SOURCE_VPC \
  --action=ALLOW \
  --rules=tcp:ALLOYDB_PORT \
  --source-ranges=IP_RANGE
```
Reemplaza lo siguiente:
- FIREWALL_RULE_NAME: Es el nombre de la regla de firewall.
- SOURCE_VPC: La red de VPC a la que está conectada tu fuente.
- ALLOYDB_PORT: Es el número de puerto de la instancia de AlloyDB para PostgreSQL.
- IP_RANGE: Es el rango de direcciones IP al que deseas limitar el tráfico entrante.
Un comando de ejemplo para permitir el tráfico de entrada desde todas las direcciones IP:
```
gcloud compute firewall-rules create ds-proxy1 \
  --direction=INGRESS \
  --priority=1000 \
  --target-tags=ds-tcp-proxy \
  --network=default \
  --action=ALLOW \
  --rules=tcp:5432
```

Configura AlloyDB para la replicación

Habilitar la decodificación lógica para la instancia principal de AlloyDB. En Google Cloud, configura el valor de la marca alloydb.logical_decoding en ON Para obtener información sobre cómo actualizar las marcas de la base de datos, consulta Configura las marcas de base de datos de una instancia.

Nota: Si actualizas la marca alloydb.logical_decoding, se reinicia la instancia.
Ejecuta el siguiente comando desde cualquier VM de la misma VPC para conectarte a la instancia de AlloyDB con la dirección IP del proxy TCP:
```
  psql -h PROXY_IP \
    -U DB_USER \
    -d DB_NAME
```
Reemplaza lo siguiente:
- PROXY_IP: La dirección IP del proxy TCP.
- DB_USER: Es el nombre de usuario de la base de datos de AlloyDB.
- DB_NAME: Es el nombre de la base de datos de AlloyDB.
Ejecuta el siguiente comando para otorgar privilegios de replicación al usuario de la base de datos:
```
ALTER USER DB_USER WITH REPLICATION;
```
Crea una publicación. Te recomendamos que crees una publicación solo para las tablas que quieras replicar. Esto permite que Datastream lea solo los datos relevantes y disminuya la carga en la base de datos y Datastream:
```
CREATE PUBLICATION PUBLICATION_NAME
FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;
```
Reemplaza lo siguiente:
- PUBLICATION_NAME: El nombre de tu publicación. Deberás deberás proporcionar este nombre cuando crees una transmisión en Datastream para crear transmisiones.
- SCHEMA: Es el nombre del esquema que contiene la tabla.
- TABLE: Es el nombre de la tabla que deseas replicar.
Puedes crear una publicación para todas las tablas de un esquema. Este enfoque te permite replicar los cambios de las tablas en la lista de esquemas especificada, incluidas las tablas que crees en el futuro:
```
CREATE PUBLICATION PUBLICATION_NAME
FOR TABLES IN SCHEMA1, SCHEMA2;
```
También puedes crear una publicación para todas las tablas de tu base de datos. Ten en cuenta que este enfoque aumenta la carga en la base de datos de origen y en Datastream:
```
CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;
```
Crea una ranura de replicación mediante la ejecución del siguiente comando.
```
SELECT PG_CREATE_LOGICAL_REPLICATION_SLOT('REPLICATION_SLOT_NAME', 'pgoutput');
```
Reemplaza lo siguiente:
- REPLICATION_SLOT_NAME: Es el nombre de tu ranura de replicación. Deberás proporcionar este nombre cuando crees una transmisión en Datastream para crear transmisiones.

Crea un usuario de Datastream

Para crear un usuario de Datastream, ingresa el siguiente comando de PostgreSQL:
```
CREATE USER USER_NAME WITH REPLICATION LOGIN PASSWORD 'USER_PASSWORD';
```
Reemplaza lo siguiente:
- USER_NAME: Es el nombre del usuario de Datastream que deseas. para crear.
- USER_PASSWORD: Es la contraseña de acceso del usuario de Datastream. que quieras crear.
Otorga los siguientes privilegios al usuario que creaste:
```
GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME;
GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME;
ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME GRANT SELECT ON TABLES TO USER_NAME;
```
Reemplaza lo siguiente:
- SCHEMA_NAME: Es el nombre del esquema al que deseas otorgar los privilegios.
- USER_NAME: Es el usuario al que deseas otorgar los privilegios.
El primer comando puede mostrar advertencias, pero es seguro ignorarlas.

¿Qué sigue?

Obtén más información sobre cómo funciona Datastream con fuentes de PostgreSQL.