【CEP】復瑣事件處理簡介和StreamInsight初步使用

一、復瑣事件處理

* 事件處理的發展主要分爲三個階段：數據庫處理、數據流處理和復瑣事件處理。

* 人們面對的數據是多種多樣的，處理需求也各不相同。好比製造物聯網領域中，數據處理面對着如下困難：海量動態數據難以及時處理，多樣性業務數據難以智能區分、數據關聯性難以準確描述。

咱們能夠認爲：複雜數據處理（complex event processing）是數據流的響應模型。

CEP引擎爲一系列不相關的事件尋找匹配的模式和事件間的關係，經過對事件進行分析，找出威脅、機遇，並將這些響應給檢測模版。

｛！好比你的皮膚感受到溫度降低，鼻子感受到溼氣很重，眼睛看到遠方烏雲。由這些基礎事件能夠獲得復瑣事件：即將下雨。

｝

* 概念介紹

五星：

StreamInsight概念

（http://msdn.microsoft.com/zh-cn/library/jj136801(v=sql.111).aspx）；

事件結構

（http://msdn.microsoft.com/zh-cn/library/ee378905(v=sql.111).aspx）；

深刻淺出系列

（【原】StreamInsight 淺入淺出（二）—— 流與事件）；

四星：

CEP系列（http://www.cnblogs.com/shanyou/category/262009.html），

華爲CEP概念彙總帖子（http://www.huawei.com/ecommunity/bbs/10166475.htm）；

其連載8中提到：

目前知名的CEP產品來自Tibco、IBM、Oracle、StreamBase、Sybase等。微軟也即將推出名爲StreamInsight的CEP產品。

頗有意思的是StreamBase與StreamInsight這兩個CEP產品名稱，恰好是CEP的三個關鍵字：Stream、Base、Insight。同時具有這三點才能算是CEP。

在各類CEP工具中，本文使用Microsoft的streaminsight工具。

二、StreamInsight初步使用

傳統數據庫的基本單位是數據行，而在 StreamInsight 或者說 CEP 架構中，基本數據單位是事件（Event）。

在傳統數據庫中，數據行集合成爲數據表，而在 StreamInsight 中，相對應的集合就是流（Stream），全部的查詢都是針對流的。

其實流中的每一個基本數據其實並非一個完整的事件，只是包含了構成一個事件的基礎信息，須要通過打包才能成爲一個標準的事件。

2.0、下載StreamInsight（大小大約是14MB）安裝到本機

官方教程（包含下載地址）：

（http://msdn.microsoft.com/zh-cn/library/ee378749.aspx）；

StreamInsight2.1圖文版安裝教程：

（http://www.dotblogs.com.tw/skychang/archive/2013/04/18/101775.aspx）；

* 安裝的時候注意

實例名欄目輸入Default或者你想起的名字（通常是Default這樣別人代碼基本上不用修改）。

接着輸入產品密鑰: FH666-Y346V-7XFQ3-V69JM-RHW28

{！這是 SQL SERVER 2012 ENTERPRISE的密鑰 

}

選擇將當前用戶添加到StreamInsight 用戶組

2.一、快速上手官方demo：TrafficJoinQuery

* 打開（http://go.microsoft.com/fwlink/?LinkId=180356），下載StreamInsightProductTeamSamples.zip；

（本例中調試TrafficJoinQuery，打開Application文件夾便可看到）

* 啓動Visual Studio 2013，打開StreamInsightProductTeamSamples\Applications\TrafficJoinQuery\TrafficJoinQuery.sln；

* 導入項目成功之後，按Ctrl+F5運行便可。

* 對應教程（【原】StreamInsight 淺入淺出（四）—— 例子）

2.二、本身新建示例

StreamInsight手札（二）——構建HelloInsight程序

｛！表達還算清晰，但按其步驟完成到最後沒法調通。

不過好在原文有源碼，具體調試見（http://my.oschina.net/SnifferApache/blog/338550）

｝

StreamInsight實例

（http://technet.microsoft.com/zh-cn/library/jj136799(v=sql.111).aspx）

{！新建項目以後，選擇項目>添加>引用

程序集引用

• System.Reactive.dll

• System.Reactive.Providers.dll

• System.ServiceModel.dll

• Microsoft.ComplexEventProcessing.dll

• Microsoft.ComplexEventProcessing.ManagementService.dll

• Microsoft.ComplexEventProcessing.Observable.dll

其中，System.Service Model .dll在引用管理器>程序集>框架中勾選，其他的在程序集>擴展中勾選；便可開始運行

}

2.三、MouseGestureDemo的導入運行

直接打開以後

using Microsoft.ComplexEventProcessing;
using Microsoft.ComplexEventProcessing.Linq;
using MouseCaptureInputAdapter;
using TraceOutputAdapter;
using System.ServiceModel;
using Microsoft.ComplexEventProcessing.ManagementService;

一、二、6句提示缺乏程序集引用，此時解決方案資源管理器>引用中CEP相關的三個dll前面有黃色歎號，右鍵移除之。

從新在程序集>擴展中勾選這三個便可。

三、TrafficJoinQuery

佔位

四、推廣以及源碼

熱烈歡迎個人好基友熳熳同窗爲了CEP項目28號在oschina開博：

http://my.oschina.net/zhangxuman

博文源碼：

‍‍http://pan.baidu.com/s/1qWqKe5Y‍‍