您可以通过以下步骤快速发布流数据服务(Streaming Service):
- 在服务管理“首页”点击“快速发布”或在“服务-服务管理”页面,点击“快速创建服务”,进入发布向导
- 选择数据源为"流处理模型",点击“下一步”;
- 进行服务信息配置
- 指定服务名;
- 选择配置信息来源,iServer 提供了“配置信息”和“配置文件”两种方式。
- 配置信息:输入流处理模型中的全部内容
- 配置文件:点击“选择”,选择后缀为 .streaming 的流处理模型文件
- 根据需要确定是否启用 Token。启用时,需输入用于验证用户身份的 Token(令牌)。
- 根据需要选择是否创建数据流服务。如选择创建,则应输入数据流服务名称,分析处理后的数据将通过数据流服务在服务器与客户端之间实时传输;
- 选择发布的服务类型“流数据服务”,点击“下一步”;
- 无需进行服务配置,点击“发布”按钮完成发布流程;
- 发布完成后,可以看到当前发布的服务名和链接,点击可直接访问服务。进入发布的服务的订阅界面,点击订阅,若显示订阅成功且订阅框中有 feature 返回,则表示服务发布成功。
注:
1.数据流服务名,必需和 streaming 文件中 path 地址中的服务名一致,下图中红色框内的字符为数据流服务名称。
2.如果 streaming 文件关联了本机的某份文件(如csv文件),需要将文件地址,改为绝对路径。
常见问题及解决方法:
1.点击订阅按钮,显示订阅成功,但订阅框未返回数据。
原因: spark 的 Running Applications 中仅允许一个 Application 处于运行状态。
解决方法:打开 spark 地址,检查进程。
常见情况:
-
Running Application 中没有 Application。刷新服务订阅页面,重新点击订阅。若重新订阅后依然没有 Application,请重启 iServer,再次在服务订阅界面中点击订阅。
-
Running Application 中有 2 个 Application, 一个为 waiting 状态,一个为 running 状态。可能是上次服务订阅还未停止,导致本次不能订阅。此时结束以前未停止的处于 running 状态的的 Application,处于 waiting 状态的 Application 将自动会变成 running 状态。
-
Running Applications 中仅有一个 Application 处于 running 状态,但依然未返回数据。请检查 spark 日志,查看是否报错。检查日志步骤:点击 Application 的名称,进入页面 -> 点击 stderr 进入 -> load new 更新日志。如 Spark 日志中有报错信息,请根据报错信息进行修改。
2.如何修改 streaming 的配置信息?
解决方法:
-
在本地上传的文件中直接修改
-
在服务管理界面找到流数据服务,点击进入管理界面,在配置信息框中直接进行修改。(注意,在未做任何修改的情况下,请勿点击保存,该操作将会清空配置信息)
3.如何配置字段?
在 【iServer 安装目录】\webapps\iserver\WEB-INF 文件夹下找到 iserver-dataflow.xml 文件,将 streaming 文件中的字段信息,复制到此文件中。
配置成功后,可在页面上看到字段信息。