La mayoría de las oportunidades en curso de integración de compañía entre Salesforce y plataformas de análisis externas se basan en código personalizado. Funcionan hasta que algo se rompe. La desviación de esquemas, el agotamiento de API y las brechas de eliminación permanente requieren una intervención de ingeniería constante. A medida que las compañías empujan hacia arquitecturas ágiles activadas por el desarrollador de ciudadanos, este modelo se convierte en un cuello de botella: Los equipos de análisis esperan en sprints de ingeniería para agregar un campo de Salesforce a un esquema descendente, las cargas nocturnas fallidas retrasan la creación de reportes el lunes por la mañana y los cambios de configuración sencillos requieren revisiones e implementaciones de código.
CRM Analytics, la plataforma de análisis e inteligencia de negocio nativa de Salesforce, resuelve este problema permitiendo a las compañías explorar datos, crear tableros interactivos y descubrir perspectivas dirigidas por IA sin salir del ecosistema de Salesforce. Un elemento central de esta función es una función de sincronización de datos declarativa de código bajo creada de forma nativa en la plataforma: CRM Analytics SyncOut y CRM Analytics SyncIn.
CRM Analytics SyncOut traslada registros de Salesforce a establecimientos de datos externos en una programación configurada, utilizando Captura de datos de cambios (CDC) para cargas incrementales y seguimiento de eliminación permanente integrado para marcar registros eliminados permanentemente. CRM Analytics SyncIn devuelve datos externos a Salesforce, asignando columnas a campos de objetos y alterando registros utilizando la API masiva 2.0. Ambas están configuradas completamente a través de Configuración de Salesforce. Sin oportunidades en curso, sin secuencias de comandos de organización, sin monitoreo personalizado. Los administradores configuran un trabajo de sincronización en una única sesión de Configuración; la plataforma gestiona la ejecución, el reintento, el registro de errores y la asignación de esquemas automáticamente.
Esta guía explica el patrón, cuándo utilizarlo, cómo implementarlo con Snowflake como un ejemplo trabajado y las consideraciones arquitectónicas que determinan si se ajusta a un problema de integración concreto.
Nota de licencia: SyncIn y SyncOut de CRM Analytics no están disponibles en las ediciones base de Salesforce sin un complemento de licencia de CRM Analytics. Confirme las asignaciones de licencias antes de diseñar una arquitectura de sincronización que dependa de estas funciones.
La integración de datos es una de las superficies de mayor fricción en la arquitectura de la compañía. Una canalización de ETL personalizada desde Salesforce a una plataforma de análisis normalmente requiere una aplicación conectada para la autenticación, un trabajo programado para la extracción de SOQL, una capa de transformación para conciliar tipos de campo, un área de preparación para la carga masiva y una capa de monitoreo para detectar fallos. Cada componente de código personalizado representa un punto de fallo.
El costo de este compuesto de fricción a lo largo del tiempo. La desviación de esquemas en Salesforce (un campo cambiado de nombre, un nuevo valor de lista de selección, un nombre de API cambiado) interrumpe las oportunidades en curso de forma silenciosa. El agotamiento de API durante el uso máximo detiene la extracción. Los registros eliminados permanentemente nunca aparecen en la tabla de destino, dejando datos obsoletos que los análisis descendentes tratan como en vivo. El equipo de ingeniería se convierte en el cuello de botella para operaciones de datos rutinarias.
CRM Analytics SyncIn y SyncOut cambian el modelo operativo. Configuración sustituye código. La plataforma asume la responsabilidad de la ejecución, la gestión de errores, la asignación de esquemas y la observabilidad. Los administradores pueden definir, modificar y monitorear trabajos de sincronización sin elevar un ticket de desarrollo.
El resultado de este nuevo modelo operativo es un tiempo reducido desde el diseño de la integración a la sincronización operativa, una carga de trabajo de ingeniería inferior y un modelo de integración que se amplía dentro de las restricciones de la plataforma en vez de requerir mantenimiento de código personalizado.
SyncIn y SyncOut son los dos modos direccionales de sincronización de datos de CRM Analytics. SyncOut mueve registros de Salesforce a una plataforma externa. SyncIn aporta registros externos a Salesforce. Ambos funcionan en un modelo de configuración declarativa sin necesidad de código personalizado.
La configuración declarativa significa que todo el comportamiento de sincronización se define a través de la interfaz de usuario de apuntar y hacer clic en Configuración de Salesforce. El objeto de origen, la tabla de destino, las asignaciones de campos, la programación de sincronización, el modo de sincronización y los filtros se establecen a través de metadatos de configuración. La plataforma deriva el plan de ejecución de esos metadatos y los gestiona de extremo a extremo.
Sincronización completa frente a sincronización incremental controla qué datos se mueven en cada ejecución. Una sincronización completa consulta todos los registros que coinciden con los criterios de filtro en cada ejecución. Una sincronización incremental utiliza CDC para consultar solo registros que cambiaron desde la última ejecución. La sincronización incremental es el modo recomendado para objetos de gran volumen, ya que reduce el consumo de API y la duración de la sincronización de forma significativa.
Captura de datos es una función de plataforma de Salesforce que registra cambios a nivel de campo en objetos como transmisiones de eventos. SyncOut utiliza CDC para detectar creaciones, actualizaciones y eliminaciones sin realizar exploraciones de tablas completas. CDC debe estar activado por objeto en Configuración de Salesforce antes de que se pueda hacer referencia a él mediante una configuración de sincronización.
El seguimiento de eliminación permanente resuelve uno de los problemas más persistentes en Salesforce a ETL externo. Cuando se elimina un registro de forma permanente en Salesforce, desaparece de las consultas SOQL estándar. Sin un seguimiento explícito, la plataforma externa nunca se entera de que se eliminó el registro. El seguimiento de eliminación permanente de SyncOut, cuando se activa, marca registros eliminados en la tabla de destino con DEL_FLAG = 'Y', proporcionando a los sistemas descendentes una señal fiable para filtrar datos obsoletos.
La frecuencia de sincronización es configurable desde 15 minutos a semanal. La opción es una compensación entre la actualización de datos, el consumo de API y el costo de computación de almacén de Snowflake. Las sincronizaciones de 15 minutos se aproximan casi en tiempo real para tableros operativos; las sincronizaciones diarias son apropiadas para cargas de trabajo de creación de reportes por lotes.
El regulador limita el diseño de trabajos de sincronización de restricciones: El límite de solicitudes de API de Salesforce (15.000 llamadas por 24 horas en Unlimited Edition), el tamaño de lote de API masiva 2.0 de 10.000 registros y el límite de filas de consultas SOQL de 50.000 por transacción informan sobre cómo dimensionar y programar trabajos de sincronización. La plataforma gestiona la fragmentación y la paginación automáticamente, pero los arquitectos deben tener en cuenta el espacio de maniobra limitado entre todos los trabajos de sincronización que se ejecutan en la organización.
Snowflake es un destino principal y un origen para la sincronización de datos con Salesforce CRM Analytics. Sirve como un ejemplo concreto de cómo funciona el movimiento de datos por lotes e incremental de extremo a extremo.
Esta sección proporciona una descripción general de la implementación de CRM Analytics SyncOut y SyncIn utilizando Snowflake como plataforma de análisis externa. Cubre cada método, los modelos de autenticación compartidos, los marcos de trabajo de seguridad, las consideraciones clave de la plataforma y las prácticas de observabilidad.
En esta configuración de SyncOut, Salesforce utiliza CRM Analytics SyncOut para enviar registros a Snowflake. La plataforma extrae datos a través de SOQL, gestiona conversiones de tipos automáticamente y los carga en tablas de Snowflake en una programación configurada (que varía de 15 minutos a semana). Consulte la documentación actual de Salesforce y Snowflake para obtener semántica de carga específica.

En esta configuración de SyncIn, Salesforce utiliza CRM Analytics SyncIn para extraer datos de vuelta a Salesforce. La plataforma consulta Snowflake a través de la API de declaraciones e inserta resultados en Salesforce utilizando la API masiva 2.0. Los conjuntos de resultados de gran tamaño se paginan automáticamente para permanecer dentro de los límites de la API. La sincronización se ejecuta en una programación configurada, que oscila entre 15 minutos y semanalmente.

La sincronización de Salesforce admite múltiples métodos de autenticación para conectar de forma segura con Snowflake. Los dos enfoques principales para integraciones de compañía son Par de claves (Clave privada) y OAuth 2.0 delegado.
Método 1: Autenticación de pares de claves (clave privada): La autenticación de pares de claves es el enfoque recomendado para el movimiento de datos automatizado de sistema a sistema como CRM Analytics SyncIn y SyncOut. La autenticación se basa en tokens web JSON (JWT) en vez de contraseñas o tokens actualizables, lo que la hace perfecta para trabajos programados desatendidos que no requieren actualización de token.
- Certificado de Salesforce: Genere una clave privada y almacénela de forma segura en Gestión de certificados y claves de Salesforce.
- Credencial externa/nombrada: Configurado para utilizar un intercambio JWT. Salesforce utiliza la clave privada almacenada para firmar solicitudes de conexión salientes.
- Clave pública de usuario de Snowflake: La clave pública coincidente se asigna directamente a la cuenta de servicio de Snowflake dedicada (por ejemplo, ALTER USER CRM_ANALYTICS_SYNC_USER SET RSA_PUBLIC_KEY = ’…’). Snowflake utiliza esta clave para verificar la firma JWT entrante. No se requiere integración de seguridad para este método.
Método 2: Autenticación de OAuth 2.0 delegada: De manera alternativa, Salesforce puede utilizar un apretón de manos de OAuth para autenticarse. Los componentes clave son:
- Proveedor de autenticación: Gestiona el saludo de OAuth con Snowflake, utilizando las credenciales de cliente recuperadas desde la integración de seguridad de Snowflake.
- Credencial externa: Mantiene los tokens de OAuth de forma segura en Salesforce y los inyecta en las llamadas de sincronización automáticamente.
- Credencial nombrada: Define la URL del extremo de Snowflake (por ejemplo, https://<account>.snowflakecomputing.com) y hace referencia a la credencial externa.
- Integración de seguridad de Snowflake: Registra Salesforce como un cliente de confianza de OAuth en Snowflake (OAUTH_CLIENT = CUSTOM). Define el URI de redireccionamiento permitido y activa tokens de actualización.
Dependencia de configuración: Independientemente del método elegido, estos componentes forman una cadena de dependencia que conecta la configuración de sincronización con el extremo. Se requiere otorgar acceso a los perfiles de Salesforce relevantes a la Credencial nombrada; sin este acceso, los trabajos de sincronización fallan debido a errores de autenticación independientemente del resto de configuraciones.
La sincronización en segundo plano se basa en una única identidad de integración.
- Cuenta de servicio exclusiva: Cree una cuenta de servicio de Snowflake dedicada con una función de menor privilegio con ámbito únicamente a las bases de datos, los esquemas y las tablas requeridos para la sincronización.
- Permisos granulares: Para SyncOut, esta función requiere INSERTAR, ACTUALIZAR y SELECCIONAR en tablas de destino. Nunca utilice funciones de alto privilegio como ACCOUNTADMIN, SECURITYADMIN o SYSADMIN.
- Límites reguladores y fragmentación: Durante la extracción de SyncOut, los conjuntos de resultados de gran tamaño se fragmentan automáticamente para respetar los límites reguladores de Salesforce SOQL. SyncIn obtiene grandes conjuntos de resultados desde la API de declaraciones de Snowflake a través de paginación automática para gestionar volúmenes de datos de forma eficiente.
- Captura de datos de cambios (CDC): SyncOut incremental se basa en la transmisión de eventos de Salesforce CDC para identificar registros creados, actualizados o eliminados. Si el seguimiento de eliminación permanente está activado, los registros de Salesforce eliminados no se descartan sino que se marcan con
DEL_FLAG = 'Y'en Snowflake. - Restricciones de inserción: SyncIn se basa en la API masiva 2.0 para cargar datos de vuelta en Salesforce. Esto requiere que se configure un campo Id. externo designado en el objeto de Salesforce de destino para que actúe como la clave de alteración.
- Orientación de diseño: Sincronice siempre desde vistas de Snowflake depuradas en vez de tablas sin procesar. Las vistas permiten el filtrado previo de filas, la selección de columnas y la aplicación de lógica de negocio, lo que reduce el volumen de datos, la duración de la sincronización y los costos de computación del almacén de Snowflake en proporción al filtrado previo aplicado.
Cada ejecución de sincronización genera seguimientos de auditoría integrales para validar el movimiento de datos. El tablero Monitor de trabajos de sincronización proporciona estado en tiempo real, conteos de registros procesados, duraciones de ejecución y registros de errores detallados para SyncIn y SyncOut. En el lado de Snowflake, cada consulta enviada por Salesforce se registra en Historial de consultas de Snowflake, proporcionando visibilidad completa de la latencia de ejecución, las filas exploradas y el uso de computación de almacén. Además, los arquitectos definen tablas de auditoría de Snowflake exclusivas para capturar metadatos de ejecución de sincronización: marca de tiempo, conteos de registros y errores; estos no se generan automáticamente por la plataforma. Para la validación de extremo a extremo, compare conteos de registros entre ambas plataformas: verifique registros activos en Snowflake (WHERE DEL_FLAG = 'N') para ejecuciones de SyncOut y compare conteos de objetos de destino de Salesforce directamente con la vista de origen de Snowflake original para ejecuciones de SyncIn.
Utilice CRM Analytics SyncIn y SyncOut cuando:
- La sincronización bidireccional es un requisito: Los datos fluyen a Salesforce a través de SyncIn y a una plataforma externa a través de SyncOut.
- El seguimiento de eliminación permanente es fundamental: El marcado integrado de SyncOut resuelve un problema de ETL complejo históricamente sin lógica de reconciliación personalizada.
- La sincronización incremental basada en CDC es viable: Para objetos de Salesforce de gran volumen, los CDC reducen significativamente el consumo de API y la duración de la sincronización frente a las exploraciones completas.
- La sincronización por lotes programada cumple los requisitos de latencia: La frecuencia de sincronización mínima es de 15 minutos, adecuada para tableros operativos y reportes de análisis casi en tiempo real.
- Los bajos gastos generales operativos son una prioridad: Los tableros integrados proporcionan visibilidad de sincronización completa sin registro personalizado o infraestructura de alerta, y la interfaz de usuario de Configuración declarativa permite a los administradores definir, modificar y monitorear trabajos de sincronización sin elevar un ticket de desarrollo.
No utilice este patrón si:
- Se requieren transformaciones complejas: Uniones de múltiples tablas, análisis JSON o gestionar lógica de negocio avanzada en vistas de Snowflake o una capa de transformación dedicada antes o después de la sincronización.
- Se requiere una latencia de menos de 15 minutos: Para casos de uso en tiempo real, utilice Eventos de plataforma o API de transmisión.
- Las cargas de trabajo de transmisión de gran volumen están en el ámbito: Los objetos con millones de transacciones por hora están mejor servidos por oportunidades en curso de transmisión exclusivas (Kafka, Eventos de plataforma).
- Se necesita lógica de gestión de errores personalizada: La plataforma proporciona reintento estándar y registro de errores. Los patrones de reintento complejos o las alertas personalizadas requieren Apex u orquestación externa.
- Sincronización entre organizaciones o entre nubes: CRM Analytics SyncIn y SyncOut funcionan en una única organización de Salesforce. Se requiere MuleSoft o una capa de integración personalizada para escenarios de múltiples organizaciones.
Un equipo ejecutó oportunidades en curso de ETL complejas para cargar datos de análisis de Snowflake en conjuntos de datos de CRM Analytics. Las oportunidades en curso eran lentas, frágiles y requerían un mantenimiento de ingeniería constante.
CRM Analytics SyncIn se configuró para sincronizar vistas agregadas de Snowflake depuradas directamente en objetos personalizados de Salesforce. El equipo volvió a configurar tableros de CRM Analytics para leer desde esos objetos en vez de conjuntos de datos de CRM Analytics. El resultado: se eliminaron dos oportunidades en curso de ETL, la duración de la sincronización se redujo de cuatro horas a 30 minutos y los administradores pueden modificar configuraciones de sincronización sin elevar un ticket de ingeniería.
Un equipo de datos necesitaba realizar un seguimiento de registros de Salesforce eliminados de forma permanente en su almacén de datos operativo Snowflake. Los enfoques tradicionales requerían trabajos divididos y una lógica de reconciliación de Id. compleja que tardaba horas en ejecutarse y era frágil entre los cambios de esquema.
El equipo configuró CRM Analytics SyncOut con CDC y seguimiento de eliminación permanente activado. Los registros eliminados ahora se marcan automáticamente con DEL_FLAG = ‘Y’ en la tabla de consumo de Snowflake. Las consultas de análisis descendentes se aplican WHERE DEL_FLAG = ‘N’ para ver solo registros activos. La lógica de reconciliación se eliminó por completo, y la duración de la sincronización se redujo de ocho horas a ejecuciones incrementales de 15 minutos.
Durante una adquisición, la compañía adquirente sincronizó seis objetos de Salesforce de gran volumen en Snowflake para la creación de reportes entre organizaciones y el cumplimiento normativo en una cronología fija.
El equipo configuró CRM Analytics SyncOut para los seis objetos con sincronizaciones incrementales basadas en CDC. Las tablas de metadatos de auditoría realizaron un seguimiento de los cambios de esquema y conteos de registros en el periodo de integración. No redactaron ningún código personalizado. La actualización de los datos mejoró de intervalos diarios a intervalos de 15 minutos, y las tablas de metadatos de auditoría proporcionaron la trazabilidad requerida para la creación de reportes de cumplimiento.
Los trabajos de sincronización comparten el presupuesto de API de la organización. Una organización que ejecuta muchos trabajos de sincronización de alta frecuencia con objetos de gran tamaño corre el riesgo de agotar las 15.000 llamadas de API por límite de 24 horas. Inventario de todos los trabajos de sincronización, estimación del consumo de API por ejecución y escalonamiento de programaciones para distribuir la carga. Para objetos con índices de cambio de bajos a moderados, el modo incremental basado en CDC puede reducir significativamente el consumo de API por ejecución en comparación con la sincronización completa.
SyncIn y SyncOut ejecutan consultas y cargas de datos en un almacén de Snowflake, consumiendo créditos de computación. Para consultas SELECT sencillas, un almacén X-Small o Small suele ser suficiente. Para cargas de SyncOut grandes, es posible que se requiera Mediano o Grande. Configure la suspensión automática (5 minutos de inactividad) y la reanudación automática en el almacén. Utilice un almacén exclusivo para trabajos de sincronización de producción para aislar costos y evitar conflictos con consultas de usuarios.
Si un campo de Salesforce cambia de nombre, se elimina o cambia el nombre de API, la asignación del campo SyncOut correspondiente falla de forma silenciosa o registra errores. Establezca un proceso de gestión de cambios que incluya la revisión de configuraciones de sincronización activas como parte de cualquier cambio de metadatos de Salesforce. Las tablas de auditoría de Snowflake proporcionan un historial de cambios que ayuda a identificar cuándo se produjo un evento de desviación.
El seguimiento de eliminación permanente en SyncOut requiere que CDC esté activado en el objeto Salesforce. Si CDC no está activado, la opción “Seguir eliminaciones definitivas” no tiene efecto. Valide la activación de CDC como parte de la lista de comprobación de configuración de sincronización, particularmente durante la configuración inicial o después de migraciones de organización.
La clase de fallo más común es la caducidad de credenciales o la pérdida de permisos. Las credenciales nombradas deben seguir siendo válidas y la cuenta de servicio de Snowflake debe mantener sus permisos de tablas y subvenciones de uso de almacén. Para configuraciones basadas en OAuth, los fallos de actualización de tokens pueden estancar silenciosamente los trabajos de sincronización. Monitoree el tablero Monitoreo de trabajos de sincronización para patrones de error de autenticación y configure notificaciones Chatter o de email para fallos de trabajos.
SyncIn utiliza un campo Id. externo de Salesforce como la clave de alteración. Si la vista de Snowflake de origen contiene valores duplicados en el campo clave, la alteración falla para registros afectados. Aplique la exclusividad en el campo clave en la capa de vista de Snowflake antes de que alcance la configuración de sincronización.
Cuando fallan los trabajos de sincronización, la plataforma registra mensajes de error detallados por registro en el Monitor de trabajos de sincronización. Escenarios de fallo comunes y sus resoluciones:
- Fallo de autenticación: verificar el estado de Credencial nombrada y la caducidad de la cuenta de Snowflake. Vuelva a autenticar OAuth si la actualización del token ha fallado.
- Error de asignación de campos: compruebe la compatibilidad de tipos entre columnas de Snowflake y campos de Salesforce. Revise la seguridad a nivel de campo para el usuario que ejecuta.
- Límite regulador superado: reduzca la frecuencia de sincronización o pase al modo CDC incremental para difundir el consumo de API.
- Almacén de copo de nieve suspendido: configure la reanudación automática en el almacén o desencadene una reanudación manual antes de la siguiente sincronización programada.
- El seguimiento de eliminación permanente no funciona: confirme que CDC está activado en el objeto y el indicador “Seguir eliminaciones definitivas” está establecido en la configuración de sincronización.
La sincronización de datos de CRM Analytics se alinea con múltiples pilares del Marco de trabajo bien arquitectónico de Salesforce.
- Fiabilidad (tolerancia a fallos): La plataforma gestiona la ejecución, la lógica de reintento y la gestión de fallos parciales automáticamente. Los registros con fallos se registran individualmente en el Monitor de trabajos de sincronización. Implemente la reconciliación de conteo de registros después de fallos para confirmar la coherencia, complementar con notificaciones de fallos y monitorear el Monitor de trabajos de sincronización para patrones de error recurrentes. La sincronización incremental basada en CDC reduce el radio de explosión de una ejecución con fallo limitando el ámbito de la ventana de datos.
- Confianza: El modelo de credenciales (Credenciales nombradas, Credenciales externas, Proveedor de autenticación) aplica almacenamiento cifrado, actualización de token automática y gestión centralizada. El acceso con menos privilegios en el lado de Snowflake limita el radio de explosión de una credencial comprometida. La seguridad a nivel de campo se aplica durante la sincronización; los usuarios no pueden sincronizar campos a los que no están autorizados a acceder.
- Optimización de recursos y costos: El modo CDC incremental es la palanca principal para la optimización del desempeño. Reduce el consumo de API, la duración de la sincronización y el costo de computación de Snowflake en comparación con la sincronización completa. El filtrado previo de vistas de Snowflake reduce aún más el volumen de datos en tránsito. La suspensión automática de almacén evita el gasto de computación inactivo.
- Excelencia operativa: El modelo de configuración declarativa significa que los trabajos de sincronización se definen en metadatos, no en código. Esto los hace auditables, reproducibles y gestionables sin implicación de ingeniería. Los tableros de monitoreo integrados proporcionan observabilidad completa sin infraestructura de registro personalizada.
- Fiabilidad (escalabilidad): La plataforma gestiona la fragmentación, la paginación y los lotes de API masiva automáticamente. Para objetos con volúmenes de registro muy altos, el modo CDC incremental y la programación fuera de horas punta son las palancas arquitectónicas principales para mantener el rendimiento dentro de las restricciones del límite regulador.
Esta lista de comprobación cubre los pasos mínimos para configurar y validar una configuración de sincronización.
Lista de comprobación de configuración previa:
- Active Captura de datos de cambios en todos los objetos de Salesforce destinados al modo incremental SyncOut (Configuración → Captura de datos de cambios).
- Cree una cuenta de servicio de Snowflake exclusiva con una función de menor privilegio; otorgue solo los permisos de almacén y tabla requeridos.
- Cree una integración de seguridad de Snowflake si utiliza autenticación de OAuth.
- Identifique el campo Id. externo en cada objeto de Salesforce que SyncIn utilizará como la clave de alteración; confirme la exclusividad en los datos de origen.
Conectividad:
- Crear proveedor de autenticación en Salesforce (Configuración → Proveedores de autenticación).
- Cree credenciales externas y vincule a Proveedor de autenticación (Configuración → Credenciales nombradas → Credenciales externas).
- Cree Credencial nombrada y vincule a Credencial externa (Configuración → Credenciales nombradas).
- Otorgue acceso a Credencial nombrada a perfiles relevantes de Salesforce.
Configuración de SyncOut:
- Cree Conexión de Snowflake (Configuración → Analytics Studio → Gestor de datos → Conexiones → Conexiones de Snowflake).
- Crear configuración de SyncOut: objeto de origen, tabla de destino, modo de sincronización, asignaciones de campos, CDC, seguimiento de eliminación permanente, programación.
- Comience con la sincronización diaria; valide la calidad y el desempeño de esos datos antes de aumentar la frecuencia.
Configuración SyncIn:
- Crear origen de datos externo (Configuración → Analytics Studio → Gestor de datos → Conexiones → Conexiones de Snowflake).
- Crear configuración SyncIn: vista de origen, objeto de destino, campo Id. externo, asignaciones de campos, programación.
- Sincronice desde vistas de Snowflake, no tablas sin procesar.
Validación:
- Revise Monitor de trabajos de sincronización después de la primera ejecución (Configuración → Analytics Studio → Gestor de datos → Monitor de trabajos de sincronización).
- Consulte la tabla de auditoría de Snowflake para confirmar que se redactaron metadatos de sincronización.
- Valide el marcado de eliminación permanente confirmando que la columna DEL_FLAG está presente y rellenada.
- Compare conteos de registros entre origen y destino.
- Configure notificaciones de fallos mediante Chatter o email.
Utilice este patrón cuando la sincronización por lotes programada cumpla los requisitos de latencia, el flujo de datos bidireccional sea necesario y la reducción de la dependencia de ingeniería en operaciones de integración sea una prioridad.
El ejemplo trabajado de Snowflake en esta guía ilustra el ciclo de vida completo: configuración de conectividad, configuración, flujo de ejecución y validación. Los mismos principios se aplican a cualquier plataforma de datos externa admitida.
Cuando la latencia de menos de 15 minutos, transformaciones complejas o escenarios de múltiples organizaciones están en el ámbito, evalúe Eventos de plataforma, API de transmisión o MuleSoft como enfoques complementarios o alternativos.
Yugandhar Bora es Arquitecto de Ingeniería de Software en Salesforce, especializado en arquitectura de datos dentro de la plataforma Aplicaciones de inteligencia y datos. Lidera iniciativas del Consejo de Revisión de Arquitectura Empresarial (EARB) centradas en la gobernanza de datos y modelos de datos unificados, mientras contribuye a soluciones de aprovisionamiento de plataforma automatizadas.