处理复杂事件

Question

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

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

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

• 这是否可以像处理复杂事件一样处理单个事件规则？规则更改会要求我的风暴重启吗？

• 能否将规则动态插入风暴螺栓？

其他解决方案？火花？

Answer 1

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

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

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