r - 从 WSO2 调用 R 脚本 - 弥合松散的末端

Question

我希望从 WSO2 DAS 服务器调用我的 R 脚本。我在 siddhi 查询中编写了以下代码

@Plan:name('MyRPlan')

@Import('MyRStream:1.0.0')
define stream Rin (emplyId int);

@Export('MyRout:1.0.0')
define stream Rout (emplyId int);

from Rin#r:eval('/my/file/path/MyRFun.R', 'emplyId int', emplyId)
select *
insert into Rout;

我调用 R 脚本的语法是否正确？如果有人可以告诉我为什么我在 DAS 控制台中收到此错误错误消息。我还 根据 wso2 提供的链接在https://rforge.net/JRI/files/下载了 JRI 文件。

Answer 1

这不是由于语法错误，而是因为 JRI 配置不正确。请参阅有关集成 R 的 WSO2 CEP 文档，并确保您使用的是准确的版本 [1]。您可以尝试为 R 扩展 [2] 编写的几个测试用例。

[1] https://docs.wso2.com/display/CEP400/Installing+R+to+work+with+WSO2+CEP

[2] https://github.com/wso2-gpl/siddhi/blob/master/siddhi-extensions/r/src/test/java/org/wso2/siddhi/gpl/extension/r/RScriptTestCase.java