architecture - 处理复杂事件

Question

我的系统中有一系列离散事件，我需要根据每个事件的内容应用规则。另外，我想对这些流事件应用复杂的事件处理。

约束 1. 这些规则是用户提供的，并且会动态变化。2. 我不想在应用规则时重新启动系统。3. HA 4. 只有成熟的开源解决方案

可能的方法.. 1. 在风暴螺栓内运行 Esper CEP
2. 在风暴螺栓内运行流口水

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

• 我可以动态地将规则插入到风暴螺栓中吗？

其他解决方案？火花？

Answer 1

Drools 和 Esper 都可以动态注入规则，并且不需要重启 Storm 或 JVM。

Esper 和 Drools Fusion 通常都可以处理复杂的事件，但需要权衡取舍。

Spark 流、Storm、Yahoo S4 和 Apache Samza 在同一个分布式流处理解决方案领域。其中任何一个都可用于托管 Esper/Drools。对于 Storm，我认为因为它会重放元组，所以您希望在发送到 Drools/Esper 之前进行重复数据删除，或者设计您的连续查询以期望可能的重复交付。