处理复杂事件
我有一个离散事件流进入我的系统，我需要根据每个事件的内容应用规则。另外，我想对这些流事件应用复杂的事件处理。
约束1.这些规则是用户提供的，并将动态更改。2.每当应用规则时，我不想重新启动我的系统。3.HA 4.只有成熟的开源解决方案
可能的方式...1.在Storm螺栓内运行Esper CEP
2。让口水流到Storm螺栓里
>
这会处理单事件规则和复杂事件吗？规则更改是否需要我的Storm重新启动？
我可以在Storm螺栓中动态插入规则吗？
其他解决方案？火花
共有1个答案
Drools和Esper都可以动态注入规则，并且不需要重新启动Storm或JVM。
Esper和Drools Fusion都可以处理复杂的事件，通常具有不同的权衡。
在同一个分布式流处理解决方案域中有Spark streaming、Storm、Yahoo S4和Apache Samza。其中任何一个都可以用来托管Esper/Drools。对于Storm，我认为因为它重放元组，所以您可能希望在发送到Drools/Esper之前消除重复，或者设计连续查询，以期望可能的重复交付。
-
我有一个flink cep代码，可以从套接字读取数据并检测模式。假设模式（单词）为“警报”。如果单词alert出现五次或五次以上，则应创建一个警报。但我得到了一个输入不匹配错误。Flink版本为1.3.0。提前谢谢！！
-
我正在尝试了解Apache Flink CEP程序，该程序用于监控数据中心中的机架温度，如Flink官方文档所述。但是当我按照步骤使用mvn clean package创建jar并尝试使用命令执行包时 但我有以下错误， 我尝试了给出这里描述的类路径的不同变体，但得到了相同的错误。有人能指出我在运行程序时的错误吗？
-
我一直在寻找如何将apache storm用作CEP的方法，但似乎有两个概念（流处理和复杂事件处理），在CEP中，您可以编写类似sql的查询，并在数据流上执行它们，如ESPER，但我在apache storm中找不到类似的东西，这是否意味着apache storm是一个数据流处理器而不是CEP？
-
我想根据具有相同标识符的两个事件来检测两个事件是否在定义的时间范围内发生。例如，如下所示： 下面示例中的My DoorEvent java类具有相同的结构。 我想检测id为1的门在打开后5分钟内关闭。为此，我尝试使用Apache flink CEP库。传入流包含来自20扇门的所有打开和关闭消息。 如何在中将门1的状态保存为打开，以便在步骤中我知道门1是关闭的门，而不是其他门？
-
问题内容： 我有一个类似大型的对象，需要在多个工作进程之间共享。每个工作人员读取对象中信息的随机子集，并对其进行一些计算。我想避免复制大对象，因为我的机器很快耗尽了内存。 我正在处理此SO问题的代码，并对其进行了一些修改以使用固定大小的进程池，该池更适合于我的用例。然而，这似乎打破了它。 输出是 如您所见，在第一种情况下，所有工作进程都获得相同的对象（按ID）。在第二种情况下，id不相同。这是否意
-
我正在使用spring-mvc和Thymeleaf开发一个内部工具。 这个工具的一部分用于创建我们保存在数据库中的实体。这个实体相当复杂；它包含许多性质和关系。其中一些关系包含列表和其他属性。 我有两个限制： null 使用Thymeleaf呈现基本页面。使用JavaScript创建html元素，而不是提交到@ModelAttribute，我将表单序列化到JSON并将此JSON提交到服务器。（客户