Migración de la tabla de exportación de perfiles de Snowflake a una tabla híbrida

Qué aprenderás

Descubre cómo convertir la tabla KLAVIYO_PROFILE en la que el exportador del almacén de datos de Klaviyo escribe en Snowflake de una tabla estándar a una tabla híbrida de Snowflake, con los comandos exactos que debes ejecutar en cada paso.

La sincronización de exportación de Klaviyo utiliza instrucciones MERGE para aplicar cambios de perfil a KLAVIYO_PROFILE. Las tablas híbridas se crean para lecturas puntuales de baja latencia basadas en índices y escrituras simultáneas. Pueden ajustarse a búsquedas individuales de perfiles desde una aplicación, una API o una interfaz de usuario. Las tablas Standard suelen rendir mejor para grandes escaneos analíticos y agregaciones. Antes de migrar, compara el rendimiento de la exportación, las consultas posteriores y el coste total usando tus propios datos y carga de trabajo.

Antes de empezar

Revisa las 4 comprobaciones siguientes antes de cambiar nada.

1. Confirma que la cuenta admite tablas híbridas

Reemplaza KLAVIYO_DATABASE y KLAVIYO_DATA_TRANSFER_WAREHOUSE por los nombres que configuraste en el script de configuración de Snowflake, y reemplaza PUBLIC si usas un esquema diferente. Aplica estas sustituciones en todos los ejemplos de SQL. Mantén el nombre de la tabla de perfil KLAVIYO_PROFILE: el script de configuración lo marca como fijo y la exportación de Klaviyo escribe con ese nombre.

USE ROLE SYSADMIN;
USE WAREHOUSE KLAVIYO_DATA_TRANSFER_WAREHOUSE;
USE DATABASE KLAVIYO_DATABASE;
USE SCHEMA PUBLIC;

CREATE OR REPLACE HYBRID TABLE HYBRID_SMOKE_TEST (ID VARCHAR(32) PRIMARY KEY);
DROP TABLE HYBRID_SMOKE_TEST;

Si una instrucción falla, detente y lee el error de Snowflake antes de continuar. Una cuenta o región no admitida, privilegios ausentes, un almacén no disponible o un límite de cuota pueden impedir la creación. Resuelve la causa indicada y vuelve a ejecutar la comprobación correctamente.

2. Ajusta el tamaño de la tabla de perfiles

SELECT
    ROW_COUNT,
    BYTES / POWER(1024, 3) AS SIZE_GB
FROM KLAVIYO_DATABASE.INFORMATION_SCHEMA.TABLES
WHERE TABLE_SCHEMA = 'PUBLIC'
  AND TABLE_NAME = 'KLAVIYO_PROFILE';

Las tablas híbridas usan un almacenamiento principal basado en filas, por lo que, normalmente, los mismos datos ocupan más espacio que en una tabla estándar columnar. SIZE_GB describe la tabla estándar existente; no es una estimación fiable del almacenamiento híbrido. Mide el almacenamiento de la tabla híbrida de prueba y deja margen para los índices y el crecimiento dentro de la cuota de almacenamiento híbrido de la base de datos.

3. Buscar ID duplicados o nulos

El script de configuración de Klaviyo declara la clave principal (ID) e ID NOT NULL en la tabla estándar. Snowflake no aplica claves principales en tablas estándar, pero sí aplica NOT NULL. Las tablas híbridas aplican ambas, por lo que los ID duplicados bloquearán la carga. Comprueba también si hay ID nulos, por si el esquema de la tabla existente difiere del script de configuración. Ambas consultas deben devolver 0.

SELECT COUNT(*) AS DUPLICATE_IDS
FROM (
    SELECT ID
    FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE
    GROUP BY ID
    HAVING COUNT(*) > 1
);

SELECT COUNT(*) AS NULL_IDS
FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE
WHERE ID IS NULL;

Si cualquiera de los dos devuelve un valor distinto de cero, resuelve el problema de calidad de datos en la tabla estándar antes de continuar. De lo contrario, la carga del paso 2 fallará.

4. Comprueba las dependencias posteriores

Las tablas híbridas no admiten claves de clustering, uso compartido de datos, tablas dinámicas, Fail-safe, vistas materializadas, Query Acceleration Service, replicación, Search Optimization Service, Snowpipe, Snowpipe Streaming, streams ni UNDROP. Time Travel es compatible con limitaciones.

SELECT
    REFERENCING_DATABASE,
    REFERENCING_SCHEMA,
    REFERENCING_OBJECT_NAME,
    REFERENCING_OBJECT_DOMAIN
FROM SNOWFLAKE.ACCOUNT_USAGE.OBJECT_DEPENDENCIES
WHERE REFERENCED_DATABASE = 'KLAVIYO_DATABASE'
  AND REFERENCED_SCHEMA = 'PUBLIC'
  AND REFERENCED_OBJECT_NAME = 'KLAVIYO_PROFILE';

Esta vista puede retrasarse hasta 3 horas y no incluye movimientos de datos como CTAS, INSERT o MERGE. Comprueba también las tareas programadas, las aplicaciones externas y otros consumidores de la tabla. Si algo posterior depende de una función no compatible, reconstrúyelo antes de migrar. Prevé actualizar y validar los objetos dependientes después del cambio de nombre en el paso 5.

Paso 1: pausa la sincronización de exportación

1. En Klaviyo, navega hasta Advanced Klaviyo Data Platform > Gestión de datos > Sincronización.
2. Selecciona el destino de Snowflake y abre la pestaña Periódica.
3. En la fila Exportación del perfil, selecciona Pausar.

Si una exportación de un perfil sigue en curso en la pestaña Histórico, pon esa tarea en pausa también. Mantén en pausa todas las exportaciones de perfiles hasta el paso 7.

Confirma que las tareas que pausaste muestran Paused y, a continuación, confirma en el historial de consultas de Snowflake que cualquier consulta de exportación que ya esté en ejecución haya finalizado. El estado de pausa por sí solo no confirma que se haya detenido una escritura en curso. Mantén detenidos los demás procesos de escritura en KLAVIYO_PROFILE durante la copia, la validación y el cambio de nombre. Migrar mientras la tabla está cambiando puede hacer que la copia quede incompleta.

Paso 2: crear la tabla híbrida y cargarla

Elige 1 método de carga: ejecuta la única instrucción CREATE HYBRID TABLE ... AS SELECT (CTAS) que aparece a continuación, o usa la alternativa de carga por lotes en la siguiente subsección. No ejecutes ambos: cada ejemplo reemplaza KLAVIYO_PROFILE_HYBRID. CTAS requiere que declares explícitamente el esquema completo de columnas; no se puede inferir a partir del SELECT. Los ejemplos coinciden con el script de configuración de Klaviyo. Compara primero el esquema existente y conserva los nombres de las columnas y los tipos de datos.

USE ROLE SYSADMIN;
USE WAREHOUSE KLAVIYO_DATA_TRANSFER_WAREHOUSE;
USE DATABASE KLAVIYO_DATABASE;
USE SCHEMA PUBLIC;

CREATE OR REPLACE HYBRID TABLE KLAVIYO_PROFILE_HYBRID (
    ID VARCHAR(32) NOT NULL,
    EXTERNAL_ID VARCHAR(255),
    EMAIL VARCHAR(255),
    PHONE_NUMBER VARCHAR(255),
    FIRST_NAME VARCHAR(255),
    LAST_NAME VARCHAR(255),
    TITLE VARCHAR(255),
    ORGANIZATION VARCHAR(255),
    PROPERTIES OBJECT,
    IMAGE VARCHAR(255),
    CREATED TIMESTAMP_NTZ(9),
    UPDATED TIMESTAMP_NTZ(9),
    LOCATION_ADDRESS1 VARCHAR(255),
    LOCATION_ADDRESS2 VARCHAR(255),
    LOCATION_CITY VARCHAR(255),
    LOCATION_COUNTRY VARCHAR(255),
    LOCATION_LATITUDE VARCHAR(255),
    LOCATION_LONGITUDE VARCHAR(255),
    LOCATION_REGION VARCHAR(255),
    LOCATION_ZIP VARCHAR(255),
    PRIMARY KEY (ID)
)
AS
SELECT
    ID,
    EXTERNAL_ID,
    EMAIL,
    PHONE_NUMBER,
    FIRST_NAME,
    LAST_NAME,
    TITLE,
    ORGANIZATION,
    PROPERTIES,
    IMAGE,
    CREATED,
    UPDATED,
    LOCATION_ADDRESS1,
    LOCATION_ADDRESS2,
    LOCATION_CITY,
    LOCATION_COUNTRY,
    LOCATION_LATITUDE,
    LOCATION_LONGITUDE,
    LOCATION_REGION,
    LOCATION_ZIP
FROM KLAVIYO_PROFILE;

Cargar una tabla muy grande en lotes

Si una única CTA es demasiado grande como para ejecutarse cómodamente, usa esta alternativa para crear la tabla híbrida vacía y cargarla por rangos de fechas. El INSERT INTO ... SELECT inicial en una tabla vacía utiliza la ruta de carga masiva optimizada. Para los lotes posteriores, el uso de esa ruta depende del tamaño y del número de filas que se estén cargando. Comprueba el perfil de la consulta para confirmar si se utilizó.

USE ROLE SYSADMIN;
USE WAREHOUSE KLAVIYO_DATA_TRANSFER_WAREHOUSE;
USE DATABASE KLAVIYO_DATABASE;
USE SCHEMA PUBLIC;

CREATE OR REPLACE HYBRID TABLE KLAVIYO_PROFILE_HYBRID (
    ID VARCHAR(32) NOT NULL,
    EXTERNAL_ID VARCHAR(255),
    EMAIL VARCHAR(255),
    PHONE_NUMBER VARCHAR(255),
    FIRST_NAME VARCHAR(255),
    LAST_NAME VARCHAR(255),
    TITLE VARCHAR(255),
    ORGANIZATION VARCHAR(255),
    PROPERTIES OBJECT,
    IMAGE VARCHAR(255),
    CREATED TIMESTAMP_NTZ(9),
    UPDATED TIMESTAMP_NTZ(9),
    LOCATION_ADDRESS1 VARCHAR(255),
    LOCATION_ADDRESS2 VARCHAR(255),
    LOCATION_CITY VARCHAR(255),
    LOCATION_COUNTRY VARCHAR(255),
    LOCATION_LATITUDE VARCHAR(255),
    LOCATION_LONGITUDE VARCHAR(255),
    LOCATION_REGION VARCHAR(255),
    LOCATION_ZIP VARCHAR(255),
    PRIMARY KEY (ID)
);

INSERT INTO KLAVIYO_PROFILE_HYBRID
SELECT * FROM KLAVIYO_PROFILE
WHERE UPDATED < '2024-01-01';

INSERT INTO KLAVIYO_PROFILE_HYBRID
SELECT * FROM KLAVIYO_PROFILE
WHERE UPDATED >= '2024-01-01' AND UPDATED < '2025-01-01';

INSERT INTO KLAVIYO_PROFILE_HYBRID
SELECT * FROM KLAVIYO_PROFILE
WHERE UPDATED >= '2025-01-01' OR UPDATED IS NULL;

Ajusta los límites para que se adapten a los datos y asegúrate de que los rangos no se solapen ni dejen huecos.

Paso 3: añadir índices secundarios

La clave principal en ID se indexa automáticamente. Añade índices secundarios solo para las columnas por las que realmente filtras, porque cada índice consume almacenamiento y añade sobrecarga a las escrituras. Las sentencias siguientes son ejemplos opcionales: usa EMAIL o EXTERNAL_ID para búsquedas en esas columnas, y UPDATED para consultas filtradas por antigüedad. Ejecuta solo las sentencias que necesites, de una en una, y espera a que cada índice termine de construirse antes de iniciar otro.

CREATE INDEX IDX_KLAVIYO_PROFILE_EMAIL
    ON KLAVIYO_PROFILE_HYBRID (EMAIL);

CREATE INDEX IDX_KLAVIYO_PROFILE_EXTERNAL_ID
    ON KLAVIYO_PROFILE_HYBRID (EXTERNAL_ID);

CREATE INDEX IDX_KLAVIYO_PROFILE_UPDATED
    ON KLAVIYO_PROFILE_HYBRID (UPDATED);

Después de cada CREATE INDEX, comprueba su status con SHOW INDEXES. Espera a que esté ACTIVE antes de crear el siguiente índice. Si el estado es BUILD FAILURE, inspecciona status_info, resuelve la causa indicada y, a continuación, elimina y vuelve a crear el índice:

SHOW INDEXES IN TABLE KLAVIYO_PROFILE_HYBRID;

Paso 4: validar el texto

Los recuentos de filas deben coincidir y la consulta de diferencias debe devolver 0.

SELECT
    (SELECT COUNT(*) FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE) AS STANDARD_ROWS,
    (SELECT COUNT(*) FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE_HYBRID) AS HYBRID_ROWS;

SELECT COUNT(*) AS MISSING_IDS
FROM (
    SELECT ID FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE
    MINUS
    SELECT ID FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE_HYBRID
);

Confirma que la nueva tabla sea realmente híbrida y, a continuación, sustituye someone@example.com por un email presente en tus datos. Ejecuta la misma consulta de lectura puntual en la tabla estándar y compara los valores de perfil devueltos. Evalúa el rendimiento usando consultas representativas de tu aplicación real también:

SHOW HYBRID TABLES LIKE 'KLAVIYO_PROFILE_HYBRID';

SELECT * FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE_HYBRID
WHERE EMAIL = 'someone@example.com';

Paso 5: intercambia la tabla híbrida para ponerla en su lugar

Mantén detenidas todas las exportaciones de perfiles y el resto de escritores. Cambia el nombre de la tabla estándar para apartarla, en lugar de eliminarla, para tener una copia de seguridad en caso de revertir los cambios. Confirma que KLAVIYO_PROFILE_STANDARD_BACKUP no esté ya en uso antes de ejecutar estas sentencias. Después del cambio de nombre, actualiza y prueba las dependencias posteriores que identificaste antes para que usen la tabla híbrida.

USE ROLE SYSADMIN;
USE DATABASE KLAVIYO_DATABASE;
USE SCHEMA PUBLIC;

ALTER TABLE KLAVIYO_PROFILE RENAME TO KLAVIYO_PROFILE_STANDARD_BACKUP;
ALTER TABLE KLAVIYO_PROFILE_HYBRID RENAME TO KLAVIYO_PROFILE;

Paso 6: Vuelve a conceder privilegios al rol de Klaviyo

Sustituye el nombre del rol que configuraste como role_name en tu script de configuración de Snowflake.

USE ROLE SECURITYADMIN;

GRANT SELECT, INSERT, UPDATE, DELETE
    ON TABLE KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE
    TO ROLE KLAVIYO_DATA_TRANSFER_ROLE;

SHOW GRANTS ON TABLE KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE;

Paso 7: Reanuda la sincronización y confirma

1. En Klaviyo, vuelve a Advanced KDP > Gestión de datos > Sincronización.
2. Selecciona el destino de Snowflake y abre la pestaña Periódica.
3. En la fila Exportación de perfil, selecciona Reanudar. Reanuda también cualquier exportación de perfiles histórica que hayas pausado en el paso 1.

Las exportaciones periódicas siguen la cadencia configurada para tu destino. Después de que la exportación reanudada procese los cambios de perfil, comprueba que se ejecute sin errores y que esos cambios aparezcan en Snowflake. Una tarea periódica puede volver a Programada entre ejecuciones; no es necesario que muestre Completada. Usa la consulta siguiente para comprobar el recuento de filas y la marca de tiempo de la actualización más reciente del perfil, y comprobar de forma puntual un perfil que sepas que cambió. Estos valores por sí solos no demuestran que se haya exportado cada cambio:

SELECT
    COUNT(*) AS ROW_COUNT,
    MAX(UPDATED) AS LAST_UPDATED
FROM KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE;

Si la sincronización da error, abre la exportación fallida en la pestaña Periódico para leer el resumen del error, el código y el mensaje devuelto por Snowflake. Consulta la sección Ver registros de errores de La sincronización del almacén de datos en Klaviyo. Cuando se completen las exportaciones y las comprobaciones posteriores se superen, reinicia los demás procesos de escritura que detuviste.

Revertir

Si la sincronización falla con la tabla híbrida y necesitas revertirla, pon en pausa cualquier exportación de perfiles activa y confirma que las escrituras de Snowflake en curso hayan finalizado, como en el paso 1. Antes de cambiar el nombre de las tablas, determina si alguna inserción, actualización o eliminación llegó a la tabla híbrida después de que se creara la copia de seguridad. La copia de seguridad no recibe esos cambios.

Si los cambios llegaron a la tabla híbrida, concilia esas inserciones, actualizaciones y eliminaciones en la copia de seguridad estándar antes de restaurarla. Si no puedes conciliar los datos, mantén las exportaciones detenidas y ponte en contacto con el equipo de asistencia de Klaviyo para obtener ayuda y recuperar los cambios que faltan. Reanudar conserva el progreso de la exportación y no vuelve a reproducir automáticamente los cambios que ya se han procesado. Una vez que la copia de seguridad esté actualizada, usa los comandos que aparecen a continuación y sustituye el nombre de tu rol de Klaviyo Service.

USE ROLE SYSADMIN;
USE DATABASE KLAVIYO_DATABASE;
USE SCHEMA PUBLIC;

ALTER TABLE KLAVIYO_PROFILE RENAME TO KLAVIYO_PROFILE_HYBRID;
ALTER TABLE KLAVIYO_PROFILE_STANDARD_BACKUP RENAME TO KLAVIYO_PROFILE;

USE ROLE SECURITYADMIN;
GRANT SELECT, INSERT, UPDATE, DELETE
    ON TABLE KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE
    TO ROLE KLAVIYO_DATA_TRANSFER_ROLE;

Verifica las concesiones del rol de Klaviyo y restaura cualquier acceso y dependencia posteriores en la tabla estándar. Luego, reanuda las exportaciones de perfiles y repite las comprobaciones del paso 7. Para una tarea que muestre Error, selecciona Volver a habilitar en lugar de Reanudar. Mantén la tabla híbrida hasta que hayas confirmado que la tabla restaurada está actualizada y que las exportaciones funcionan. Reinicia cualquier otro escritor una vez que la validación se complete correctamente.

Después de migrar

Mantén la copia de seguridad estándar hasta que hayas validado las exportaciones reanudadas y los consumidores posteriores, y ya no la necesites para revertir los cambios. Cuando esas comprobaciones se superen, elimina la copia de seguridad para que deje de acumular costes de almacenamiento.

USE ROLE SYSADMIN;
DROP TABLE KLAVIYO_DATABASE.PUBLIC.KLAVIYO_PROFILE_STANDARD_BACKUP;

Ten en cuenta lo siguiente de forma continua:

• Cuota de almacenamiento: La cuota predeterminada es de 2 TB de datos de tablas híbridas activas en el almacenamiento de filas por base de datos de Snowflake. Por encima de la cuota, se bloquean las escrituras que añaden datos a cualquier tabla híbrida en esa base de datos, lo que puede hacer que falle la exportación. Elimina datos o tablas para reducir el uso, o ponte en contacto con el servicio de asistencia de Snowflake para solicitar un aumento de la cuota.
• Cuota de solicitudes: Aproximadamente 16 000 operaciones por segundo por base de datos para una carga de trabajo equilibrada del 80 % de lectura / 20 % de escritura.
• Sin sistema de seguridad, Time Travel limitado: UNDROP no es compatible con las tablas híbridas. Mantén tu propio proceso de copia de seguridad si lo necesitas.
• Sin caché de resultados: las consultas en tablas híbridas no utilizan la caché de resultados de consultas persistidas de Snowflake.
• Cost: Snowflake cobra por el almacenamiento de tablas híbridas y por el cómputo del almacén virtual. El almacenamiento en fila es más caro que el almacenamiento estándar, mientras que la tasa de consumo del almacén es la misma. Revisa la documentación de costes de Snowflake y mide la carga de trabajo antes de migrar una tabla grande.

Recursos adicionales

• La sincronización del almacén de datos en Klaviyo
• Conectar Klaviyo y Snowflake
• Snowflake: Tablas híbridas
• Snowflake: Crear tablas híbridas
• Snowflake: limitaciones y funciones no admitidas para tablas híbridas
• Snowflake: Evaluar el coste de las tablas híbridas
• Snowflake: Convertir tablas estándar de Snowflake en tablas híbridas