使用 spring-xd 中的分析模块创建流失败

stream creation with analytic module in spring-xd get failed

我正在开发 spring-xd 框架。我正在关注 Spring-XD 指南分析选项卡,并希望为实时流数据部署我的预测模型。

我在 R 中使用朴素贝叶斯构建了鸢尾花分类模型,并将该 pmml 文件存储在我桌面上的 Ubuntu-14.0.4 Lts 中。这是我的流定义-

stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy
.

错误:- 找不到分析和处理器模块。

我认为我的流定义有误。因为我无法在 spring-xd 指南中找到这种情况的流定义。

我 运行 spring-xd 在我本地机器的单节点中。我不想使用 Http,而是想使用 MQTT Pub-Sub 协议发送我的数据。我的 MQTT 代理已启动并且 运行,我们将不胜感激任何形式的帮助。多谢。

IIRC,由于许可问题,它没有随 XD 开箱即用地分发。

您可以 find it on github here 和 build/install 自己。