StreamInsight-Beispiele

  • Artikel

 

Dieser Abschnitt umfasst Beispiele für die verschiedenen Komponenten und Schritte, die zum Erstellen eines StreamInsight-Programms erforderlich sind. Jedes Beispiel stellt ein vollständiges StreamInsight-Programm dar, in dem Ereignisquellen, Ereignissenken und Abfragen kombiniert werden, um ein Ereignisverarbeitungsszenario zu implementieren. Die StreamInsight-API bietet eine Vielzahl von Schnittstellen, um verschiedene Steuerungs- und Komplexitätsgrade beim Erstellen und Warten von Ereignisverarbeitungsanwendungen zu unterstützen. Die Beispiele in diesem Abschnitt veranschaulichen die Verwendung dieser Schnittstellen mit einfachen Quellen, Senken und Abfragen.

Für die in diesem Abschnitt enthaltenen Beispiele werden die folgenden Namespaces aus den aufgelisteten Assemblyverweisen verwendet.

Assemblyverweise

  • System.Reactive.dll

  • System.Reactive.Providers.dll

  • System.ServiceModel.dll

  • Microsoft.ComplexEventProcessing.dll

  • Microsoft.ComplexEventProcessing.ManagementService.dll

  • Microsoft.ComplexEventProcessing.Observable.dll

Namespaces

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

In diesem Abschnitt

Im ersten Beispiel dieses Abschnitts wird ein Server erstellt, der in den anderen Beispielen verwendet wird. Die Schnittstellen werden mithilfe einfacher Quellen, Senken und Abfragen veranschaulicht. Anhand dieser Grundprinzipien lassen sich äußerst komplexe Ereignisverarbeitungsszenarien entwickeln.

StreamInsight-Beispiel: Server - Verfügbarmachen eines eingebetteten Servers
In diesem Beispiel wird ein eingebetteter StreamInsight-Server erstellt und anschließend ein Endpunkt verfügbar gemacht, damit StreamInsight-Clients als Remoteserver damit verbunden werden können.

StreamInsight-Beispiel: Client A - Verwenden eines Remoteservers
In diesem Beispiel wird eine Verbindung mit dem Server aus dem vorherigen Beispiel hergestellt. Anschließend werden im Server definierte Entitäten verwendet, um einen CEP-Prozess zu erstellen.

StreamInsight-Beispiel: Client B - Erstellen eines Subjekts
In diesem Beispiel wird unter Verwendung des Remoteservers aus dem ersten Beispiel ein Subjekt erstellt, das Daten von zwei Quellen an zwei Senken übergibt.