Presentando el nuevo conector Oracle CDC
Oracle gestiona muchos de los sistemas más críticos de la empresa, como ERP, finanzas, pedidos e inventario. Diariamente, estos sistemas registran un flujo constante de cambios a medida que se desarrollan las operaciones. Se ha creado el nuevo conector de origen CDC de Oracle Database para Microsoft Fabric Eventstream (versión preliminar) para que pueda incorporar esos cambios a Fabric en el momento en que se producen. El conector captura cada inserción, actualización y eliminación como un evento de cambio estructurado, de modo que un pedido que pasa a estado de enviado, un saldo que cae por debajo de cero o un recuento de inventario que alcanza el nivel de reposición se refleja en Fabric de inmediato.
En lugar de esperar a que se realice una extracción nocturna que proporcione una instantánea actualizada del estado final, el conector transmite cada cambio de la base de datos Oracle a Fabric como un evento de cambio estructurado, que incluye información sobre el estado de la fila antes y después de la modificación. De esta forma, los usuarios pueden saber exactamente qué cambió y actuar en consecuencia de inmediato.
¿Qué es el CDC y por qué es importante?
La captura de cambios de datos (CDC, por sus siglas en inglés) es un método para rastrear los cambios de datos en una base de datos a medida que ocurren. En lugar de copiar la tabla completa según un cronograma, la CDC supervisa el registro de transacciones de la base de datos y registra cada inserción, actualización y eliminación individual a nivel de fila.
Cada cambio se registra como un evento estructurado que incluye el tipo de operación (crear, actualizar o eliminar) junto con los valores de la fila antes y después del cambio. Esto proporciona un registro continuo de qué cambió y cuándo, lo que permite que los sistemas posteriores reaccionen en tiempo real.
Las principales ventajas son una menor carga en el sistema de origen, una actualización casi en tiempo real y una visibilidad completa de cómo ha evolucionado un registro a lo largo del tiempo, en lugar de solo su estado actual.
Una sucesión de eventos de cambio puede liberar un valor real:
- Permite aplicaciones basadas en eventos: Cada cambio se convierte en una señal a la que sus sistemas pueden reaccionar al instante, sin necesidad de sondeo ni de esperar a la siguiente ejecución programada. Un nuevo pedido puede iniciar de inmediato el procesamiento posterior, y un cambio de estado puede activar el flujo de trabajo adecuado.
- Te ofrece información detallada sobre los cambios, además del estado final: una instantánea de lote te muestra los valores actuales de una fila. Un evento de cambio te indica que la fila pasó de "PEDIDO REALIZADO" a "ENVIADO" y conserva el valor anterior, para que puedas ver la transición, medir cuánto tiempo tardó y comprender por qué los datos tienen ese aspecto.
- Convierte cada cambio en una acción: Dado que cada evento incluye los detalles del antes y el después, puedes activar flujos de trabajo, generar alertas y generar actualizaciones posteriores a partir del cambio en sí, en lugar de volver a escanear toda la tabla. Por ejemplo, cuando una fila de pedido se actualiza de "PEDIDO REALIZADO" a "ENVIADO", ese único evento puede enviar al cliente una notificación de envío y actualizar el panel de entregas, sin necesidad de reprocesar toda la tabla de pedidos.
Qué puedes hacer con un evento de cambio
Una vez que los cambios de Oracle llegan a Eventstream, cada evento es un disparador sobre el que se puede construir:
- Dirija el mismo flujo a varios destinos a la vez: envíe los cambios a un Eventhouse para análisis KQL y paneles en tiempo real, a un Lakehouse para análisis históricos y a otros destinos de Fabric en paralelo, todo desde un único flujo de eventos y sin recargas completas. Por ejemplo, mantenga los cambios de pedidos detallados en un Eventhouse para una visualización en vivo, mientras que una copia resumida llega a un Lakehouse para informes de tendencias.
- Activa alertas y acciones automatizadas con Activator: Establece condiciones en el flujo de cambios para que Activator genere una alerta o inicie una acción en el momento en que se cumplan. Por ejemplo, notifica al equipo de éxito del cliente en Teams cuando el saldo de una cuenta premium supere un umbral o cuando un envío cambie a "RETRASADO".
- Reconstruye la historia detrás de los datos: Dado que las eliminaciones y actualizaciones conservan el estado anterior, puedes crear un registro de auditoría que muestre cómo un registro alcanzó su valor actual. Esto es útil para el cumplimiento normativo, la depuración y el análisis del cambio en sí, como por ejemplo, para medir cuánto tiempo permanecen los pedidos en estado "PEDIDO REALIZADO" antes de ser enviados.
Sobre este nuevo conector:
El conector utiliza Oracle LogMiner, un mecanismo nativo de Oracle para leer el registro de rehacer, y funciona tanto si la base de datos está en las instalaciones como en la nube. El flujo consta de tres etapas:
- Instantánea inicial: En la primera conexión, el conector captura una instantánea consistente de las tablas que especifique, lo que proporciona a su flujo de eventos una línea base completa del estado actual.
- Captura continua de cambios: Después de la instantánea, lee los registros de rehacer archivados de Oracle a través de LogMiner. Cada cambio a nivel de fila en una tabla monitoreada se convierte en un evento de cambio estructurado, con valores antes y después y un indicador de operación (c para crear, u para actualizar, d para eliminar).
- Enrutamiento en tiempo real en Fabric: Una vez que los cambios llegan al flujo de eventos, se procesan y se enrutan a los destinos posteriores dentro de Fabric, sin necesidad de una infraestructura de transmisión independiente.
Es compatible con Oracle Database 12c (12.1) y versiones posteriores, incluidas 19c, 21c y Oracle Autonomous Database.
Dónde esto marca la diferencia
La misma funcionalidad se manifiesta de forma distinta en cada sector, pero el patrón siempre es el mismo. Se produce un cambio en Oracle y, en cuestión de segundos, se genera una mejora en otros procesos.
- Detección de fraude y anomalías en servicios financieros: Cada transacción se registra en los libros contables de Oracle. El procesamiento en tiempo real de estos cambios permite evaluar patrones sospechosos, como una rápida sucesión de transferencias o un aumento repentino en la velocidad de una cuenta, comparándolos con reglas predefinidas en el momento en que se registra cada fila, lo que puede marcar automáticamente la cuenta para su revisión. El tiempo que transcurre entre un evento y la acción de la persona se reduce de horas a segundos.
- Actualizaciones de suscripción y facturación en tiempo real para SaaS y medios: Las suscripciones, los cambios de plan y los eventos de pago se registran en tiempo real en un sistema de facturación de Oracle. Con CDC, una actualización se aplica a los derechos en el momento en que se confirma, un fallo en el pago activa un flujo de trabajo y una cancelación inicia de inmediato un proceso de recuperación de clientes. Un panel de control de ingresos y bajas en tiempo real se actualiza con cada cambio, para que los equipos vean la evolución de los planes al instante, en lugar de en un informe diario.
- Procesamiento de reclamaciones en tiempo real en el sector de seguros: Las reclamaciones se gestionan a través de los sistemas ERP a medida que se envían, revisan y liquidan. Con los eventos de cambio, una reclamación que pasa de "ENVIADA" a "APROBADA" puede activar el flujo de trabajo de pago y notificar al cliente, mientras que una reclamación marcada para revisión se puede enviar a un perito de inmediato. El estado anterior se conserva, lo que permite medir cuánto tiempo permanecen las reclamaciones en cada etapa e identificar cuellos de botella.
En cada caso, la arquitectura se mantiene limpia y predecible. El conector captura el estado inicial, transmite los cambios posteriores a Fabric y el destino final se mantiene actualizado continuamente, sin necesidad de pipelines ETL adicionales ni infraestructura CDC independiente. Los datos se transfieren en tiempo real desde una transacción de Oracle a los análisis, alertas y flujos de trabajo de Fabric.