La mayoría de las oportunidades en curso de integración empresarial entre Salesforce y plataformas de análisis externas se basan en código personalizado. Trabajan hasta que algo se rompe. La desviación de esquemas, el agotamiento de API y los espacios de eliminación permanente requieren una intervención de ingeniería constante. A medida que las empresas empujan hacia arquitecturas ágiles y activadas por el desarrollador ciudadano, 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 informes el lunes por la mañana y los cambios de configuración sencillos requieren revisiones e implementaciones de código.

CRM Analytics, la plataforma nativa de análisis e inteligencia comercial de Salesforce, resuelve este problema permitiendo a las empresas explorar datos, crear paneles interactivos y descubrir perspectivas dirigidas por la IA sin salir del ecosistema de Salesforce. El 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 Cambiar Captura de datos (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. Ambos están configurados completamente a través de Configuración de Salesforce. Sin oportunidades en curso, sin secuencias de comandos de organización, sin supervisión personalizada. 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 ejemplo trabajado y las consideraciones arquitectónicas que determinan si se ajusta a un problema de integración concreto.

Nota de licencia: CRM Analytics SyncIn y SyncOut no están disponibles en ediciones de Salesforce base 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 empresarial. 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 carga masiva y una capa de supervisión para detectar fallos. Cada componente del código personalizado representa un punto de fallo.

El coste de estos compuestos 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 de forma permanente 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. La configuración sustituye al 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 supervisar 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 integración a la sincronización operativa, un menor gasto de ingeniería 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 traslada 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.

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 lo gestiona de extremo a extremo.

La sincronización completa frente a la 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 significativamente.

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 análisis de tabla completos. CDC debe estar activado por objeto en Configuración de Salesforce antes de que se pueda hacer referencia a él por una configuración de sincronización.

El seguimiento de eliminación permanente resuelve uno de los problemas más persistentes en Salesforce-to-external ETL. 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 coste de cálculo de almacén de Snowflake. Las sincronizaciones de 15 minutos se aproximan casi en tiempo real para paneles operativos; las sincronizaciones diarias son apropiadas para cargas de trabajo de creación de informes 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 de cómo dimensionar y programar trabajos de sincronización. La plataforma gestiona el desplazamiento y la paginación automáticamente, pero los arquitectos deben tener en cuenta el margen 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 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 de plataforma clave 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 tipo 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.

Arquitectura SyncOut

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 introduce resultados en Salesforce utilizando la API masiva 2.0. Los conjuntos de resultados grandes 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.

SyncIn Architecture

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 empresa 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 de 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 apretón de manos 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 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 a los perfiles relevantes de Salesforce acceso a la credencial nombrada; sin este acceso, los trabajos de sincronización fallan debido a errores de autenticación independientemente de todas las demás 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 exclusiva con una función de menor privilegio con ámbito únicamente a las bases de datos, esquemas y 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 abandono: Durante la extracción de SyncOut, los grandes conjuntos de resultados se segmentan 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 volver a cargar datos en Salesforce. Esto requiere que se configure un campo Id. externo designado en el objeto de Salesforce de destino para actuar 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 comercial, reduciendo el volumen de datos, la duración de la sincronización y los costes de cálculo de 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 panel Supervisor de trabajos de sincronización proporciona estado en tiempo real, recuentos 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 ejecuciones de sincronización: marca de tiempo, recuentos de registros y errores; estos no se generan automáticamente por la plataforma. Para la validación de extremo a extremo, compare recuentos de registros entre ambas plataformas: verifique registros activos en Snowflake (WHERE DEL_FLAG = 'N') para ejecuciones de SyncOut y compare recuentos 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 tanto a Salesforce a través de SyncIn como 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 el consumo de API y la duración de la sincronización significativamente frente a los análisis completos.
  • La sincronización por lotes programada cumple los requisitos de latencia: La frecuencia de sincronización mínima es de 15 minutos, adecuada para paneles operativos y creación de informes de análisis casi en tiempo real.
  • Los bajos gastos generales operacionales son una prioridad: Los paneles integrados proporcionan visibilidad de sincronización completa sin infraestructura de registro o alerta personalizada, y la interfaz de usuario de Configuración declarativa permite a los administradores definir, modificar y supervisar 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 comercial 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 se sirven mejor 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 tuberías eran lentas, frágiles y requerían 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 paneles 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 almacenamiento 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 descendente 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 empresa adquirente sincronizó seis objetos de Salesforce de gran volumen en Snowflake para la creación de informes 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 recuentos 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 informes 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 en 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 informáticos. Para consultas SELECT sencillas, un almacén X-Small o Small suele ser suficiente. Para cargas de SyncOut grandes, se pueden requerir Medianas o Grandes. 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 costes y evitar disputas con consultas de usuarios.

Si un campo de Salesforce cambia de nombre, se elimina o cambia el nombre de API, la asignación de 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 permanentes” no tiene efecto. Valide la activación de CDC como parte de la lista de comprobación de configuración de sincronización, especialmente durante la configuración inicial o después de migraciones de organización.

La clase de fallo más común es caducidad de credenciales o pérdida de permiso. Las credenciales nombradas deben seguir siendo válidas y la cuenta de servicio de Snowflake debe mantener sus permisos de tabla 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. Supervise el panel Supervisor de trabajos de sincronización para patrones de error de autenticación y configure notificaciones Chatter o por correo electrónico 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 Credencial nombrada y el vencimiento 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.
  • Se ha superado el límite regulador: reducir la frecuencia de sincronización o pasar al modo CDC incremental para propagar el consumo de API.
  • Almacén de Snowflake suspendido: configurar la reanudación automática en el almacén o desencadenar una reanudación manual antes de la siguiente sincronización programada.
  • Seguimiento de eliminación permanente no funciona: confirme que CDC está activado en el objeto y el indicador “Seguir eliminaciones permanentes” 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 Supervisor de trabajos de sincronización. Implemente la reconciliación de recuento de registros después de fallos para confirmar la coherencia, complementar con notificaciones de fallos y supervisar 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 fallida 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 costes: El modo CDC incremental es la palanca principal para la optimización del rendimiento. Reduce el consumo de API, la duración de la sincronización y el coste de cálculo de Snowflake en comparación con la sincronización completa. El filtrado previo de la vista 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 participación de ingeniería. Los paneles de supervisión integrados proporcionan observabilidad completa sin infraestructura de registro personalizada.
  • Fiabilidad (escalabilidad): La plataforma gestiona el desplazamiento, la paginación y el lote 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 Cambiar Captura de datos en todos los objetos de Salesforce pensados para el modo incremental SyncOut (Configuración → Cambiar Captura de datos).
  • 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 la 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 una credencial externa y vincule al 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 campo, CDC, seguimiento de eliminación permanente, programación.
  • Comience con la sincronización diaria; valide la calidad y el rendimiento de esos datos antes de aumentar la frecuencia.

Configuración SyncIn:

  • Crear una fuente de datos externa (Configuración → Analytics Studio → Gestor de datos → Conexiones → Conexiones de Snowflake).
  • Crear configuración de SyncIn: vista de origen, objeto de destino, campo Id. externo, asignaciones de campo, programación.
  • Sincronice desde vistas de Snowflake, no tablas sin procesar.

Validación:

  • Revise Supervisión de trabajos de sincronización después de la primera ejecución (Configuración → Analytics Studio → Gestor de datos → Supervisión de trabajos de sincronización).
  • Consulte la tabla de auditoría de Snowflake para confirmar que se redactaron los metadatos de sincronización.
  • Valide el marcado de eliminación permanente confirmando que la columna DEL_FLAG está presente y rellenada.
  • Compare recuentos de registros entre origen y destino.
  • Configure notificaciones de fallos mediante Chatter o correo electrónico.

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 compatible.

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 datos e inteligencia. Lidera iniciativas de Enterprise Architecture Review Board (EARB) centradas en la gobernanza de datos y modelos de datos unificados, mientras contribuye a soluciones de aprovisionamiento de plataforma automatizadas.