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

一、復瑣事件處理

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

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

咱們能夠認爲:複雜數據處理(complex event processing)是數據流的響應模型。數據庫

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

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

框架

* 概念介紹

五星:ide

StreamInsight概念工具

(http://msdn.microsoft.com/zh-cn/library/jj136801(v=sql.111).aspx);spa

事件結構.net

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

相關文章
相關標籤/搜索