问题标签 [wso2cep]

是否可以使用身份验证证书连接到 WSO2 (CEP) 管理服务？

如果是，那么如何做到这一点？

我一直在尝试与 Siddhi 建立复杂的关联，在这种情况下，我有两个输入流，Web 客户端咨询和发送给客户访问的通知，如果每个客户端的第一个流重复不止一次，我想生成警报第二个流未发生在两个窗口下，取决于此事件的状态。

我尝试做的是使用中间流来计算大于或等于 2 时的网站点击次数，我看看它是否已经通过各种加入为该客户做出了商业行为......我想我已经变得很复杂，不知道有没有更简单的解决方案？？？，考虑到它没有功能 Siddhi NOT Happened 也没有其他连接（左连接）

我正在使用外部定时窗口测试一个非常简单的 CEP 查询。查询是define stream LoginEvents (timeStamp long, ip string, phone string); @info(name = 'query1') from LoginEvents#window.externalTime(timeStamp,5 sec) select timeStamp, ip insert all events into uniqueIps;；

看看这里的单元测试，我想会发生什么是回调将被调用 9 次，传入事件 5 次，过期 4 次。相反，它只被调用一次。为什么会这样，我怎样才能达到为每个事件调用回调的状态？

我目前正在使用具有 siddhi 核心、api 和查询 jar 库的 Java servlet。我正在使用 SiddhiManager 类来创建流、查询和回调。servlet 允许我运行常规查询，但不查询基于时间窗口的查询，例如 -

从 StatusTime#window.time(4 min) 选择 cid,sum(values) 作为 SUM 组，按 cid (SUM>40) 插入 payt

每次调用 servlet 时，时间窗口都会重新启动，因此基于时间的查询会失败。如何让 siddhi 管理器使用之前启动的时间窗口。

Siddhi CEP 的新手。除了 WS02 CEP 上的常规文档之外，有人可以指出一个很好的教程。

这是我们的要求。指出有关编写此类查询的正确方法的一些线索。

• 拥有单一的传感器设备通知流（物联网应用程序）。
• 流输入是通过 REST-JSON 并且输出也将被格式化为 REST-JSON。（希望这在 WS02 CEP 3.1 上是可能的）

所需的执行计划种类： - 如果设备通知报告传感器 1 的使用情况，则在 5 分钟内监控设备通知是否也报告传感器 2 的使用情况。如果找到，则在 REST-JSON 上生成报告复合活动的输出流。
- 如果在上午、下午和晚上的时间段内未检测到此类复合活动，则在 REST-JSON 上生成警告事件流状态。（那么如何找到未及时发生的事件） - 如果在早上、下午和晚上的某些时间段内未找到此类复合活动，则在 REST-JSON 上报告 failure1-event-stream 状态。

这应该每天都在工作，那么之前处理的数据将如何在 WSO2 CEP 中被删除。

问候， 阿米特

我尝试本地化 WSO2 CEP 产品。

我发现了一些关于 http://tanyamadurapperuma.blogspot.kr/2013/10/localizing-wso2-carbon-products-part-1.html的帖子

所以我将所有 JSResources.properties 和 Resources.properties 文件更改为 JSResources_kr.properties 和 Resources_kr.properties。

但是所有的性格都被打破了。

我想在 IBM Bluemix 上运行我的 WSO2 CEP。是否可以将其作为 Liberty 应用程序托管，或者那里有任何其他可用选项？

关于 WSO2 BAM 2.5 输出事件适配器的两个问题 - 1）为什么输出事件适配器类型中没有“电子邮件”选项？根据文档，它应该在那里。即使我为电子邮件事件适配器创建了自己的 XML 文件并将其放入所需的文件夹中，然后键入“电子邮件”也无法识别，并且 BAM 将其显示为“非活动”。2) 默认记录器输出事件适配器将日志写入哪个目录和文件？我已经配置了，我可以看到消息是通过 Hive 脚本生成的并写入 BAMNotifications 列族，但我无法在存储库/日志目录日志文件中看到日志？请帮忙。

我的系统设计是把CEP作为系统的“引擎”，这样客户的请求会作为事件发送到CEP，然后重新路由到BPS来触发不同的业务流程。

我的问题是：如何配置 BPS 以订阅来自 CEP 的事件流（或多个流），并“触发”业务流程的执行？

谢谢

我希望在我的应用程序中用 Siddhi 替换 Esper。现在的 esper 语句是一种“超时”类型模式，当具有唯一“名称”和“类型”的事件（我可以在传入事件中查找的字符串值）到达和离开时，我需要报告回来。我知道当事件第一次到达我的第一个唯一窗口时事件已经到达，并且我假设如果我没有看到任何同名的事件并输入用户定义的超时值，事件就会离开。这是我的 esper 语句的样子（请注意，在实际的 esper 中还有很多事情要做，我只是为了举例而简化了这个）：

创建窗口 events_1.std:firstunique(name, type) 作为 NameEvent

插入 events_1 从 EventCycle [events] 中选择 *

在模式 [每个 event1=events_1->(timer:interval(4.0 sec) 而不是 events_1(name=event1.name, type=event1.type))] 从 events_1 中删除 name = event1.name AND type=event1.type

然后我从 events_1 中选择 irstream 并通过获取传入和删除的事件，然后从窗口中获取“到达”和“离开”事件。

对于 siddhi，第一个独特的窗口相当简单（我认为？）：

从 EventCycle#window.firstUnique('name')[ type=='type' ] 选择名称，输入插入到 NameEvent

但我真的对如何用 Siddhi 替换那个 esper “on pattern”一无所知。我可以为此使用一个“来自每个”的声明，还是需要对 Siddhi 采用不同的方法？

任何帮助我走上正确道路的帮助将不胜感激！