我的系统中有一个离散事件流，我需要根据每个事件的内容应用规则。另外，我想对这些流事件应用复杂的事件处理。
限制条件1。这些规则由用户提供，并将动态更改。2.我不想在应用规则时重新启动系统。3.哈4。只有成熟的开源解决方案
可能的方法。。1.在防风雨螺栓内运行esper cep
2.在风暴栓里流口水
这会处理单事件规则和复杂事件吗？规则的改变会要求我的风暴重新开始吗？
我可以动态地将规则插入风暴螺栓吗？
其他解决方案？Spark？
我的系统中有一个离散事件流，我需要根据每个事件的内容应用规则。另外，我想对这些流事件应用复杂的事件处理。
限制条件1。这些规则由用户提供，并将动态更改。2.我不想在应用规则时重新启动系统。3.哈4。只有成熟的开源解决方案
可能的方法。。1.在防风雨螺栓内运行esper cep
2.在风暴栓里流口水
这会处理单事件规则和复杂事件吗？规则的改变会要求我的风暴重新开始吗？
我可以动态地将规则插入风暴螺栓吗？
其他解决方案？Spark？
1条答案
按热度按时间zlwx9yxi1#
drools和esper都可以动态注入规则，不需要重启storm或jvm。
esper和droolsfusion都可以处理复杂的事件，一般来说，有不同的权衡。
在同一个分布式流处理解决方案域中有spark streaming、storm、yahoo s4和apache samza。其中任何一个都可以用来托管esper/drools。对于storm，我认为由于它重放元组，所以您可能希望在发送到drools/esper之前消除重复，或者设计连续查询以期望可能的重复传递。