问题标签 [siddhi]

我有两个流，streamA并且streamB. 每个streamA都有一个 ID，并且匹配的事件streamB将具有相同的 ID。

我想知道在1 分钟的滑动窗口之后streamA哪些 ID 没有进入。streamB

我试过这个，但没有成功：

from streamA as A join streamB#window.time(1 min) as B on A.id == B.id select S.Id insert expired events into streamC;

让我知道如何解决这个问题。

我有一个网络服务 (REST)。每次有事件进入我的流时，我都想调用 WS。

我必须创建 Siddhi 的扩展并从 java 调用 Web 服务？

如果我需要 java 来调用 Web 服务，我应该扩展“聚合函数”吗？

在 Siddhi 中存在我可以用来调用 Web 服务的任何指令吗？

接下来是我的 WS 示例：

http://72.37.125.125:3000/phishing?url=www.innerjoin.co

感谢您的意见

我可以使用来自 siddhi 的 HTTP 类型的其他输入流的参数调用服务 REST 吗？

例如：

我有一个输入流sensorStream：

我想使用属性 meta_sensorName 作为调用我的 Web 服务的输入：

这可能吗？

我有一个问题。

我可以进行查询并将“str:contains”函数与两个事件一起使用吗？

例如替换：

经过

这个有可能？

我有一个用于创建 siddhi 扩展的 java 程序，我的代码是下一个：

还有我的 Custom.siddhiext：

在我的 ExecutionPlan 我使用下一个代码：

custom.siddhiext 文件位于 /repository/components/lib 中，但出现下一个错误：

为什么 ？

我想扩展 siddhi，mi java 代码是：

siddhiext：

我生成了我的 JAR，您的位置是 C:\wso2\wso2das-3.0.1\repository\components\lib

我可以使用 siddhi 中的“swordurl”：

但是我运行了我的执行计划，我得到了下一个错误：

当我对 Siddhi 使用外部依赖项时，总是会发生此错误。为什么 ？

在这种情况下，我使用下一个外部依赖项：

（我从 Esper 跳到 Siddhi）

我正在尝试在同一流中部署多个查询。此处的示例https://docs.wso2.com/display/CEP400/Using+Siddhi+as+a+Library展示了如何在一个流中部署查询，完全在一个 ExecutionPlan 中。那么，如果我想将查询添加到同一个执行计划或同一个流中呢？

我有兴趣在语法上这样做，Java 代码。

更新

我想在现有执行计划中添加查询。这意味着当流到达时，而不是之前。使用作为答案发布的示例：

我试图通过简单地导入自定义映射流来编写一个简单的 siddhi 查询。但是，一旦我导入流并验证查询，它就会出错。

然而，我的完整查询是

我想要的只是计算日志中一分钟的记录数，然后导出时间并计数到输出流。但即使在第一行，我也会遇到错误。我的输入是一个broids 的日志文件，ssh.log. 它的样本记录类似于： {"ts":"2016-05-08T08:59:47.363764Z","uid":"CLuCgz3HHzG7LpLwH9","id.orig_h":"172.30.26.119","id.orig_p":51976,"id.resp_h":"172.30.26.160","id.resp_p":22,"version":2,"client":"SSH-2.0-OpenSSH_5.0","server":"SSH-2.0-OpenSSH_6.6.1p1 Ubuntu-2ubuntu2.6","cipher_alg":"arcfour256","mac_alg":"hmac-md5","compression_alg":"none","kex_alg":"diffie-hellman-group-exchange-sha1","host_key_alg":"ssh rsa","host_key":"8d:df:71:ac:29:1f:67:6f:f3:dd:c3:e5:2e:5f:3e:b4"}

我正在使用一个简单的 SiddhiQL 查询来获取具有相同时间戳的记录数，直到分钟条目和这些时间戳。查询是：

它给了我错误mismatched input 'group' expecting {'*', '+', '-', '/', '%', '<', '<=', '>', '>=', '==', '!=', AS, OR, AND, IN}。group by在这种情况下，从句有什么问题？

我在通过查询消化我的组的结果时遇到了麻烦。我的源流名为intermediateStream有数据

SIDDHI 查询是

我期待输出像

但相反，它返回

有什么建议么？