-
0 votesanswersviews
Siddhi分布式缓存模式部署
根据文档（https://docs.wso2.org/display/CEP310/Clustered+Deployment），您可以在分布式模式下运行Siddhi . 据我所知，所有节点将共享流定义并在共享上下文（流，查询，事件......）上运行 . 但我不能把它付诸实践： 使用2.0.0-wso2v4版本 我编写了一个简单的程序，启动了两个启用了分布式处理的siddhiManager... -
0 votesanswersviews
将扩展的Siddhi事件表扩展到PostgreSQL
我需要在执行计划中使用与PostgreSQL数据库连接的事件表 . 我尝试扩展Siddhi扩展RDBMS事件表（来自siddhi-master分支），在进行jUnit测试时，我可以与数据库成功交互 . 我将eventtable.siddhiext文件添加到conf文件夹，将.jar添加到dropins文件夹，但是当我尝试通过执行计划访问时，我无法 Build 连接 . 而且，我可以毫无问题地创建P... -
4 votesanswersviews
无法在wso2 cep中执行自定义函数扩展
我正在使用 wso2cep 4.1.0 并使用以下包名创建了自定义函数扩展类： package org.wso2.siddhi.extension.custom; ..... public class MyFunction extends FunctionExecutor { ..... } 然后我创建了文件： custom.siddhiext 放入以下内容 . mycount=org.ws... -
0 votesanswersviews
WSO2 CEP自定义函数不能用作聚合函数
WSO2 CEP自定义函数不能用作聚合函数，而是在每行数据上运行 . 假设我们在输入流中有value1和value2 . host：A，Value1：1，value2：10 host：A，Value1：2，value2：20 host：A，Value1：3，value2：30 host：A，Value1：4，value2：40 host：A，Value1：5，value2：50... -
1 votesanswersviews
编写自定义扩展Siddhi
我有一个用于创建siddhi扩展的java程序，我的代码是下一个： package co.com.easysol.phisingRestClient; import java.io.StringReader; import javax.json.Json; import javax.json.JsonReader; import javax.ws.rs.client.Client; impor... -
1 votesanswersviews
wso2cep：错误 - 'distance'既不是函数扩展也不是执行计划“ExecutionPlan”中的聚合属性扩展
我正在使用WSO2 CEP 4.2.0版本，我正在编写一个执行计划，用于通过Siddhi查询检查来自不同传感器的坐标何时变化不超过4米 . 但是得到一个错误：'distance'既不是函数扩展，也不是执行计划“ExecutionPlan”中的聚合属性扩展 . 我已经安装了GPL - Siddhi Geo Extension，但我不知道为什么会出现这个错误 . 请帮我解决这个错误 . 我的执行计... -
0 votesanswersviews
WSO2 CEP窗口时间为1天
我正在评估ATM卡交易欺诈检测的不同可能解决方案，输入负载约为每秒50000，响应时间为几秒 . WSO2 CEP看起来更适合整体解决方案，但由于我是WSO2 CEP的新手而遇到了内存和性能问题所以请在CEP WSO2 / CEP中建议以下有更好的方法 . 为了检测欺诈，我们必须在1天的时间段内捕获数据聚合，这会导致内存溢出或性能损失 . 1）由于CEP试图将所有记录保存在内存中一整天，导致内存不... -
0 votesanswersviews
JAR扩展了SIDDHI
我想扩展siddhi，mi java代码是： package org.wso2.siddhi.extension.fraude; import org.wso2.siddhi.core.config.ExecutionPlanContext; import org.wso2.siddhi.core.executor.ExpressionExecutor; import org.wso2.sidd... -
1 votesanswersviews
使用两次窗口查询Siddhi CEP
我试图做一个简单的查询，但两个时间窗口;如果您已经为此产品发送了上个月的广告，那么查询将类似于尝试向过去四个月内访问过网络产品两次以上的用户发送消息 . define stream webvisit (idClient string, idProduct string, chanel string) from webvisit select idCliente, idProducto, cana... -
2 votesanswersviews
将WSO2 CEP Siddhi事件聚合到单个json对象
我正在尝试构建一个执行计划，将不同的事件聚合为一个并计算事件（CurrentEventId） . 该计划如下所示： define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId int); partition with (CurrentEventId of inStream) begin... -
1 votesanswersviews
关于编写自定义OutputAttributeProcessor
我有一些关于编写自定义OutputAttributeProcessor的问题 . 我使用WSO2 CEP 2.1.0和siddhi 1.1.0 . 我想创建一个自定义的OutputAttributeProcessor，所以我创建了两个java类，TestFactory实现了OutputAttributeProcessorFactory和Test实现的OutputAttributeProcessor... -
0 votesanswersviews
编写自定义OutputAttributeProcessor时出错
我有一个关于编写自定义OutputAttributeProcessor的问题 . 我使用WSO2 CEP 2.1.0和siddhi 1.1.0 . 我想创建一个自定义的OutputAttributeProcessor，所以我创建了两个java类，DiscomfortIndexAggregatorFactory实现了OutputAttributeProcessorFactory和Discomfort... -
0 votesanswersviews
Siddhi编写自定义聚合函数
我正在siddhi中构建一个自定义聚合函数，我对于官方文档有疑问，放在https://docs.wso2.com/display/CEP420/Writing+a+Custom+Aggregate+Function 在示例中，它创建了一个聚合函数扩展，其中 custom 作为命名空间， std 作为函数名称“，所以我的第一个问题是，为什么然后，当它从siddhi调用函数时，它使用： from pi... -
0 votesanswersviews
Siddhi：状态持久性和实时可查询状态？
My Scenario is like this. 我想查看/查询活动处理窗口的特定查询的当前聚合值是什么 . 我在Apache Flink见过这个 . For e.g: 假设我有一个查询来计算失败的总数，每12小时开窗一次 . 我想（从另一个应用程序）询问活动聚合窗口的当前计数是多少 . 请注意，活动窗口仍在处理中 . 原因是我的应用程序需要向用户提供有关其当前总故障计数的反馈 . 所以他/她可... -
0 votesanswersviews
Siddhi查询网络利用率
我目前正在评估siddhi用于snmp环境 . POC围绕网络接口利用而构建 . 流定义为： define stream interfaceStatsEvents (nodeName string, sdate double, ifSpeed long, ifIndex string, ifAdminStatus string, ifOperStatus string, ifInDiscards... -
0 votesanswersviews
参加Siddhi的3个活动
我想加入Siddhi有条件选择的3个赛事 . 我这样做是通过在存储桶定义中定义两个查询 . 这是第一个查询定义： from inStream[severity == 1] as a1 join inStream[name == 'name1'] as a2 on a1.time == a2.time insert into midStream a1.product as a1_product; ... -
3 votesanswersviews
wso2：cep：siddhi：如何使时间窗持续存在
我们目前正在测试siddhi wso2 cep . 我们需要能够重新启动wso2服务器进程而不会丢失已在窗口中累积的数据（例如时间窗口） . 有没有办法让时间窗持久化，以便服务器可以重新启动而不会失去其状态？ 我们是否必须配置服务器以使用持久性？ 或者我们只需要调整查询并使用事件表吗？ 这是我们的查询示例： from every data= DataInStream[state == 1] -&g... -
2 votesanswersviews
Siddhi查询语言'and'运算符
我正在测试'和'运算符的用法并使用文档中提到的示例： from every a1 = OrderStock1[action == "buy"] and a2 = OrderStock2[action == "buy"] -> b1 = StockExchangeStream[price... -
1 votesanswersviews
“str包含”功能SIDDHI
我有一个问题 . 我可以进行查询并使用带有两个事件的“str：contains”函数 . 例如替换： from DSBStream[(str:contains(correlation_phr_incident_detail, '0.0.0.0')==FALSE)] select * insert into DSBFiltered; 通过 from DSBStream#window.length(... -
1 votesanswersviews
Siddhi发送性能问题 - 嵌入式
我们正在评估Siddhi作为我们应用的嵌入式CEP处理器 . 在进行规模测试时，我们发现随着规则数量的增加，插入事件所需的时间会因每个唯一ID而显着增加 . 例如： 创建10条规则（使用窗口和ID分区） 一次加载1000个唯一条目 . 跟踪时间 . 请注意，当您接近100K唯一条目时，插入性能会从ms - >很多秒增加 . 您的规则越多，这次也会增加 . 现在为每条记录加载&q... -
0 votesanswersviews
如何从Kafka到Siddhi的数据摄取？
我通过本教程设置了一个Kafka事件接收器：https://docs.wso2.com/display/CEP420/Kafka+Event+Receiver 我完成了上面链接中描述的所有先决条件，并设置了一个事件接收器，用于从我本地计算机上的Kafka中提取数据并将其映射到特定流 . Question: 如何从Kafka开始摄取数据并开始将其推送到我在上面创建的事件接收器？我是否必须在Siddh... -
0 votesanswersviews
如何从siddhi事件模拟器发送事件到android siddhi应用程序
我在Android上运行了一个siddhi cep应用程序 . 现在我想通过套接字连接将事件模拟器中的事件从流处理编辑器发送到Android应用程序 . 直到现在我已成功制作了听取我制作的python客户端模拟器的android服务器套接字 . 但为了简化这个过程，我是否有可能使用事件模拟器将事件发送到android siddhi应用程序？ 我想知道我是否可以更改一些配置，以便事件模拟器将事件发送... -
0 votesanswersviews
siddhi服务器支持的最大规则数wso2 siddhi
我通过运行worker.sh与siddhi复杂事件处理器一起工作，并且遇到可以在siddhi中创建的最大数量的规则是675.超过该规则，Post to / siddhi-apps无法创建新规则 . 能告诉我怎样才能将它提升到1000以上 . -
0 votesanswersviews
Siddhi覆盖eventTimestamp
我在WSO2 Siddhi CEP中关注了Source： @source(type='kafka', topic.list='userInfo', partition.no.list='0', threading.option='single.thread', group.id="threadAccessor", bootstrap.se... -
0 votesanswersviews
WSO2 CEP thrift ip地址没有绑定到linux机器的eth0 / sitelocal ip地址
独立模式 当我在我的linux机器上启动WSO2 CEP服务器时，ip地址显示在日志中，如下所示 管理控制台网址：https：// <172.16.55.1>：9443 / carbon / 当我在该端口上运行netstat时，如下所示 linux-0rla：/ test / home / CEP / data #netstat -tulpn | grep 9443 t...