siddhi相关内容
我正在使用CEP检查事件是否在指定的时间量(比如1分钟)内到达。如果不是,我想发布警报。 更具体地说,(服务器)计算机生成心跳数据流并将其发送到CEP。心跳流包含服务器ID和时间戳。如果在1分钟内没有心跳数据到达,则应生成警报。 使用CEP可以做这样的事情吗?我还看到了有关检测未发生事件的其他问题,但我仍然不确定如何处理上述方案。 推荐答案 您可以尝试: define
..
我正在按照 WSO2 Stream Processor Studio 教程练习 Siddhi.到目前为止,我已经设法解决了教程中包含的所有错误;但是,我被困在第 12 个教程“进行实时预测"上. Siddhi 应用程序是 @App:name("SugarSyrupPredictionApp")@app:description("实时预测教程12")@source(type='http',
..
我想使用其中一列不为空的附加条件来更新事件表 (RDBMS).表名为 MSISDNProfileDB,在 oracle db 中. 来自incomingStream#window.length(1)选择correlation_MSISDN作为MSISDN,INTERACTION_DT 为 INTERACTION_DT更新 MSISDNProfileDB在 MSISDNProfileDB.MSIS
..
我可以在 CEP 引擎中查找未发生事件的模式. 编辑欺诈模式检测查询:如果在一天内购买了两次同一张卡,并且第一次购买的金额低于 10 美元,而第二次没有,我可以触发该事件吗?超过 10,000 美元. 从每个 (a1 = purchase[price > 10] ) NOT -> a2 = 1 天内购买 [price >10000 and 1.cardNo==a2.cardNo]插入潜
..
我正在尝试创建一个简单的应用程序,该应用程序将使用 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":{
..
我正在尝试创建一个简单的应用程序,该应用程序将使用 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":{
..
我正在尝试创建一个简单的应用程序,该应用程序将使用 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":{
..
我正在学习 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还是很陌生,我需要分析流中发生的事件. 例如:我有这样的数据[id,value]: InputStream=[1001,90] InputStream=[1001,85] InputStream=[1002,70] InputStream=[1001,85] InputStream=[1003,70] InputStream=[1003,85]
..
例如数据: 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
..
首先让我描述一下我的要求: 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. 我正在考虑一种方案,其中单个查找表可用于多个执行计划.据我所知,存储数据所有数据的唯一方法是事件表. 我的问题是: 我可以一次加载一个事件表(可能由一个执行计划加载)并与其他执行计划共享该表吗? 如果Q1的答案为否,那么它将是同一数据的多个副本,存储在不同的执行计划中,对吗?有什么办法可以减少这种空间的利用? 如果事件表不是正
..
我想知道WSO2 CEP/Siddhi查询是否支持返回多行(如果可以)如何将这些行中的数据映射到输出XML?例如我的事件流中有一个字段statusCode,该字段可以具有要编写查询的A/B/CI值,该查询可以为我提供过去5分钟内按状态类型计数的当前值,例如A-10,B-5,C-2 ..查询我使用statusCode分组以获取状态计数 MyQuery- ...insert into Test
..
我想使用其他条件更新事件表(RDBMS),因为其中的一列不为null.表名是MSISDNProfileDB,在oracle db中. from incomingStream#window.length(1) select correlation_MSISDN as MSISDN, INTERACTION_DT as INTERACTION_DT update MSISDN
..
我正在使用Siddhi来减少系统中现有的事件数量。为此,我声明了一个批处理时间窗口,该窗口根据事件的target_ip将所有事件分组。 from Events#window.timeBatch(30秒) 选择id作为meta_ID,Target_IP4作为target_ip 按Target_IP4 插入温度组; 我想要的结果是每个target_ip和meta_ID参数
..