处理复杂事件

Vik*_*ram 6 architecture esper complex-event-processing apache-spark apache-storm

我有一系列离散事件进入我的系统,我需要根据每个事件的内容应用规则.此外,我想对这些流事件应用复杂的事件处理.

约束1.这些规则由用户提供,并将动态更改.2.每当应用规则时,我都不想重新启动系统.3. HA 4.只有成熟的开源解决方案

可能的方法.. 1.在风暴螺栓内运行Esper CEP
2.在风暴螺栓内部运行drools

  • 这会做单事件规则处理以及复杂事件吗?规则更改是否需要我的风暴重启?

  • 我可以动态地将规则插入到暴风雨中吗?

其他方案?火花?

小智 5

Drools和Esper都可以动态注入规则,不需要重启Storm或JVM.

Esper和Drools Fusion都可以处理复杂的事件,通常会有不同的权衡.

在同一个分布式流处理解决方案领域是Spark流,Storm,Yahoo S4和Apache Samza.其中任何一种都可用于宿主Esper/Drools.对于Storm,我认为,因为它重放了元组,你需要在发送给Drools/Esper之前去除重复,或者设计你的连续查询,期望可能重复传递.

  • 你能指点一下Spark Streaming和Esper可以一起使用的资源吗? (4认同)