Guía de configuración de la fuente AlloyDB Postgres

Para propagar datos desde tu instancia de AlloyDB a ClickHouse Cloud mediante ClickPipes, tu instancia debe estar configurada para la replicación lógica. Esta función es compatible a partir de la versión 14 de AlloyDB.

Para comprobar si la replicación lógica está habilitada en su instancia de AlloyDB, ejecute la siguiente consulta en la instancia principal:

SHOW  wal_level;

Si el resultado es logical, la replicación lógica ya está habilitada y puedes pasar al siguiente paso. Si el resultado es replica, debes establecer las marcas alloydb.enable_pglogical y alloydb.logical_decoding en on en la instancia principal.

Para habilitar estas marcas:

1. En Google Cloud Console, ve a la página de AlloyDB Clusters. En el menú Actions de tu instancia principal, haz clic en Edit.

   

2. Desplázate hacia abajo hasta Advanced configuration options y expande la sección. En Flags, haz clic en Add a database flag.

   • Agrega la marca allowdb.enable_pglogical y establece su valor en on
   • Agrega la marca alloydb.logical_decoding y establece su valor en on

   

3. Haz clic en Update instance para guardar los cambios de configuración. Es importante tener en cuenta que esta acción provoca un reinicio de la instancia principal.

4. Una vez que el estado de la instancia cambie de Updating a Ready, ejecuta la siguiente consulta en tu instancia principal para verificar que la replicación lógica esté habilitada:

   SHOW  wal_level;

   El resultado debería ser logical.

   

Conéctese a su instancia de AlloyDB como usuario administrador y ejecute los siguientes comandos:

1. Cree un usuario dedicado para ClickPipes:

   CREATE USER clickpipes_user PASSWORD 'some-password';

2. Conceda acceso de solo lectura a nivel de esquema al usuario que creó en el paso anterior. El siguiente ejemplo muestra los permisos para el esquema public. Repita estos comandos para cada esquema que contenga tablas que quiera replicar:

   GRANT USAGE ON SCHEMA "public" TO clickpipes_user;
   GRANT SELECT ON ALL TABLES IN SCHEMA "public" TO clickpipes_user;
   ALTER DEFAULT PRIVILEGES IN SCHEMA "public" GRANT SELECT ON TABLES TO clickpipes_user;

3. Conceda privilegios de replicación al usuario:

   ALTER USER clickpipes_user WITH REPLICATION;

4. Cree una publicación con las tablas que quiera replicar. Recomendamos encarecidamente incluir en la publicación solo las tablas que necesite para evitar la sobrecarga de rendimiento.

• Para crear una publicación para tablas específicas:

  CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;

  • Para crear una publicación para todas las tablas de un esquema específico:

    CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";

La publicación clickpipes define el conjunto de tablas cuyos eventos de cambio se transmitirán a ClickPipes. Recomendamos no usar FOR ALL TABLES a menos que tenga la intención de replicar todas las tablas, ya que incluir tablas innecesarias aumenta el tráfico de WAL desde Postgres hacia ClickPipes y reduce la eficiencia general de la replicación.

A continuación, elija cómo se conectará ClickPipes a su instancia de AlloyDB.

Ahora puedes crear tu ClickPipe y comenzar a ingestar datos desde tu instancia de Postgres hacia ClickHouse Cloud. Asegúrate de anotar los datos de conexión que usaste al configurar tu instancia de Postgres, ya que los necesitarás durante el proceso de creación de ClickPipe.