Siddhi检查事件是否未在指定的时间窗口内到达？
我正在使用CEP检查事件是否在指定的时间量(比如1分钟)内到达。如果不是，我想发布警报。 更具体地说，(服务器)计算机生成心跳数据流并将其发送到CEP。心跳流包含服务器ID和时间戳。如果在1分钟内没有心跳数据到达，则应生成警报。 使用CEP可以做这样的事情吗？我还看到了有关检测未发生事件的其他问题，但我仍然不确定如何处理上述方案。 推荐答案 您可以尝试： define
..
siddhi相关内容
pmml:predict WSO2 Stream Processor 不存在扩展
我正在按照 WSO2 Stream Processor Studio 教程练习 Siddhi.到目前为止，我已经设法解决了教程中包含的所有错误；但是，我被困在第 12 个教程“进行实时预测"上. Siddhi 应用程序是 @App:name("SugarSyrupPredictionApp")@app:description("实时预测教程12")@source(type='http',
..
使用 wso2 CEP 处理空值
我想使用其中一列不为空的附加条件来更新事件表 (RDBMS).表名为 MSISDNProfileDB，在 oracle db 中. 来自incomingStream#window.length(1)选择correlation_MSISDN作为MSISDN，INTERACTION_DT 为 INTERACTION_DT更新 MSISDNProfileDB在 MSISDNProfileDB.MSIS
..
对尚未发生的事件使用 Siddhi 模式
我可以在 CEP 引擎中查找未发生事件的模式. 编辑欺诈模式检测查询:如果在一天内购买了两次同一张卡，并且第一次购买的金额低于 10 美元，而第二次没有，我可以触发该事件吗?超过 10,000 美元. 从每个 (a1 = purchase[price > 10] ) NOT -> a2 = 1 天内购买 [price >10000 and 1.cardNo==a2.cardNo]插入潜
..
无法使用 Flink siddhi 库处理 kafka json 消息
我正在尝试创建一个简单的应用程序，该应用程序将使用 Kafka 消息进行一些 cql 转换并发布到 Kafka，以下是代码: Java:1.8弗林克:1.13斯卡拉:2.11flink-siddhi: 2.11-0.2.2-SNAPSHOT 我正在使用库:https://github.com/haoch/flink-siddhi 向Kafka输入json: {“awsS3":{
..
无法使用 Flink siddhi 库处理 kafka json 消息
我正在尝试创建一个简单的应用程序，该应用程序将使用 Kafka 消息进行一些 cql 转换并发布到 Kafka，以下是代码: Java:1.8弗林克:1.13斯卡拉:2.11flink-siddhi: 2.11-0.2.2-SNAPSHOT 我正在使用库:https://github.com/haoch/flink-siddhi 向Kafka输入json: {“awsS3":{
..
无法使用 Flink siddhi 库处理 kafka json 消息
我正在尝试创建一个简单的应用程序，该应用程序将使用 Kafka 消息进行一些 cql 转换并发布到 Kafka，以下是代码: Java:1.8弗林克:1.13斯卡拉:2.11flink-siddhi: 2.11-0.2.2-SNAPSHOT 我正在使用库:https://github.com/haoch/flink-siddhi 向Kafka输入json: {“awsS3":{
..
pmml:predict WSO2 流处理器不存在扩展
我正在学习 WSO2 Stream Processor Studio 教程来练习 Siddhi.到目前为止，我已经设法解决了教程中包含的所有错误；但是，我被困在第 12 个教程“进行实时预测"上. Siddhi 应用程序是 @App:name("SugarSyrupPredictionApp")@app:description("进行实时预测教程12")@source(type='http
..
对尚未发生的事件使用悉地模式
在 CEP 引擎中，我可以为尚未发生的事件寻找模式. 编辑欺诈模式检测查询:如果在一天内两次购买同一张卡，并且第一次购买低于 10 美元而第二次购买低于 10 美元，我可以触发该事件吗不是超过 10,000 美元. 从每个 (a1 = purchase[price > 10] ) NOT -> a2 = purchase [price >10000 and 1.cardNo==a2.c
..
WSO2 CEP:Siddhi QL:创建具有类似事件记录的唯一流
我对WSO2 CEP Siddhi QL还是很陌生，我需要分析流中发生的事件. 例如:我有这样的数据[id，value]: InputStream=[1001,90] InputStream=[1001,85] InputStream=[1002,70] InputStream=[1001,85] InputStream=[1003,70] InputStream=[1003,85]
..
我如何使用Siddhi从事件的连续值中挑选出价值
例如数据: 1,1470732420000,0 2,1470732421000,0 3,1470732422000,0 4,1470732423000,86 5,1470732424000,87 6,1470732425000,88 7,1470732426000,84 8,1470732427000,0 9,1470732428000,0 10,1470732429000,0 11,147
..
如何使用siddhi实施执行计划?
首先让我描述一下我的要求: data.csv : 第一列是id，第二列是vlaue. 1,0 2,0 3,0 4,86 5,87 6,88 7,89 8,86 9,0 10,0 11,0 12,0 13,0 14,86 15,87 16,88 17,89 18,0 19,0 20,0 这是我的 InputStream 和我的 OutPutStream : id int,val
..
WSO2 CEP-多个执行计划的单个事件表
最近几天，我一直在探索WSO2 CEP. 我正在考虑一种方案，其中单个查找表可用于多个执行计划.据我所知，存储数据所有数据的唯一方法是事件表. 我的问题是: 我可以一次加载一个事件表(可能由一个执行计划加载)并与其他执行计划共享该表吗? 如果Q1的答案为否，那么它将是同一数据的多个副本，存储在不同的执行计划中，对吗?有什么办法可以减少这种空间的利用? 如果事件表不是正
..
WSO2 CEP结果集中有多行
我想知道WSO2 CEP/Siddhi查询是否支持返回多行(如果可以)如何将这些行中的数据映射到输出XML?例如我的事件流中有一个字段statusCode，该字段可以具有要编写查询的A/B/CI值，该查询可以为我提供过去5分钟内按状态类型计数的当前值，例如A-10，B-5，C-2 ..查询我使用statusCode分组以获取状态计数 MyQuery- ...insert into Test
..
使用wso2 CEP处理空值
我想使用其他条件更新事件表(RDBMS)，因为其中的一列不为null.表名是MSISDNProfileDB，在oracle db中. from incomingStream#window.length(1) select correlation_MSISDN as MSISDN, INTERACTION_DT as INTERACTION_DT update MSISDN
..
Siddhi CEP：在批处理时间窗口中聚合分组事件的字符串值
我正在使用Siddhi来减少系统中现有的事件数量。为此，我声明了一个批处理时间窗口，该窗口根据事件的target_ip将所有事件分组。 from Events＃window.timeBatch（30秒） 选择id作为meta_ID，Target_IP4作为target_ip 按Target_IP4 插入温度组； 我想要的结果是每个target_ip和meta_ID参数
..