问题标签 [wso2cep]

学习 SiddhiQL 的最简单方法是什么。是否有任何工具，例如用于 Siddhi的Esper EPL Online ？或者对于初学者来说最简单的方法是什么？

谢谢

如何定义 Siddhi 查询以检测具有以下属性的两个事件 e1 和 e2：

• e1 可能出现在 e2 之前或之后。
• 这意味着： abs( e1.timestamp - e2.timestamp ) <= 5s)

在 Drools 中我们可以使用 Allen 运算符一致：e1 一致 e2[5s]

在 SiddhiQL 中，如何插入具有相同条件的多个流？

当我有两个相关事件（event1 和 event2）并且想要在 streamA 中插入 event1 时；在streamB中插入event2；在streamC中插入abstractEvent。

我必须写三个 Siddhi 查询吗？

谢谢你。

是否有任何文档/文章解释 WSO2 CEP 中的事件生命周期？我不太明白事件是如何从事件流中丢弃的。

谢谢你，雨果卡拉多

我希望从 WSO2 DAS 服务器调用我的 R 脚本。我在 siddhi 查询中编写了以下代码

我调用 R 脚本的语法是否正确？如果有人可以告诉我为什么我在 DAS 控制台中收到此错误错误消息。我还 根据 wso2 提供的链接在https://rforge.net/JRI/files/下载了 JRI 文件。

我正在尝试运行以下 wso2cep 示例。 https://docs.wso2.com/display/CEP400/Sample+0067+-+Publishing+Map+Events+via+Cassandra+Transport

但是在最新的 cassandra 版本中，我们找不到 cassandra-cli。所以我们必须改用 cassandra CQL。

如何在 CQL 中运行以下针对 cassandra-cli 的命令？

谢谢..

我正在寻找将 CEP 引擎集成到我的应用程序中的方法，我想知道是否存在 REST API 或其他工具来集成它并在管理控制台之外访问其功能。

我没有在文档中找到任何东西。

I'm new on Stackoverflow even if I solved a lot of problems with your hints. Now I have a problem I have not found the solution. I'm developing a pushing service using the WSO2 CEP and the GCM. CEP handles the subscribe/unsubscribe requests and the push events. The subscriptions keys are stored on my own server using MySQL together with other info. My problems come with the subscribe step. This step has to handle either the new subscriptions (insert) and existing subscription (update). To make the operation easier, I decided to normalise the two operations by deleting and inserting the records (even if the record could be already on the DB). To handle this, I developed an execution plan using Siddhi. The plan defines 2 streams: an event stream and a table stream linked to a MySQL table. In the Execution Plan, first a delete is done using the key taken from the event and after a new record is inserted using the info contained into the event. But it seems that the sequence of the operations (delete and insert) differs, so sometimes I found two or more records with the same GCM key on my server. I applied a workaround by adding a unique constraint on the table, but I'd like to know if there is a way to fix a deterministic order on the Siddhi operations.

Regards

Michele de Rosa

我在管理控制台中定义了一个使用 WSO2-CEP 的 KafkaReceiver。它不起作用，我可以在服务器控制台日志中读取此错误

如果我们在此链接阅读课程源https://github.com/wso2/carbon-analytics-common/blob/master/components/event-receiver/event-input-adapters/org.wso2.carbon.event.input .adapter.kafka/src/main/java/org/wso2/carbon/event/input/adapter/kafka/KafkaEventAdapter.java

我读到错误是在 ConsumerConfig 创建中

我正在寻找一个 CEP 工具来开始我关于监控实时网络入侵检测系统日志的项目。我发现了有关 WSO2 的信息，但没有成功找到安装了 WSO2 并配置为下载和练习的 vm 映像。谁能给我一些有用的链接，WSO2 CEP包括其完整的示例和 VM 映像下载链接？谢谢。