►顶部微信名片可直接添加市场总监商务咨询、方案沟通即时响应►点击链接了解详情马上加入开源社区获取资源https://docs.qq.com/doc/DVnhVemtBTHdDVHpsAllData数据中台通过开源项目Apache StreamPipes重磅发布物联网实时平台。Apache StreamPipes是一个面向工业物联网的开源数据平台帮助团队搭建可扩展的本地环境用于连接机器和软件系统将传入事件转换为可重用的数据流实时处理这些数据流持久化历史数据并在此基础上构建图表和仪表盘。对于开发人员而言StreamPipes提供接口以使用自定义插件扩展软件并提供客户端库以编程方式与资源交互。需要理解的最重要的一点是StreamPipes不仅仅是一个用于处理特定数据任务的便捷用户界面还可以作为团队自主运行的开源物联网和工业数据基础设施的基础。StreamPipes开源项目https://github.com/apache/streampipesStreamPipes官方文档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、智慧城市场景安防、交通、市政、环境设备海量实时数据流处理统一数据治理、统一监控预警支撑城市智慧化运维管理。