问题标签 [siddhi]

我想知道 WSO2 CEP/Siddhi 查询是否支持返回多行，如果是的话，如何将这些行中的数据映射到输出 XML？例如，我的事件流有一个字段 statusCode，它可以有值 A/B/CI 想要编写一个查询，它给我过去 5 分钟的状态类型计数，例如 A-10、B-5、C-2.. 在当前查询我使用按状态代码分组来获取状态计数

是否可以在单个 XML 中获取查询结果？即在上述情况下，单个 XML 中的 A、B、C 计数？

谢谢拉吉夫

我正在尝试使用 siddhi 查询语言，但似乎我在滥用它。

我有一些带有以下 streamdef 的事件：

我只是想使用这样的查询过滤具有相同进程值和相同通量值的事件：

每当我尝试此操作时，都不会生成任何输出。当我摆脱过滤器

我所有的事件都在输出中。

我的查询有什么问题？

siddhi ( http://siddhi-cep.blogspot.com/ ) / WSO2 是否具有处理类似于以下内容的查询的功能

1) 5 次错误后成功

2) 5 个错误，5 个致命，1 个成功

可以假设存在时间窗口

谁能提供一个例子？

我目前正在评估在 snmp 环境中使用的siddhi。POC 是围绕网络接口利用率构建的。

流定义为：

计算接口利用率的查询为：

问题是查询似乎只运行一次。向interfaceStatsEvents流添加了4 个事件 。期望为interfaceUtilization生成 3 个事件，而不是仅生成一个事件。

有没有人知道原因或如何修复查询？

我想参加有条件选择的 3 个 Siddhi 活动。我通过在存储桶定义中定义两个查询来做到这一点。

这是第一个查询定义：

第二个：

执行查询时，我不断收到 ArrayIndexOutOfBounds 异常。我究竟做错了什么？异常日志：

顺便说一句，输入映射是正确的，并且成功部署了存储桶。

桶定义：

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

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

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

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

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

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

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

有人可以帮忙吗？

代码

FirstBucket 配置

rawPacketTopic 的流定义

parsedPacketTopic 的流定义

第二桶配置

displayTopic的流定义

下午好。

我以建筑师 SW Competence Centers 为 Indra 公司 (www.indra.com) 撰写文章。

在这个领域通常使用 CEP，开源和商业，在开源领域直到现在我们一直使用 Esper CEP，但我们发现 GPL 存在问题。

在我们对尝试 Siddhi CEP 感到好奇之后，我们已经使用这个 CEP 启动了一个项目。

问题是我们发现我们无法识别包含所有 CEP 和项目需求的功能：检测事件的缺失。

在 Esper 中，这可以通过如下查询来完成：

我们想知道产品路线图是否包含此功能，以及现在是否有解决此问题的方法。

谢谢和问候。

我对编写自定义 OutputAttributeProcessor 有一些疑问。我使用 WSO2 CEP 2.1.0 和 siddhi 1.1.0。

我想创建一个自定义的OutputAttributeProcessor，所以我创建了两个java类，TestFactory实现了OutputAttributeProcessorFactory，Test实现了OutputAttributeProcessor。两个类的包是org.wso2.siddhi.extention。

TestFactory 必须覆盖 createAggregator 和 getProcessorType，而 Test 必须覆盖 createNewInstance、getType、processInEventAttribute 和 processRemoveEventAttribute。

第一个问题是关于每种方法。

getProcessorType 应该写什么？

还有，processInEventAttribute 和 processRemoveEventAttribute 有什么不同？

另外，我还有一个问题。我将创建两个 java 类的 jar 文件。我将 jar 文件添加到 /repository/components/lib 的类路径中，并将 TestFactory 的完全限定类名添加到位于 /repository/conf/siddhi 的 siddhi.extension 文件中。

siddhi.extension 的内容是什么？

下面是一行吗？

如果有关于自定义 OutputAttributeProcessor 的示例程序，请教我。

先感谢您。

我有一个关于编写自定义 OutputAttributeProcessor 的问题。我使用 WSO2 CEP 2.1.0 和 siddhi 1.1.0。

我想创建一个自定义的OutputAttributeProcessor，所以我创建了两个java 类，DiscomfortIndexAggregatorFactory 实现了OutputAttributeProcessorFactory 和DiscomfortIndexAggregator 实现了OutputAttributeProcessor。两个类的包是org.wso2.siddhi.extention.aggregator.environment。

两个java程序如下。

DiscomfortIndexAggregatorFactory.java

DiscomfortIndexAggregator.java

我创建的 jar 文件包含两个 java 类，将 jar 文件添加到 /repository/components/lib 的类路径中，并添加了位于 /repository/conf/siddhi 的 siddhi.extension 文件。siddhi.extention 的内容如下。

org.wso2.siddhi.extention.aggregator.environment.DiscomfortIndexAggregatorFactory

我在上述配置后重新启动。重启后不输出错误日志。

但是我创建了以下存储桶查询，

并输出以下错误日志。

你能告诉我怎么做吗？

先感谢您。