Dominar Kafka Streams y ksqlDB

Capítulo 11. Procesamiento de flujos intermedio y avanzado con ksqlDB

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

En el último capítulo, aprendimos a realizar tareas básicas de preprocesamiento y transformación de datos utilizando ksqlDB. Las sentencias SQL que analizamos eran sin estado, y nos permitieron filtrar datos, aplanar estructuras complejas o anidadas, utilizar la proyección para remodelar datos, y mucho más. En este capítulo, profundizaremos en nuestro conocimiento de ksqlDB analizando algunos casos de uso de enriquecimiento y agregación de datos. La mayoría de las sentencias que discutiremos son de estado (por ejemplo, implican múltiples registros, lo que es necesario con uniones y agregaciones) y basadas en el tiempo (por ejemplo, operaciones en ventanas), lo que las hace más complejas bajo el capó, pero también más potentes.

Algunos de los temas que trataremos en este capítulo son:

• Utilizar uniones para combinar y enriquecer datos

• Realizar agregaciones

• Ejecutar consultas pull (es decir, búsquedas puntuales) contra vistas materializadas utilizando la CLI

• Trabajar con las funciones ksqlDB integradas en (funcionesscalar, aggregate, y table)

• Crear funciones definidas por el usuario utilizando Java

Utilizaremos el tutorial de monitorización de cambios de Netflix de del capítulo anterior para introducir muchos de estos conceptos (consulta "Tutorial: Monitorización de cambios en Netflix" ...