De Semanas a Días: Ingeniería en Tiempo Real con Atome y RisingWave

Atome, una plataforma financiera líder en el sudeste asiático, necesitaba aprobar crédito y monitorizar pagos en tiempo real para mantener la agilidad de su negocio. Su anterior canal basado en Flink generaba cuellos de botella que ralentizaban la innovación y la capacidad de respuesta frente a fraudes emergentes. El desafío incluía ciclos de desarrollo lentos, dependencias complejas en bases de datos OLTP para búsquedas de características y fricción operativa al empaquetar y desplegar jobs, lo que retrasaba la implementación de nuevas reglas y la entrega de valor.

La solución llegó con RisingWave, una base de datos de streaming basada en SQL que permitió a Atome transformar su motor de riesgo. Al utilizar SQL estilo Postgres para expresar joins complejos, ventanas y agregaciones, el equipo eliminó la necesidad de operadores personalizados y conocimientos especializados, democratizando el desarrollo del pipeline. Las vistas materializadas en cascada mantuvieron los features y agregados siempre frescos, reduciendo drásticamente la presión sobre las bases de datos OLTP y mejorando la observabilidad y auditabilidad de los datos.

La implementación productiva ingiere datos desde MySQL CDC y Kafka y procesa todo con SQL: normalización, generación de features como velocity checks, joins entre streams y finalmente el volcado de resultados a tablas MySQL para que el motor de riesgo online los consuma. Gracias a este enfoque Atome logró pasar de procesos que tardaban semanas a entregas en cuestión de días, sin empaquetado de jobs ni operadores a medida, solo DDL y vistas materializadas.

Resultados clave obtenidos por Atome

Reducción drástica del tiempo de desarrollo El ciclo para añadir una nueva característica de streaming se redujo de semanas a aproximadamente 1 día. Alto rendimiento El sistema soporta una entrada de 10k filas/s y un sink de 2k filas/s. Baja latencia La latencia de extremo a extremo se mantiene consistentemente por debajo del segundo, sin observación de backpressure en picos de carga.

Impacto operativo y de negocio

Operativamente se logró reducir la carga en las bases de datos transaccionales, estabilizar latencias para aprobaciones en flujo y señalización de riesgo en tiempo real, y acelerar la gestión del cambio permitiendo al equipo de riesgo desplegar nuevas reglas y experimentos en 1 a 3 días. En términos de negocio se incrementó la confianza en las aprobaciones al disponer de más features en tiempo real, se controlaron costos al reducir la necesidad de grandes clusters OLTP y réplicas de emergencia, y se amplió el patrón de pipeline en tiempo real hacia casos de uso como CRM y personalización, acelerando el time to value en toda la organización.

Q2BSTUDIO y la ingeniería en tiempo real

En Q2BSTUDIO somos expertos en convertir retos como el de Atome en soluciones productivas. Como empresa de desarrollo de software y aplicaciones a medida ofrecemos servicios integrales que abarcan desde el diseño de arquitecturas de streaming hasta la implementación de pipelines en SQL, soluciones de software a medida y despliegues escalables en la nube. Nuestra experiencia incluye integración de servicios cloud aws y azure, implementaciones de inteligencia artificial y ia para empresas, y despliegues de agentes IA para automatizar decisiones en tiempo real.

Además, ofrecemos servicios de ciberseguridad y pentesting para proteger pipelines de datos sensibles, servicios de servicios inteligencia de negocio con Power BI para aprovechar los resultados en cuadros de mando y análisis avanzado, y consultoría para arquitecturas de alta disponibilidad y baja latencia. Si su organización necesita una solución personalizada para riesgo en tiempo real, detección de fraude, recomendaciones o CRM personalizado, podemos diseñar la arquitectura, desarrollar la aplicación a medida y poner en producción modelos de IA y pipelines robustos.

Casos de uso y cómo podemos ayudar

Implementamos pipelines que reducen latencia, aceleran la entrega de features y bajan costes operativos, integrando bases de datos, CDC, Kafka y motores de streaming SQL. También ofrecemos servicios para modernizar plataformas legacy, migrar cargas a la nube y desplegar soluciones de inteligencia de negocio con Inteligencia artificial y Power BI que permiten tomar decisiones más informadas.

Si su objetivo es pasar de semanas a días en la entrega de capacidades en tiempo real, Q2BSTUDIO combina experiencia en aplicaciones a medida, inteligencia artificial, ciberseguridad, servicios cloud aws y azure, agentes IA y power bi para diseñar e implementar soluciones efectivas que escalen con su negocio.