Información general (StreamInsight)
Microsoft StreamInsight proporciona una sólida plataforma para la programación e implementación de aplicaciones de procesamiento de eventos complejos (CEP). CEP es una tecnología para procesar secuencias de eventos con rendimiento alto y latencia baja. Generalmente, los orígenes de secuencias de eventos incluyen datos de aplicaciones para la fabricación, aplicaciones de comercio financiero, análisis web o análisis operacional. La arquitectura de procesamiento de secuencias de StreamInsight y la conocida plataforma de desarrollo basada en .NET permiten implementar aplicaciones de procesamiento de eventos realmente eficaces.
StreamInsight ofrece las siguientes ventajas principales:
Rendimiento y generación de datos muy optimizados
StreamInsight implementa una arquitectura de secuencias ligera que admite la ejecución paralela de consultas continuas en datos de gran velocidad. El uso de memorias caché y el cálculo de resultados incremental proporciona un rendimiento excelente con gran volumen de datos y baja latencia. La baja latencia se logra porque los eventos se procesan sin grandes cargas de datos ni operaciones de almacenamiento en la ruta de acceso del procesamiento crítica. Los eventos de entrada desencadenan automáticamente todo el procesamiento con StreamInsight. Concretamente, las aplicaciones no experimentan sobrecarga alguna para realizar el sondeo de eventos. La plataforma proporciona funcionalidad para administrar los eventos desordenados. Además, se puede tener acceso a referencias estáticas o datos históricos para incluirlos en el análisis de latencia baja.
Entorno de desarrollo .NET
Los desarrolladores de software pueden escribir las aplicaciones CEP mediante el lenguaje .NET de Microsoft, por ejemplo Visual C#, utilizando la plataforma de lenguaje avanzado LINQ (Language Integrated Query) como un lenguaje de consultas incrustado. La comunidad de desarrolladores de software que ya conocen estas tecnologías es muy numerosa, de forma que esta capacidad reduce costes de programación y el tiempo desde la programación de aplicaciones a la producción. En la versión actual, StreamInsight solo admite C# como lenguaje de host.
Utilizando LINQ, los desarrolladores de software que conocen SQL podrán escribir rápidamente consultas de forma declarativa que procesan y ponen en correlación datos de varios flujos en resultados significativos. El optimizador y el programador del servidor de StreamInsight garantizan el rendimiento óptimo de las consultas.
Capacidad de implementación flexible
StreamInsight admite tres escenarios de implementación:
Integración completa en la aplicación como DLL hospedada (incrustada).
Como servidor independiente con varias aplicaciones y usuarios que comparten el servidor. En su configuración independiente, el servidor de StreamInsight se ejecuta en un contenedor como una aplicación ejecutable o bien se puede empaquetar como un servicio de Windows.
El servidor de StreamInsight hospedado o independiente podría formar parte de una granja de servidores.
Facilidad de uso
Las características de supervisión y facilidad de uso integradas en el servidor de StreamInsight reducen el coste total de la propiedad (TCO) de las aplicaciones CEP. La interfaz de administración y las vistas de diagnóstico que se proporcionan en el servidor de StreamInsight permiten al administrador supervisar y administrar la aplicación CEP. El marco de facilidad de uso permite también que los ISV y los integradores de sistemas supervisen y den soporte técnico remotamente a los sistemas implementados de StreamInsight en centros de fabricación y otras instalaciones externas.
StreamInsight facilita un depurador de flujo de eventos independiente que se puede utilizar para analizar las consultas que se usan en aplicaciones StreamInsight, y diagnosticar y solucionar sus problemas.
Escenarios CEP
La necesidad de procesamiento de flujos de eventos con alto rendimiento y latencia baja, es común a los siguientes escenarios empresariales:
Supervisión y control de procesos de fabricación
Análisis clickstream
Servicios financieros
Empresas de energía
Servicios de salud
Supervisión de TI
Logística
Telecomunicaciones
En las siguientes secciones se describen algunos de estos escenarios y se analizan sus requisitos para el procesamiento de eventos.
Supervisión y control de procesos de fabricación
Para garantizar que los productos y procesos se están ejecutando óptimamente y con la menor cantidad de tiempo de inactividad, las empresas de fabricación necesitan recopilar datos con latencia baja y analizar los dispositivos y sensores de la fábrica. El escenario industrial típico tiene los siguientes requisitos:
Supervisión basada en activos y agregación de datos procedentes de máquinas.
Observación basada en sensores de las actividades y la producción de la fábrica.
Observación y reacción a través de los controladores de dispositivo.
Capacidad para manejar hasta 10.000 eventos de datos por segundo.
Generación de eventos y alertas en el momento que algo sale mal.
Mantenimiento proactivo y basado en condiciones de los equipos clave.
Análisis de latencia baja de datos agregados (en ventanas y escalas de registro).
Análisis clickstream
Una experiencia de cliente óptima de un sitio web comercial exige el procesamiento de latencia baja del comportamiento del usuario y las interacciones en el sitio. La aplicación de análisis de secuencias de clics típica tiene los siguientes requisitos:
Capacidad de controlar el diseño de página, la navegación y la presentación en función de análisis de secuencias de clics de latencia baja.
Capacidad para manejar hasta 100.000 eventos de datos por segundo en momentos de máximo tráfico.
Detección inmediata del modelo de secuencias de clics y respuesta con publicidad concreta.
Comercio con algoritmos en un entorno de servicios financieros.
El comercio con algoritmos, que tiene necesidades de procesamiento de datos de gran volumen, tiene normalmente los siguientes requisitos:
Capacidad para manejar hasta 100.000 eventos de datos por segundo.
El tiempo de procesamiento de consultas es crítico.
Supervisión y aprovechamiento de las condiciones del mercado actuales, con ventanas muy cortas de oportunidad.
Filtrado inteligente de datos de entrada.
Capacidad de definir modelos sobre varios orígenes de datos y en el tiempo, para desencadenar automáticamente decisiones de compra, venta y espera en los activos de una cartera.
Empresas de energía
El sector de servicios públicos exige una infraestructura eficaz para administrar redes eléctricas y otras instalaciones. Estos sistemas tienen normalmente los siguientes requisitos.
Respuesta inmediata a las variaciones de consumo de energía o agua, para minimizar o evitar interrupciones del servicio.
Obtención de mejoras operativas y medioambientales avanzando hacia redes inteligentes.
Varios niveles de agregación a lo largo de la red.
Capacidad de manejar hasta 100.000 eventos por segundo de millones de orígenes de datos.