Usar LINQ de StreamInsight

  • Artículo

 

Una vez entregados los datos en el servidor de StreamInsight, se pueden realizar cálculos con ellos de forma continua. Dicho de otro modo, cuando se insertan eventos en el servidor, las consultas permanentes los procesan y emiten los eventos de salida procesados. Las consultas permanentes se escriben en el marco del lenguaje LINQ. LINQ es un mecanismo para expresar consultas declarativas sobre conjuntos de datos que se integra totalmente en un lenguaje de host como C#. En la versión actual, StreamInsight solo admite C# como lenguaje de host. Este marco se ha adaptado para la plataforma StreamInsight, lo que ha dado como resultado una estrecha integración del servidor de StreamInsight con C#. En los temas de esta sección se muestran varias operaciones de cálculo con eventos admitidos por esta plataforma y, además, se muestra cómo se especifican estas operaciones con consultas LINQ de StreamInsight.

Nota


En la versión 2.0 de StreamInsight y en versiones anteriores, los flujos temporales se implementaban mediante la interfaz CepStream<>. Si bien se sigue admitiendo la interfaz CepStream<>, en la versión 2.1 y posteriores los flujos temporales se implementan mediante la interfaz IQStreamable<> y se pueden procesar mediante LINQ de StreamInsight. La sintaxis de las consultas temporales compuestas sobre IQStreamable<> es coherente con la sintaxis del proveedor de LINQ basado en CepStream<> existente; sin embargo, se han realizado algunos cambios para aprovechar las nuevas capacidades que ofrece la interfaz IQStreamable<>. En esta sección se identifican las diferencias existentes entre las interfaces IQStreamable<> y CepStream<>.

Para obtener instrucciones detalladas sobre cómo se escriben consultas LINQ en StreamInsight, vea la guía de un autoestopista para consultas en StreamInsight.

En esta sección

Proyección
Filtrar
Combinaciones
Uniones
Agrupar y aplicar
Modificaciones de marca de tiempo
Funciones definidas por el usuario (StreamInsight)
Operadores de flujo definidos por el usuario
Utilizar ventanas de eventos
Ventanas de recuento
Ventanas de salto
Ventanas de instantánea
Agregaciones
TopK
Agregados y operadores definidos por el usuario

Vea también

Conceptos de servidor de StreamInsight
Language Integrated Query