StreamInsight 範例

 

本節包含數個範例，示範與建立 StreamInsight 程式有關的各種元件和步驟。 每個範例是完整的 StreamInsight 程式，結合了事件來源、事件接收和查詢，以便實作事件處理案例。 StreamInsight API 會提供各種介面來支援建立及維護事件處理應用程式的各種控制和複雜性等級。 本節提供的範例示範這些介面搭配簡單來源、接收和查詢的使用方式。

本節的範例使用所列出之組件參考的下列命名空間。

組件參考

• System.Reactive.dll

• System.Reactive.Providers.dll

• System.ServiceModel.dll

• Microsoft.ComplexEventProcessing.dll

• Microsoft.ComplexEventProcessing.ManagementService.dll

• Microsoft.ComplexEventProcessing.Observable.dll

命名空間

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

本節內容

本節的第一個範例建立供其他範例使用的伺服器。 為示範介面，使用了簡單來源、接收和查詢。 依照這些相同的基本原則，可建立非常複雜的事件處理案例。

StreamInsight 範例：伺服器 - 公開內嵌伺服器
這個範例建立內嵌 StreamInsight 伺服器，然後公開端點，讓 StreamInsight 用戶端可以將它當做遠端伺服器進行連接。

StreamInsight 範例：用戶端 A - 使用遠端伺服器
這個範例連接到上一個範例中的伺服器，然後使用定義於伺服器上的實體以建立 CEP 處理序。

StreamInsight 範例：用戶端 B - 建立主旨
這個範例使用第一個範例中的遠端伺服器，並建立主旨，從兩個來源傳遞資料至兩個接收。