-
1 votesanswersviews
WSO2中的自定义执行功能
我正在尝试为WS02（4.2.0）编写一个简单的自定义函数扩展 . 我的函数基本上接受一个String并返回大写 . 这是更高级自定义功能的第一步POC . 我实现了一个扩展org.wso2.siddhi.core.executor.function.FunctionExecutor类的类，并创建了一个ams.siddhiext文件 . 然后我使用maven-bundle插件将类和siddhiex... -
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... -
0 votesanswersviews
WSO2 CEP pizzaOrderProcessingPlan的Siddhi语言很奇怪
以下链接提供WSO2 CEP样本 https://docs.wso2.com/display/CEP310/Getting+Started+with+CEP 我顺序完成文件并没有问题 . 但我有一个关于遵循Siddhi语言的问题 define table pizza_deliveries (deliveredTime long, order_id string); from deliveryS... -
1 votesanswersviews
WSO2 CEP中卡尔曼滤波器的输入和输出参数的含义是什么？
我希望得到一些关于WSO2 CEP 4.2.0中Kalman Filter Extension的输入（命名：measuredValue，measuredChangingRate，measurementNoiseSD和timestamp）和输出（2个值）的信息 . 我找不到任何文件 . 我认为measuredValue是要过滤的值，timestamp是关于measuredValue获取瞬间的数字标签... -
1 votesanswersviews
wso2cep：错误 - 'distance'既不是函数扩展也不是执行计划“ExecutionPlan”中的聚合属性扩展
我正在使用WSO2 CEP 4.2.0版本，我正在编写一个执行计划，用于通过Siddhi查询检查来自不同传感器的坐标何时变化不超过4米 . 但是得到一个错误：'distance'既不是函数扩展，也不是执行计划“ExecutionPlan”中的聚合属性扩展 . 我已经安装了GPL - Siddhi Geo Extension，但我不知道为什么会出现这个错误 . 请帮我解决这个错误 . 我的执行计... -
0 votesanswersviews
尝试WSO2 CEP入门示例时出现SQL语法错误
是W2 CEP的新手，并试图运行Wso2 CEP文档中给出的样本 . 我实际上是按照入门指南，几乎完成所有步骤而没有任何问题 . 但是在创建个性化仪表板的同时坚持最后一步 . 我使用Oracle数据库作为我的数据源，并且在创建仪表板时能够引用在CEP中创建的数据源，并且连接已成功验证 . 但是当我输入我的sql“select * from delivered_orders”并运行它时会给出一个错误... -
0 votesanswersviews
在Windows中的WSO2 CEP快速入门指南中尝试添加配置设置时，如何修复路径中的非法字符？
我正在尝试在WSO2 CEP执行管理器中添加配置设置，作为“Quick Start Guide " describes, but it won't be saved and browser says:"保存配置时出错”的步骤12.4 . 正如_2786150中所强调的那样，XML文件中错误配置的路径可能会导致这种情况 . 我猜是真的原因吗？我该如何解决这个问题？ -
1 votesanswersviews
MQTT连接到ActiveMQ TOPIC在WSO2 CEP的事件接收器中花费了大量时间
Update 在碳分析的共同项目MQTTAdapterListener的源代码中link run() 将睡眠线程，我相信这就是MQTT连接需要这么长时间的原因 . @Override public void run() { while (!connectionSucceeded) { try { MQTTEventAdapterConstants.i... -
0 votesanswersviews
将WSO2 CEP连接到WSO2 Message Broker的异常
我正在尝试将WSO2 CEP服务器连接到WSO2 Message Broker服务器 . 我创建了一个jndi.properties文件： connectionfactory.TopicConnectionFactory = amqp://admin:admin@clientid/carbon?brokerlist='tcp://192.168.11.2:5673' topic.testTopic... -
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
WSO2 CEP，创建扩展功能
我正在尝试为cep创建一个新的扩展函数以获得时差，我正在使用cep 3.1版 . 我正在扩展类“FunctionExecutor”并覆盖函数“execute（Object [] data）”但我不知道如何在执行计划中的siddhi查询和创建的函数之间进行链接 . 顺便说一句，我不能使用注释，因为我找不到类“org.wso2.siddhi.query.api.extension.annotation... -
2 votesanswersviews
将新用户添加到H2数据库中的Wso2 CEP中
我需要在Wso2 CEP（3.1.0）中添加新用户，我知道可以通过“单击”控制台中的几个步骤（文档中的示例）来实现 . 我想知道是否可以在没有登录到控制台的情况下添加新用户，但是连接到H2数据库并在那里插入用户？ 我知道新用户将保存到“UM_USER”表中 . 也许有人知道什么类将用户写入H2，如何加入passowrd以及什么是“UM_SALT_VALUE”以及为什么需要它？ -
0 votesanswersviews
无法在WSO2 CEP中创建JMS接收器
我正在使用WSO2 CEP v4.1.0 . 我已经创建了1个JMS接收器并且工作正常，然后我尝试添加另一个JMS接收器，然后CEP给出了一个错误消息警报，但没有在控制台中打印任何碳控制台消息 . 这是WSO2 CEP的错误吗？ 错误消息屏幕上限如下 重现问题的步骤 - 1.使用以下详细信息创建新的JMS接收器（上面的图像，错误消息显示填充的数据 . ） 输入事件适配器类型-JMS 主题... -
0 votesanswersviews
Siddhi编写自定义聚合函数
我正在siddhi中构建一个自定义聚合函数，我对于官方文档有疑问，放在https://docs.wso2.com/display/CEP420/Writing+a+Custom+Aggregate+Function 在示例中，它创建了一个聚合函数扩展，其中 custom 作为命名空间， std 作为函数名称“，所以我的第一个问题是，为什么然后，当它从siddhi调用函数时，它使用： from pi...