architecture - 处理复杂事件

Question

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

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

可能的方法..
1. 在 Storm bolt 内运行 Esper CEP
2. 让流口水在 Storm bolt 内流淌

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

我可以动态地将规则插入到 Storm bolt 中吗？

其他解决方案？ Spark ？

Answer 1

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

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

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