Ejemplos de StreamInsight

  • Artículo

 

Esta sección contiene ejemplos de diversos componentes y pasos implicados en la creación de un programa de StreamInsight. Cada ejemplo es un programa completo de StreamInsight que combina orígenes de eventos, receptores de eventos y consultas para implementar un escenario de procesamiento de eventos. LA API de StreamInsight ofrece diferentes interfaces para admitir diversos niveles de control y complejidad en la creación y el mantenimiento de aplicaciones de procesamiento de eventos. El ejemplo que se proporciona en esta sección muestra el uso de estas interfaces con consultas, orígenes y receptores sencillos.

En los ejemplos de esta sección se usan los siguientes espacios de nombres de las referencias a ensamblado enumeradas.

Referencias a ensamblado

  • System.Reactive.dll

  • System.Reactive.Providers.dll

  • System.ServiceModel.dll

  • Microsoft.ComplexEventProcessing.dll

  • Microsoft.ComplexEventProcessing.ManagementService.dll

  • Microsoft.ComplexEventProcessing.Observable.dll

Espacios de nombres

  • using System.Reactive;

  • using System.Reactive.Linq;

  • using System.Reactive.Subjects;

  • using System.ServiceModel;

  • using Microsoft.ComplexEventProcessing;

  • using Microsoft.ComplexEventProcessing.Linq;

  • using Microsoft.ComplexEventProcessing.ManagementService;

En esta sección

En el primer ejemplo de esta sección se crea un servidor que se utiliza en otros ejemplos. Para mostrar las interfaces se utilizan consultas, orígenes y receptores sencillos. Siguiendo estos mismos principios básicos, se pueden crear escenarios de procesamiento de eventos muy complejos.

Ejemplo de StreamInsight: servidor, exponer un servidor insertado
En este ejemplo se crea un servidor StreamInsight incrustado y, a continuación, se expone un extremo para que los clientes de StreamInsight puedan conectarse a él como un servidor remoto.

Ejemplo de StreamInsight: cliente A, usar un servidor remoto
Este ejemplo se conecta al servidor del ejemplo anterior y utiliza las entidades definidas en el servidor para crear un proceso CEP.

Ejemplo de StreamInsight: cliente B, crear un sujeto
En este ejemplo se utiliza el servidor remoto del primer ejemplo, creando un asunto que pasa datos de dos orígenes a dos receptores.