问题标签 [complex-event-processing]

我已经在 Solaris 10 机器上成功安装了 wso2 cep 引擎。作为事件，我正在接收 UDP 提要（管道分隔的数据线）。如何配置 CEP 引擎以接收 UDP 提要并对其进行处理？

谢谢

在我的项目中，我需要跟踪数据库表中新插入的行。并将这些行提供给 .net 应用程序进行处理。我通过了 StremInSight，它非常适合。所以我想知道的是有什么选项可以捕获 StreamInSight 中的变化吗？否则我怎么能同时加入 ServiceBroker 和 StremInSight。我的意思是我们可以使用服务代理将更改流式传输到 StreamInsight 吗？

我使用 esper 加入流如下：

现在考虑一个场景：
1. 两笔交易进入系统
2. 价格到达

在这种情况下，分组流将生成两个输出，每个输出用于一笔交易。这也会从最终输出中触发两个事件。随着事件数量的增加，输出事件的数量也将增加。
现在，如果将
Id - 03
Symbol - GOOG
Quantity - 300

的交易输入到系统中，它还将触发 3 个新事件，因为每个 Id 的 %ageMV 也会发生变化。随着事件数量的增加，在 UI 上处理变得困难。

所以我的问题是 -
有没有标准的方法来做到这一点？

我需要使用 ESPER实现一个规则引擎
为此我必须准备查询规则（如果有任何其他优化方式，请提出建议）。规则在运行时必须是可声明的和可修改的。
此外，我将不得不创建一个 UI 来定义规则。
请建议任何更好和优化的方法。
一个例子：

可以在运行时定义更多的规则。

我正在尝试使用 mule+drools fusion 制作一个 twitter 应用程序，但是我在一个特定规则“Tweet a caso sospechoso”的 rhs 中得到了一个空指针异常。我想不通。

我认为 drools 引擎正在提早撤回推文事件。当我需要在 rhs 中使用 tweet 事件时，该事件不再存在。

堆栈跟踪

如果它有帮助，骡子流动：

涉及的两个构造函数

如何在其他 EPL 文件中分发表达式？

我试过了，但有两个问题需要看。
1. 任何 EPL 文件不能只包含“表达式”。（“意外结束”错误）
2. 访问另一个 EPL 文件中定义的表达式，给出“未找到”错误。
这是我的尝试：
//epl1.epl

//epl2.epl

我正在使用netbeans。 如果我知道如何在 epl 中创建单行函数
也会很有用？

我遇到了 StreamInsight 的情况，其中我有 1 个输入源，其中包含不同类型的事件，需要区别对待，但最终与来自同一源的其他事件匹配。

我在下面创建了一个（非常）更简单的场景，其中输入源生成随机数（为简单起见，1 和 0）。如果数字是偶数，我们想保存它，直到另行通知（未知持续时间）。如果数字是奇数，我们希望将其与偶数流中的 n-1 匹配，然后从偶数流中删除 n-1。如果不匹配，奇数将直接处理，无需进一步计算。在从偶数流中删除匹配的 n-1 之前，我的一切都按预期工作。进行匹配，并将匹配推送到输出适配器，但仍可用于对给定事件进行另一个连接。我收集了几天的实验和研究，不知何故我需要剪辑均匀的流事件持续​​时间（ClipEventDuration），大概作为 GenerateEvenJoinQuery 中过滤器的一部分，但是，我尝试过的一切都没有产生任何变化或不希望的结果。我还尝试将 evenStream 更改为 Interval 形状，但运气更差。任何帮助或建议将不胜感激。

例如，给定一个简化列表： [ 1, 0, 1, 1, 0, 0, 1, 1, 1 ]

我希望输出看起来像： [ 1, 100, 1, 100, 100, 1 ]

我也会接受我正在使用的真实场景，第一个输出实际上是不可能的：注意第二个和第三个 0 连接到一个 1. [ 1, 100, 1, 100, 1, 1 ]

解决方案：

虽然我希望一些更精细且可能更快的东西，但延迟处理可能有助于提高性能。

我需要有点像这样。

现在从 w1 命名窗口插入另一个事件

但有些第三事件无法自动触发派生事件重新计算。
第 4 个事件的到来触发并根据需要提供输出。
有什么标准的做法吗？

我想计算新事件是进入窗口还是离开窗口的总和。

我正在编写一个基于 Java 的 Web 服务器监控应用程序，它应该能够检测用户何时在特定时间范围内以特定顺序浏览给定的一组页面。为此，我正在使用Esper 库。我对查询的最佳表述有一些疑问。

我首先声明了一个“访问”对象，用于存储到达我的 Web 服务器的 HTTP 请求的所有信息。每当向服务器发出新请求时，都会实例化一个新的 Access 对象并将其作为事件发送到 EPL 处理核心。

假设我想跟踪浏览页面 A、页面 B 和页面 C 的所有用户。处理这种情况的最佳方法是什么？我是否需要执行多个连接，每个转换一个，如下例所示？

我必须选择以下工具之一来开发项目的事件处理部分，但该工具应在 ASF 2.0 许可下。

• SIDDHI >> 在 ASF 许可下
• ETALIS >> 在 GNU Lesser GPL 许可下
• JBoss – Drools Fusion >> ASL 许可证
• ActiveInsight >> 通用公共署名许可 1.0 (CPAL)
• 智能事件处理器 – IEP
• SQL流
• Oracle 事件处理

我知道四个冷杉，我如何检查其他冷杉？