r语言 - 使用终端将参数传递给 Rserve



我有一个R代码,它有一个经过训练的机器学习模型。现在我想获得对新数据的预测。

当前方法:

Script code.R '[{"x1" : "1011", "x2" : "1031", "x4" : "0.65"}]'

我会得到答案,问题是加载和设置环境花费了太多时间

法典:

# Loading the library
suppressPackageStartupMessages(library(C50))
suppressPackageStartupMessages(library(jsonlite))
suppressPackageStartupMessages(library(plyr))
# Loading the trained model
model1 <- readRDS("model1.RDA")
 x <- (args[1])
# Function which wraps prediction and son handling
output <- function(x) {
df <- fromJSON(x)
df[is.na(df)] <- 0
prediction <- predict.C5.0(model1, newdata = df, type = "class")
json_df <- toJSON(prediction)
return(json_df)
}
 output(x)

问题:

  • 我想使用 Rserve 并将参数传递给它,我无法想办法?我应该进行哪些修改?

  • 我知道添加库(Rserve),然后运行。Rserve() 但超越我不知道怎么做?

所以我

正在使用NodeJS与Rserve交谈。

首先从终端安装节点和 npm。

npm install --save rserve-client

javascript 文件中的代码是:

var r = require('rserve-client');
r.connect('localhost', 6311, function(err, client) {
    client.evaluate('a<-2.7+2', function(err, ans) {
        console.log(ans);
        client.end();
    });
});
  • 观察节点正在端口"6311"(Rserve的默认值)上通信

  • 部分"a<-2.7+2"是发送到R的内容,修改此部分

如果你想

使用Java客户端,你需要下载REngine jars,下面的代码会有所帮助(我从Java使用):

import org.rosuda.REngine.*;
import org.rosuda.REngine.Rserve.*;
import java.util.Arrays;
public class RServeCommunication {
    public static void main(String[] args) {
      try {
        // Setup the connection with RServer through RServe
        RConnection rConnection = new RConnection("127.0.0.1", 6311); 
        // Call R function 
        REXP retValues = rConnection.eval("rnorm(10)");
        // print the values returned to console
        System.out.println(Arrays.toString(retValues.asDoubles()));
        // [1.4280800442888217, -0.11989685521338722, 0.6836180891125788, 0.7913069852336285, -0.8968664915403061, 0.0681405000990237, -0.08726481416189025, -0.5322959519563994, -0.3302662744787598, 0.45030516965234024]
      }
      catch (REngineException e) {
        System.out.println("Error: " + e.toString());
      }
      catch (REXPMismatchException e) {
        System.out.println("Error: " + e.toString());
      }
    } 
}

相关内容

  • 没有找到相关文章

最新更新