Manejo de flujos de eventos

Event Stream Processing (ESP ) es un  conjunto de tecnologías diseñadas para construir sistemas de información de procesamiento de eventos. La tecnología ESP incluye visualización de eventos, almacenamiento de eventos, middleware controlado por eventos y lenguajes de programación de procesamiento de eventos. La tarea principal de ESP es procesar flujos de eventos (datos) para encontrar patrones significativos en ellos, utilizando métodos como la búsqueda de relaciones entre eventos, correlación de eventos, jerarquías de eventos y otros aspectos como causalidad, análisis de compuestos. eventos y series de tiempo.

La tecnología ESP se utiliza en varias aplicaciones, como la detección temprana de fraude en la industria de servicios financieros; para el análisis operativo de las actividades en los pisos de negociación de la bolsa; para evaluar el desempeño de equipos basados ​​en información heterogénea proveniente de sensores y sensores, por ejemplo, en la industria del petróleo y el gas; en telecomunicaciones para análisis operativo de churn de clientes y campañas de marketing, etc.

Ejemplos

Como ilustración, los siguientes fragmentos de código demuestran la detección de patrones dentro de un flujo de eventos. El primer ejemplo es el procesamiento de un flujo de eventos mediante una consulta SQL continua (una consulta que procesa continuamente los datos entrantes en función de las marcas de tiempo). En este fragmento de código, la operación JOIN conecta dos flujos de datos, uno contiene pedidos de acciones (Órdenes), el otro contiene los resultados de transacciones de valores (Operaciones). El resultado de la consulta es un flujo de pedidos que coinciden con transacciones que ocurrieron dentro de 1 segundo después de que se realizó el pedido. El flujo de salida se ordena por las marcas de tiempo de la tabla Pedidos.