WSO2

¿Qué es WSO2 Complex Event Processor?

18th noviembre 2019

La digitalización ha llevado a que las organizaciones empresariales realicen una enorme cantidad de transacciones diarias de información y datos. Esta entrada, gestión y salida de datos constante forma parte de una actividad en un flujo permanente, un flujo al que las empresas responden monitorizando los datos en tiempo real. Aquellas que responden de manera más rápida y eficiente a esta necesidad logran una mayor ventaja comercial sobre sus competidoras.

Es aquí donde WSO2 Complex Event Processor (CEP), una herramienta ágil, fácil de usar y de código abierto, puede aportar un valor añadido significativo. Este servidor de procesamiento de datos reconoce aquellas acciones vinculadas a ellos que son más relevantes dentro de toda una nube de datos, es capaz de medir su impacto y actúa sobre ellos en tiempo real. Ese procesamiento de datos complejos consiste en escucharlos y detectar patrones en tiempo real, con un mínimo o ningún almacenamiento.

¿Qué es capaz de hacer Complex Event Processor?

WSO2 Complex Event Processor está construido para ser extremadamente eficiente con WSO2 Siddhi y masivamente escalable usando Apache Storm. WSO2 CEP se basa en la reconocida plataforma WSO2 Carbon, que a su vez tiene sus fundamentos en el marco OSGi y permite una mejor modularidad para la arquitectura orientada a servicios (SOA). El marco de trabajo WSO2 Carbon contiene muchas características mejoradas y componentes opcionales para personalizar el comportamiento del servidor a través de un aprovisionamiento sencillo y rápido. El CEP puede integrarse perfectamente con el servidor de análisis de datos WSO2, añadiendo soporte para la grabación y postprocesamiento de eventos con Map-Reduce vía Apache Spark, y WSO2 Machine Learner para el análisis predictivo.

 

Soluciones de Complex Event Processor 

WSO2 Complex Event Processor contribuye a la detección de nuevos datos en tiempo real, a su identificación y a la notificación de alertas, de manera combinada con herramientas de visualización enriquecidas para ayudar a configurar cuadros de mando de supervisión sencillos y eficientes.

WSO2 CEP emplea un event processing de streaming de alto rendimiento, que es el resultado de una extensa investigación por parte de la compañía WSO2. Gracias a su arquitectura, optimizaciones de memoria y nuevos enfoques para almacenar datos de eventos, WSO2 CEP es una de las soluciones de código abierto más rápidas disponibles en la actualidad, capaz de encontrar patrones de eventos en milisegundos en tiempo real. En el corazón de esta herramienta se encuentra Siddhi. Configurado utilizando un lenguaje rico, compacto y fácil de aprender, WSO2 CEP es especialmente adecuado para consultas complejas que implican plazos específicos de tiempo, así como para la detección de patrones y secuencias.

Las consultas CEP pueden modificarse de forma dinámica en tiempo de ejecución mediante modelos. El núcleo del motor de streaming es de baja latencia, de tamaño extremadamente pequeño y puede desplegarse para el análisis de bordes, es decir, para la ejecución de flujos de procesamiento de eventos en un dispositivo o una pasarela de IOT. Esto, junto con su capacidad para manejar volúmenes extremadamente grandes de flujos de eventos, hace que el WSO2 CEP sea particularmente adecuado para manejar escenarios de Internet Of Things (IoT).

WSO2 CEP puede desplegarse en modo autónomo o distribuido. En modo distribuido, aprovecha la arquitectura Apache Storm para conseguir una escalabilidad casi lineal. Las soluciones preconstruidas, como la detección de fraudes, aprovechan el rendimiento del WSO2 CEP y proporcionan implementaciones específicas para cada dominio en la parte superior del motor principal.

 

Características de WSO2 CEP

 WSO2 Complex Event Processor presenta una serie de características que lo convierten en único para el procesamiento de datos en el acto y su análisis en tiempo real, como el manejo de cantidades masivas de datos transmitidos (100.000 datos por segundo o más) gracias a su motor de baja latencia. Cuenta con un lenguaje de configuración y de consulta rico y compacto, similar al SQL, que cubre la configuración de flujos de procesamiento de eventos más compleja. Además, soporta el filtrado de flujos de datos por condiciones, así como la transformación de flujos de datos.

WSO2 CEP permite una elevada escalabilidad y tiene una alta disponibilidad; soporta la implementación independiente tolerante a los errores, con o sin persistencia de flujos de datos, así como la implementación distribuida sobre la arquitectura Apache Storm. Incluye operadores de streaming específicos para impulsar la ejecución paralela en Apache Storm y contribuye a la integración completa e integral de datos, como demuestra que éstos se puedan recibir y enviar en formato XML, JSON, texto o mapa. Por otra parte, soporta receptores y editores de estándares, incluyendo HTTP(s), JMS, archivos o SOAP, REST o Email, Apache Thrift o Web sockets, y aprovecha el soporte para transportes amigables con la IoT como MQTT o Apache Kafka.

En cuanto a la gestión operativa, esta herramienta presenta una notable capacidad para recopilar datos estadísticos en varios puntos del flujo de procesamiento de eventos y para visualizarlos en cuadros de mando integrados o a través de JMX. Tiene, también, elevada capacidad para solucionar problemas en los sistemas de producción, así como posibilidad de instrumentar, monitorizar y visualizar métricas operativas.