问题标签 [siddhi]

我需要通过检查条件为流中的特定属性分配一个值。

我该怎么做？

例如

如果一个人的名字是“约翰”，我需要将他的名字修改为“彼得”并插入另一个流，我该怎么做？

我需要处理输入流并将具有与输入流相同模式的已处理流发布到记录器。

换句话说，我需要为导入和导出定义使用相同的架构。我该如何解决这个问题？

使用 siddhi QL 在 wso2 cep 中可以做到这一点吗？

我正在使用Siddhi编写一个小型 CEP 程序。每当给定过滤器输出这样的数据时，我都可以添加回调

但是有没有办法知道过滤器已经完成处理并且它不会再提供上述回调。类似的东西didFinish。我认为那将是关闭SiddhiManager和ExecutionPlanRuntime实例的理想场所。

在 WSO2 CEP 中，我制定了一个执行计划，其中包含以下查询：（如果温度在 10 秒内连续 3 次超过 20 度，它将被触发）

我如何才能实现仅在一天中的特殊时间（例如 08:00 到 10:00 点）应用查询？

有什么我可以在查询中输入的内容，例如：

我正在尝试在 siddhi 中的输入流上实现一个基本窗口。这是窗口查询

这就是我向输入流提供数据的方式。

假设查询应该在每次输入到inputHandler. 所以对于这个例子，初始输出应该是 10，然后它应该逐渐减少并变成 5。在我发送了所有 10 和 2 个 5 的时候，我应该得到一个平均为 (10+10+10+5) 的回调+5)/5= 8。但目前没有发生这种情况。对于这个实现，我得到两个平均分别为 10 和 5 的回调。为什么没有从 10 逐渐减少到 5？

这就是我添加回调的方式

我在这里想念什么？

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

谢谢

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

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

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

我们有大量用 C++ 和 Java 编写的算法。现在我们要介绍 WSO2 DAS 平台。我们可以在哪里以及如何将这些算法与 DAS 集成？

我应该解释更多信息：这些算法正在运行实时分析，但我们发现 DASsiddhi用于实时分析，并且它没有提供任何可用于这些算法的接口或 API。

我正在尝试在 Siddhi 中实施一个示例项目。有一个具有一个属性的输入事件流height。我想编写一个sequence查询，当三个连续事件具有相同的高度时给出回调。我已经参考了这个和这个博客，但我无法正确使用语法。我SiddhiParserException在尝试运行序列查询时得到。

这是相应的模式查询，它工作正常。

下面是我如何编写序列查询以获得两个连续相等的高度，但我无法做到正确。

添加错误日志：

任何帮助表示赞赏。

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

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

我必须写三个 Siddhi 查询吗？

谢谢你。