问题标签 [complex-event-processing]

以下是我们的 Esper EPL 声明：

想知道如何在上面的查询中遍历所有数组元素（上面的 'inputCounts' 给出数组大小），而不是像上面的 EPL 那样只获取一个数组值。

对此的任何帮助将不胜感激！

苏尼特。

我们在 CEP 上看到内存不足错误。线程转储显示大约有 32000 个线程在监视器上休眠。此外，即使 CEP JVM 选项指定在内存不足时生成 HeapDump，我们也没有看到任何堆转储生成。请建议。(CEP JVM -Xms256m -Xmx1536m)

1) Cassandra 在这个 CEP 上被禁用
2) CEP 版本是 2.1.0
3) CEP 前面是 WSO2 ESB（使用 BAM 中介）。
4) 除了向 CEP 发送实际的有效载荷数据外，ESB 还向 CEP 发送周期性的心跳（每 15 ec）。

5）我们还在 ESB 上配置了 JMX 代理，它每 15 分钟监视 CEP（cpu/内存线程）
6）即使指定了 -XX:HeapDumpPath= 参数，也没有找到堆转储

• 在此 OOM 之前，CEP 连续运行了 7 天。重新启动后，我们观察到线程数以每天大约 4000-5000 个线程的速度稳步增加

CEP 日志..

CEP 中配置的一些查询

谢谢拉吉夫帕蒂尔

我想根据我们的需要扩展 Wso2 CEP 产品，并尝试编写一个自定义条件，如这个官方 wso2 cep 链接中所示。

但是它说“这是最新发布的 WSO2 复杂事件处理器文档（版本 2.1.0）。” 在页面顶部，它似乎已过时或信息错误。

例如，它说，

要编写自定义条件，请创建一个扩展“org.wso2.siddhi.core.executor.conditon.AbstractGenericConditionExecutor”的类，添加 SiddhiExtionsion 注释，编译该类，并将 jar 文件添加到类路径 /repertory/components/lib . 然后在新行中将实现类的完全限定类名添加到位于 /repertory/conf/siddhi 的 siddhi.extension 文件中。

（我假设“目录”是“存储库”）。官方 WSO2 CEP 包中没有文件或目录为“/repertory/conf/siddhi”或“siddhi.extension”，（wso2cep-2.1.0）。

我在本文档中遗漏了什么，如果没有，您能否推荐一个关于在 WSO2 CEP 中编写自定义条件的新文档？

我想根据我们的需要扩展 Wso2 CEP 产品，并尝试编写一个自定义条件，如这个官方 wso2 cep 链接中所示。

我能够编写扩展“org.wso2.siddhi.core.executor.conditon.AbstractGenericConditionExecutor”的扩展类并实现其抽象方法，如下所示：

当我将此扩展方法用作：

在这种情况下，如果名称字段的开头为“A”，我希望startswithA 方法返回true。但是，当我在 CEP 中运行此查询时，整个事件会进入我的执行函数，即没有迹象表明我发送“名称”字段作为参数发送到startswithA 方法。

我如何理解流的哪个字段作为参数发送到我的扩展方法？

我也想写条件

我怎样才能做到这一点？

有没有办法检测和报告流中的重复项？

示例：包含用户名和 IP 地址元组的用户登录数据流。目标是在最后 10 秒内检测来自不同 IP 的同一用户的登录。

我已经查看了 siddhi (wso2) 和 esper 查询语言，但我不知道如何实现这一点。

我是 ESPER 的新手。我正在检查类似 SQL 的查询。这是我的场景。我需要处理一个最喜欢的用例。将有一个推荐引擎，它会在每 12 小时内向用户推荐一些 URL。如果用户通过将 URL 标记为收藏或不对其进行操作，则事件将转到 ESPER。

1. 如果用户将某个 URL 标记为收藏，则 CEP 应该告诉推荐引擎不要再次发送相同的 URL。
2. 如果用户在推荐 n 次后没有标记 URL（用户不感兴趣），那么 CEP 也会告诉推荐引擎不要再次发送相同的 URL。

请建议我如何进行。我正在考虑将最喜欢的事件用作 POJO。

是否有任何示例代码可以让一个主机发布事件，另一台主机通过 Esper 框架接收事件（侦听器或订阅者）。我注意到 Esper 提供了不同的适配器（socket、JMS 和 HTTP），但找不到相应的示例代码。谢谢

这是为了更清楚地了解 WSO2 CEP 中生成的 JSON 事件的 JSON 映射。

我为此配置了两个存储桶。我有一个字符串 ( Suresh 7 LeadSE)，我将其转换为 JSON 对象。第一个存储桶正在获取输入字符串，我编写了一个 siddhi 扩展来将其转换为 JSON。

FirstBucket 将以字符串形式获取输入并将其转换为 JSON 并将其放入名为 parsedPacketTopic 的主题中。现在我想从这个 JSON 中获取各个元素。我正在尝试通过 SecondBuke 配置来解决这个问题。但是，我不知道如何将生成的 JSON 值映射到 SecondBucket 中。

我得到了字段的空值，expInYears我不知道如何将生成的 JSON 准确地映射到这些字段。empNameposition

有人可以帮忙吗？

代码

FirstBucket 配置

rawPacketTopic 的流定义

parsedPacketTopic 的流定义

第二桶配置

displayTopic的流定义

我是 CEP 2.1 的新手，我的问题与 CEP 保留输入流的时间范围有关

假设您定期将数据发送到某个输入流，例如“HELLOSTREAM”。CEP 将输入保存到流中多久，最长时间是多少等...

假设我每天发送数据 365 天，我会在 366 天取回所有数据还是会在某个时候截断数据（仅保留最后 100 天）？无论我在查询中设置什么时间窗口？

有限制吗？

我们有一个事件流，每个事件都具有以下属性：

此外，我们还有一组分层或嵌套规则，我们想用 EPL 和 Esper 建模。当且仅当其所有父规则都已被激活（所有这些规则都发生匹配实例）时，才应应用每个规则。例如：

我们要检索与此规则层次结构的每个级别对应的所有事件实例。例如，考虑以下事件：

我们希望我们的规则层次结构报告此实例以及与层次结构的每个级别对应的所有事件的 id。例如，需要类似于以下报告的内容：

我们如何在 Esper EPL 中实现这一点（检索与所有规则匹配的事件的 id）？