►顶部微信名片可直接添加市场总监，商务咨询、方案沟通即时响应
►点击链接了解详情，马上加入开源社区获取资源
https://docs.qq.com/doc/DVnhVemtBTHdDVHps

AllData数据中台通过开源项目Apache StreamPipes，重磅发布物联网实时平台。Apache StreamPipes是一个面向工业物联网的开源数据平台，帮助团队搭建可扩展的本地环境，用于连接机器和软件系统，将传入事件转换为可重用的数据流，实时处理这些数据流，持久化历史数据，并在此基础上构建图表和仪表盘。

对于开发人员而言，StreamPipes提供接口以使用自定义插件扩展软件，并提供客户端库以编程方式与资源交互。

需要理解的最重要的一点是，StreamPipes不仅仅是一个用于处理特定数据任务的便捷用户界面，还可以作为团队自主运行的开源物联网和工业数据基础设施的基础。

StreamPipes开源项目：https://github.com/apache/streampipes
StreamPipes官方文档：https://streampipes.apache.org/docs

该平台也特意设计成可扩展的。团队可以从内置功能入手，然后根据公司特定的基础架构或领域逻辑需求，添加自定义适配器、处理器、接收器或用户界面扩展。

功能菜单一：资产

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

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

1、新建资产

• 点击新建资产按钮

• 输入资产信息

• 创建

• 添加子资产

• 保存

功能菜单二：连接器

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

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

• 点击新建适配器按钮

• 选择文件流适配器创建

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

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

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

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

• 启动适配器

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

功能菜单三：数据管道

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

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

1、新建流水线

• 点击新建流水线按钮

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

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

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

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

• 设置数据接收器属性

• 保存设置

• 保存流水线

• 应用

• 点击 Open pipeline overview，创建完成

• 启动流水线

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

功能菜单四：数据集

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

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

1、数据集列表

功能菜单五：图表视图

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

1、新建图表

• 点击新建图表按钮

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

• 命名图表，保存

功能菜单六：仪表盘

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

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

1、工业制造场景
车间设备实时状态监控、产线良率实时统计、设备故障实时预警、生产时序数据分析、产线能耗实时监测，助力生产提质降本。

2、能源管控场景
电厂、光伏、水务、油气设备实时数据采集、能耗智能统计、设备异常监测、能源数据复盘分析，实现能源精细化管控。

3、智慧城市场景
安防、交通、市政、环境设备海量实时数据流处理，统一数据治理、统一监控预警，支撑城市智慧化运维管理。