Exemples StreamInsight

  • Article

 

Cette section est composée d'exemples des différents composants et étapes impliqués dans la création d'un programme StreamInsight. Chaque exemple est un programme StreamInsight complet qui combine des sources d'événement, des récepteurs d'événement et des requêtes pour implémenter un scénario de traitement des événements. L'API StreamInsight offre plusieurs interfaces prenant en charge différents niveaux de contrôle et de complexité pour la création et la maintenance d'applications qui traitent des événements. Les exemples contenus dans cette section illustrent l'utilisation de es interfaces avec des sources, des récepteurs et des requêtes simples.

Les exemples de cette section utilisent les espaces de noms suivants provenant des références d'assembly répertoriées.

Références d'assembly

  • System.Reactive.dll

  • System.Reactive.Providers.dll

  • System.ServiceModel.dll

  • Microsoft.ComplexEventProcessing.dll

  • Microsoft.ComplexEventProcessing.ManagementService.dll

  • Microsoft.ComplexEventProcessing.Observable.dll

Espaces de noms

  • 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;

Dans cette section

Le premier exemple de cette section permet de créer un serveur qui est utilisé par les autres exemples. Des sources, récepteurs et requêtes simples sont utilisées pour illustrer les interfaces. En suivant ces mêmes principes de base, des scénarios de traitement des événements complexes peuvent être créés.

Exemple StreamInsight : Serveur - Exposition d'un serveur incorporé
Cet exemple permet de créer un serveur StreamInsight incorporé et d'exposer un point de terminaison de façon à ce que les clients StreamInsight s'y connectent en tant que serveur distant.

Exemple StreamInsight : Client A - Utilisation d'un serveur distant
Cet exemple permet de se connecter au serveur de l'exemple précédent et d'utiliser les entités définies sur le serveur pour créer un processus de traitement des événements complexes.

Exemple StreamInsight : Client B - Création d'un objet
Cet exemple utilise le serveur distant du premier exemple, en créant un objet qui passe les données de deux sources à deux récepteurs.