StreamPipes物联网实时计算平台本地部署与扩展实践

功能菜单一：资产

资产和站点为 StreamPipes 提供工业背景。它们允许您将机器、生产线、站点和工厂描述为现实世界的对象，然后将适配器、数据集、图表、仪表板和管道连接到这些对象。

如果没有这一层，许多资源在技术上仍然正确，但在实际运行中却彼此孤立。有了这一层，StreamPipes 作为工业数据平台的使用就更加便捷，因为用户可以从他们关注的机器或生产线直接跳转到属于该机器或生产线的资源。

1、新建资产

• 点击新建资产按钮

• 输入资产信息

• 创建

• 添加子资产

• 保存

功能菜单二：连接器

连接器将外部机器和软件接口转换为结构化的 StreamPipes 数据流。用户无需为每个数据源构建自定义数据摄取服务，即可直接在用户界面中配置适配器并将结果发布到平台。

1、新建适配器（以读取文件示例）

• 点击新建适配器按钮

• 选择文件流适配器创

• 假设我们有一个 CSV 文件（temperature.csv），其中包含来自温度传感器的数据，该传感器每秒记录一次数据：

• 设置适配器属性，下一步

• 配置字段（设置时间戳字段），之后点击下一步

• 设置适配器名称，描述，暂时不立即启动适配器，可添加到我们刚刚创建的资产中，之后点击启动适配器

• 启动适配器

• 单机适配器可以查看适配器获取的数据

功能菜单三：数据管道

在 StreamPipes 中，管道是连接数据转化为操作逻辑的关键所在。它允许您获取一个或多个实时数据流，将其与处理器和接收器组合，并将该数据流转化为有用的功能：过滤、丰富、告警、路由、存储或分析。

管道模块使用一组可扩展的组件（Extensions例如数据处理器和数据接收器），并允许用户基于实时数据流定义流处理逻辑。

1、新建流水线

• 点击新建流水线按钮

• 添加数据流（将数据流拖拽到画板中）

• 启用实时预览，可以实时查看数据流接收的数据

• 添加数据接收器（以接收数据到iotdb为示例）

• 连接数据流和数据接收器

• 设置数据接收器属性

• 保存设置

• 保存流水线

• 应用

• 点击 Open pipeline overview，创建完成

• 启动流水线

• 启动完成，可以配置数据集，然后配置图表查看我们存储的数据

功能菜单四：数据集

StreamPipes 中的数据集存储的是运行数据。它标志着实时机器事件不再仅仅是瞬态流流量，而是成为用户可以稍后查看、在图表中分析、在仪表板中重用、导出到其他系统以及进行长期管理的数据。

这使得数据集成为平台架构的重要组成部分。适配器和管道生成动态数据，而数据集则表示静态数据。如果您需要进行历史分析、审计、导出或基于图表的探索，通常最终都需要使用数据集。

1、数据集列表

功能菜单五：图表视图

图表将持久化的工业数据转化为用户可读可操作的信息。在 StreamPipes 中，图表首先使用现有数据集，将其转换为查询结果，然后以与分析问题相匹配的可视化方式呈现该结果。

1、新建图表

• 点击新建图表按钮

• 选中我们刚刚添加的数据集，此刻可以看到数据

• 命名图表，保存

功能菜单六：仪表盘

仪表盘将各个图表整合为一个共享的操作视图。仪表盘可以重用您已创建的图表Charts，并将它们排列在一个屏幕上，用于监控、分析或演示。

这种设计之所以重要，是因为它明确了职责划分。图表可以很好地回答一个分析问题，而仪表盘则可以整合多个问题的答案，使用户能够一目了然地了解一台机器、一条生产线或整个流程。