Novedades (StreamInsight)

Artículo
07/28/2011

Microsoft StreamInsight incluye nuevas características y mejoras que aumentan la eficacia y la productividad de los desarrolladores y administradores del procesamiento de eventos complejos.

Para obtener información acerca de los problemas conocidos, vea Notas de la versión (StreamInsight). Para obtener información acerca de la compatibilidad con versiones anteriores, vea Compatibilidad con versiones anteriores (StreamInsight).

Características nuevas de StreamInsight 1.2 (junio de 2011)

Nuevas características de resistencia

StreamInsight 1.2 presenta compatibilidad para la resistencia integrada ante errores del sistema para el procesamiento de flujos de datos. Esta compatibilidad solo está disponible en la edición Premium de StreamInsight. Para obtener más información acerca de las ediciones, vea Elegir una edición de StreamInsight.

Estas nuevas características de resistencia permiten ejecutar aplicaciones esenciales con un tiempo operativo mínimo, con transparencia en errores del sistema, en la plataforma de Windows que elija a un costo total de propiedad líder del sector. Para obtener más información, vea los siguientes temas.

Las nuevas características de resistencia también incluyen nuevos estados de consulta:

Inicializando. Este estado normalmente se produce después de uno de los siguientes eventos:
- La consulta se detuvo y el usuario ha llamado a su método Start.
- Se estaba ejecutando una consulta resistente y el servidor se está recuperando del error. Para cambiar el estado de la consulta, el usuario debe llamar a su método Start.
Comprobando punto. La consulta se está ejecutando y hay un punto de comprobación en curso.

Nuevas características para desarrolladores de software

Entre las mejoras de la API de StreamInsight se incluyen las siguientes características:

Operadores de flujo definidos por el usuario

Ahora puede proporcionar procesamiento personalizado de los flujos de entrada con operadores de flujo definidos por el usuario. A diferencia de los operadores y los agregados definidos por el usuario, que permiten interactuar con ventanas, los operadores de flujo definidos por el usuario permiten interactuar directamente con el contenido de un flujo, calcular y generar resultados incrementalmente, y administrar el estado. Para obtener más información, vea Operadores de flujo definidos por el usuario.

Mejoras en LINQ

Puede usar tipos anidados en cargas de evento, en adaptadores y en consultas LINQ. Para obtener más información sobre las cargas de eventos, vea Crear tipos de evento.
Se puede usar la cláusula "let" de LINQ. Para obtener más información, vea Cláusula let (referencia de C#).
Se pueden combinar múltiples flujos en una sola consulta. Ya no hay límite para combinar solo dos flujos. Para obtener más información acerca de las combinaciones, vea Combinaciones.
Se pueden realizar llamadas insertadas a métodos de extensión en la cláusula "from" aparte de la primera cláusula "from" y en combinaciones.
Se pueden combinar flujos en claves de combinación compuestas. Por ejemplo: where {x.a, x.b} equals {y.a, y.b}. Para obtener más información acerca de las combinaciones, vea Combinaciones.
Se puede combinar un campo individual sin crear un nuevo tipo anónimo. Por ejemplo: from x in xs select x.A en vez de from x in xs select new { x.A }. Para obtener más información acerca de la proyección, vea Proyección.
Se pueden usar varios agregados en una expresión. Por ejemplo, select new {ratio = (double)win.Sum(e => e.good) / (double)win.Count()}.
Se puede agrupar un nuevo tipo anónimo en una cláusula "group by". Por ejemplo: from x in xs group new { x.A, x.B } by new { x.C, x.D } into g, donde group new { x.A, x.B } demuestra la nueva capacidad. Anteriormente, el selector de una cláusula "group by" era el tipo entrante; por ejemplo, from e in input group e by ….
Ahora se pueden incluir proyecciones en una cláusula Take. Por ejemplo, … select new { myAvg = r.Value / 10, r.SourceId }).Take(2, …). Anteriormente, el selector de una cláusula Take era el tipo entrante; por ejemplo, from win in input.window(…) from e in … select e).Take(…).

Mejoras en API

Hay una nueva sobrecarga para el método ShiftEventTime que se comporta como el nombre del método en inglés implica. Es decir, la nueva sobrecarga desplaza la hora del evento el intervalo de tiempo proporcionado. La versión original de este método requiere que se especifiquen tanto la hora de evento actual como el intervalo de tiempo que se va a desplazar la hora del evento. En vez de escribir ShiftEventTime(e => e.StartTime + TimeSpan.FromMinutes(15)), ahora se puede escribir ShiftEventTime(e => TimeSpan.FromMinutes(15)). No obstante, se puede seguir usando la versión original del método para establecer la hora del evento a una hora específica si se proporciona un valor datetime. La versión original se ha conservado por motivos de compatibilidad. Para obtener más información, vea Modificaciones de marca de tiempo.
Hay una nueva directiva de salida, PointAlignToWindowEnd, disponible para las ventanas de salto. La directiva existente, ClipToWindowEnd, produce un tamaño de ventana que se corresponde con la duración de la operación basada en conjuntos. La directiva produce un evento de punto donde la hora de inicio es la hora de finalización de la ventana. Esta nueva directiva de salida resulta útil cuando se combina el resultado con otro flujo, ya que solo hay un único resultado válido en cada momento, lo que expresa el resultado de agregación más reciente en ese punto.
Todas las ventanas ahora tienen directivas de salida predeterminadas, que son ClipToWindowEnd para las ventanas de instantánea y PointAlignToWindowEnd para las ventanas de saltos o de saltos de de tamaño constante y para las ventanas de recuento.

Nuevas características de capacidad de administración y herramientas

Ahora puede usar su infraestructura de diagnóstico existente para supervisar los procesos y consultas de StreamInsight, así como solucionar problemas, con el Monitor de rendimiento y el Visor de eventos. También puede obtener acceso a una lista expandida de propiedades de diagnóstico.

Contadores de rendimiento

Ahora se puede usar el Monitor de rendimiento para ver los contadores de los procesos de servidor, consultas y flujos de entrada de StreamInsight. Para obtener más información, vea Supervisar contadores de rendimiento y eventos de StreamInsight.

Registro administrativo para el registro de eventos de Windows

Ahora se puede usar el Visor de eventos de Windows para ver los eventos administrativos relacionados con los procesos de servidor de StreamInsight, adaptadores, consultas y el proceso volcado en el registro de eventos de aplicación. Para obtener más información, vea Supervisar contadores de rendimiento y eventos de StreamInsight.

Propiedades de diagnóstico adicionales

Hay disponibles nuevas propiedades de diagnóstico como ayuda para la supervisión y la solución de problemas. Entre las nuevas propiedades se incluyen las siguientes:

AdapterNumberOfRunningWorkers, AdapterNumberOfRunningWorkers y AdapterNumberOfSuspendedWorkers
AdapterFirstCtiTimestamp
OperatorNumberOfWorkers
OperatorGroupIdField
QueryInstanceGroupId
StreamNumberOfWorkers
StreamMinInputEventCountAcrossWorkers y StreamMaxInputEventCountAcrossWorkers
StreamMinMemoryIncludingEventsAcrossWorkers y StreamMaxMemoryIncludingEventsAcrossWorkers

Asimismo, se han quitado algunas de las vistas disponibles anteriormente. Se incluyen todas las vistas relacionadas con el programador.

Para obtener más información, vea Supervisar el servidor y las consultas de StreamInsight.

Características nuevas de StreamInsight 1.1 (octubre de 2010)

Se implementaron los siguientes cambios e incorporaciones desde StreamInsight 1.0 Refresh 1. Se publicaron en StreamInsight 1.1 en octubre de 2010.

Compatibilidad con orígenes y receptores de eventos que implementan las interfaces IEnumerable o IObservable. Se han agregado clases y miembros nuevos a la API de StreamInsight para admitir este nuevo modelo de programación en la entrada y salida, como una alternativa a los adaptadores de entrada y salida habituales. Estas características se describen en los temas siguientes:
Un método Stop en la clase Adapter. Este método notifica a un adaptador que se detenga como consecuencia de la detención o la anulación de una consulta.
Las nuevas versiones de StreamInsight se instalan en paralelo con las versiones anteriores. Para obtener más información acerca de la instalación de las versiones de StreamInsight, vea:
- "Instalar una nueva versión de StreamInsight" en Instalación (StreamInsight).
- "Versiones de StreamInsight" en Consideraciones de programación.

Características nuevas de StreamInsight 1.0 Refresh 1 (junio de 2010)

Se implementaron los siguientes cambios e incorporaciones desde StreamInsight 1.0 RTM. Se lanzaron en StreamInsight 1.0 Refresh 1 en junio de 2010 a la vez que la Actualización acumulada 2 de SQL Server 2008 R2.

La API ClipEventDuration. Este nuevo método de la clase CepStream permite usar un flujo secundario para determinar dónde recortar la duración de los eventos en el flujo primario. Para obtener más información, vea:
- "Ajustar la duración de un evento" en Modificaciones de marca de tiempo.
- ClipEventDuration<(Of <<'(TSource, TClip>)>>)
Compatibilidad con el desarrollo de aplicaciones StreamInsight en Microsoft .NET Framework 4

Para obtener más información sobre estos cambios o descargar StreamInsight 1.0 Refresh 1, vea el artículo de Knowledge Base sobre las Actualizaciones de StreamInsight 1.0 que se publican junto con la actualización acumulativa 2 para SQL Server 2008 R2.

Características nuevas de StreamInsight 1.0 RTM (abril de 2010)

Desde el Community Technology Preview (CTP) de noviembre de 2009 de StreamInsight 1.0, se han implementado los siguientes cambios y novedades. Se lanzaron a la vez en StreamInsight 1.0 con SQL Server 2008 R2 en abril de 2010.

Diseño y desarrollo

Ahora puede usar las consultas de StreamInsight como bloques de creación para las aplicaciones. Las consultas se pueden crear en consultas existentes y actualmente en ejecución. Para obtener más información, vea Crear consultas en tiempo de ejecución.

Se ha agregado compatibilidad para los flujos de entrada sincronizados. Para obtener más información, vea Adelantar tiempo de aplicación.

El tamaño máximo de un evento único en StreamInsight se ha aumentado a 16 K. En lo que respecta a los campos de sistema y los metadatos de evento, un límite más seguro y práctico es 14 K.

Operadores

Se ha agregado compatibilidad para las ventanas de recuento. Para obtener más información, vea Ventanas de recuento.

Se ha agregado compatibilidad para las operaciones left anti semi join. Para obtener más información, vea Combinaciones.

API

La clase AdapterFactory tiene una nueva definición de interfaz, IDeclareAdvanceTimePolicy, que devuelve una instancia de AdvanceTimeSettings. Este es el mecanismo por el que puede especificar valores de adelanto de tiempo en el generador de adaptadores.

Administración

Vistas de diagnóstico

Existen nuevas vistas de diagnóstico disponibles para supervisar el sistema en los siguientes niveles de especificidad: servidor, operador, programador y adaptador. Para obtener más información, vea Supervisar el servidor y las consultas de StreamInsight.