问题标签 [complex-event-processing]

我是 Esper 的新手，我想得到一些帮助。我已经设法将 Esper 与 CSV 文件一起使用，但现在我需要使用 Java 对象作为通过套接字发送的事件，而且我在 Internet 上找不到简单的示例来用作指南。

有没有人基于它们的一些简单的例子？

无论如何，我把我正在努力工作的代码放在这里。当我运行它时没有任何反应，似乎套接字连接不起作用。

服务器类（它还包含事件类）。应该发送事件：

还有基于 Esper 的课程。

如果有人需要一些时间来帮助我，请提前非常感谢。

假设我有一个命名窗口：

其中TestEvent是 RevisionEvent，TestEventBase和TestEventDelta分别在 的基础和增量事件中定义TestEvent。这里的关键是FieldA。

目前，如果窗口中存在没有基本事件的增量事件，Esper 似乎会默默地丢弃此增量事件。因此，例如，如果 delta 事件出现在基本事件之前，则窗口中行的状态将看起来只是基本事件，因为 delta 被丢弃。

我的问题是，如果增量事件未能进入窗口，是否有办法捕捉它，例如，在发生这种情况时进行特殊处理？

如果我的应用程序要求我不丢失消息，并且 Esper 默默地丢弃了一些消息而不是其他消息，那么我如何 100% 确定某个事件进入了窗口？

提前感谢您的任何帮助！

我正在使用 StreamInsight 2.1 并遇到了意外的性能问题。

我有一个财务数据输入适配器，每秒输入 5,000 到 10,000 个事件。然后，我有大量针对该输入的查询。每个查询都连接到完全相同的直通查询，因此我有 1000 个查询使用完全相同的输入数据。

为了测试系统是否能够处理这个问题，我创建了 1000 个查询，这些查询除了传递（from d in fullStream select d）事件到仅释放事件的输出适配器之外什么都不做。

当我以这种方式运行 1,000 个查询时，系统无法跟上数据流。它越来越落后。如果我将其减少到 100 个查询，则系统可以完美运行。

我是否只是在使用 StreamInsight 时遇到了性能壁垒？它无法处理我正在构建的解决方案类型吗？还是我在这里做一些愚蠢的事情......任何帮助都会很棒，不知道还有什么可以让它更快。我需要它能够执行超过 1000 个查询，并且我需要运行比这更复杂的查询。

我尝试在 Drools 5.4.0.Final 中使用滑动时间窗口，并给出以下官方文档片段：

和

我在想混合形式是有效的：

但是，除非我弄错了，否则它的行为并不像预期的那样（即只考虑过去 2 分钟内发生的 RHT 股票报价）。我不明白结果的逻辑。

有人可以解释一下这个技巧吗？

谢谢。

我已经为我的 CEP 应用需求实施了 ESPER。在使用 EPL 时，我遇到了一个特定的场景，如下所示：

我将两个事件与左外连接结合起来，以确保第一个事件中的每个事件都可以触发语句，并且只有包含特定属性的第二个流中的事件才能出现。我创建了一个视图来存储基于某些字段的唯一数据。我的 EPL 是

我在配置文件中使用 java.util.Map 类型作为 CombinedEvent 数据类型

现在考虑测试场景

1. 已将两个 Id 不同但名称相同的 T1 类型事件输入系统
   
2. 一个 T2 类型的事件进入系统

由于视图规范，T1 类型的两个事件都驻留在视图中，并且当 T2 类型的事件进入系统时，Event Bean 类型的 NewData 参数包含 T1 的两个事件（如果我在代码中使用事件侦听器），但作为第一个 EPL 语句指定它插入到第二个语句中，它发现类型不匹配的错误，因为它期待“StmtGroupingEvent”的类型为 T2 的事件，但找到了事件 Bean。

所以我需要在 EPL 中处理数组类型的数据，这很麻烦。

另一方面，如果场景如下：

1. 只有一个 T1 类型的事件进入系统。
   
2. 一个 T2 类型的事件进入系统。

此方案不会产生任何错误，因为事件 Bean 已成功类型转换为 T2 类型。

所以请建议我这样做的任何替代方式。

谢谢

我将使用 tibco，我对它的技术堆栈感到困惑。

BPM 引擎 - TIBCO iProcess | CEP 引擎 - TIBCO 商务活动 | TIBCO ActiveSpaces

这个对吗？BusinessWorks 将在哪里出现？

我试图了解整个 WSO2 SOA 拓扑，但无法理解 CEP 和 BAM 如何组合在一起

1. CEP 能否提供已处理事件的可视化监控，例如与 WSO2 GS 的集成
2. 尽管 WSO2 网站说 CEP 与 BAM 紧密集成以进行后处理，但我找不到任何解释相同或如何完成的场景..（CEP 可以提供 BAM 吗？如何配置相同）
3. 为什么要将 CEP + BAM 放在一起？任何用例

有人知道 cassandra 中聚合的 Rainbird 项目是否已在主项目中提交？

有人对实时分析选择有什么建议吗？我也在考虑将 S4 用于 CEP 类型的功能。

问候。汤姆

我找不到在“B”事件（STREAM 模式）之间计算“A”事件的最佳方式（实际上是流口水融合方式）。序列的一个例子可能是：

一个用例可能是

验证序列有效性，即每个“B”事件之间总是有 3 个“A”事件

我不知道“窗口结束”的概念在这种情况下是否合适。感谢您的帮助，我在 CEP 方式上思考仍然有些困难。