6

我有一系列離散事件進入我的系統,我需要根據每個事件的內容應用規則。另外,我想對這些流事件應用複雜的事件處理。流程複雜事件

限制條件 1.這些規則是用戶提供的,並且會動態改變。 2.我不想在應用規則時重新啓動我的系統。 醫管局3. 4. 唯一成熟的開源解決方案

可能途徑.. 1.運行艾斯波CEP風暴之錘內
2.有風暴之錘內運行的Drools

  • 這會做單事件規則處理以及複雜事件?規則的變化是否會要求我的風暴重啓?

  • 我可以動態地將規則插入風暴螺栓嗎?

其他解決方案?火花?

回答

5

Drools和Esper都可以動態注入規則,並且不需要重新啓動Storm或JVM。

Esper和Drools Fusion都可以處理複雜的事件,通常可以進行不同的折衷。

在同一個分佈式流處理解決方案領域有Spark流,Storm,Yahoo S4和Apache Samza。任何這些都可以用來託管Esper/Drools。對Storm而言,我認爲它會重播你想在發送給Drools/Esper之前去除重複的元組,或者設計你期望可能發生重複發送的連續查詢。

+4

請問我可以將Spark Streaming和Esper一起使用嗎? –