?頂部微信名片可直接添加市場(chǎng)總監(jiān)商務(wù)咨詢(xún)、方案溝通即時(shí)響應(yīng)?點(diǎn)擊鏈接了解詳情馬上加入開(kāi)源社區(qū)獲取資源https://docs.qq.com/doc/DVnhVemtBTHdDVHpsAllData數(shù)據(jù)中臺(tái)通過(guò)開(kāi)源項(xiàng)目Apache StreamPipes重磅發(fā)布物聯(lián)網(wǎng)實(shí)時(shí)平臺(tái)。Apache StreamPipes是一個(gè)面向工業(yè)物聯(lián)網(wǎng)的開(kāi)源數(shù)據(jù)平臺(tái)幫助團(tuán)隊(duì)搭建可擴(kuò)展的本地環(huán)境用于連接機(jī)器和軟件系統(tǒng)將傳入事件轉(zhuǎn)換為可重用的數(shù)據(jù)流實(shí)時(shí)處理這些數(shù)據(jù)流持久化歷史數(shù)據(jù)并在此基礎(chǔ)上構(gòu)建圖表和儀表盤(pán)。對(duì)于開(kāi)發(fā)人員而言StreamPipes提供接口以使用自定義插件擴(kuò)展軟件并提供客戶(hù)端庫(kù)以編程方式與資源交互。需要理解的最重要的一點(diǎn)是StreamPipes不僅僅是一個(gè)用于處理特定數(shù)據(jù)任務(wù)的便捷用戶(hù)界面還可以作為團(tuán)隊(duì)自主運(yùn)行的開(kāi)源物聯(lián)網(wǎng)和工業(yè)數(shù)據(jù)基礎(chǔ)設(shè)施的基礎(chǔ)。StreamPipes開(kāi)源項(xiàng)目https://github.com/apache/streampipesStreamPipes官方文檔https://streampipes.apache.org/docs該平臺(tái)也特意設(shè)計(jì)成可擴(kuò)展的。團(tuán)隊(duì)可以從內(nèi)置功能入手然后根據(jù)公司特定的基礎(chǔ)架構(gòu)或領(lǐng)域邏輯需求添加自定義適配器、處理器、接收器或用戶(hù)界面擴(kuò)展。功能菜單一資產(chǎn)資產(chǎn)和站點(diǎn)為 StreamPipes 提供工業(yè)背景。它們?cè)试S您將機(jī)器、生產(chǎn)線(xiàn)、站點(diǎn)和工廠(chǎng)描述為現(xiàn)實(shí)世界的對(duì)象然后將適配器、數(shù)據(jù)集、圖表、儀表板和管道連接到這些對(duì)象。如果沒(méi)有這一層許多資源在技術(shù)上仍然正確但在實(shí)際運(yùn)行中卻彼此孤立。有了這一層StreamPipes 作為工業(yè)數(shù)據(jù)平臺(tái)的使用就更加便捷因?yàn)橛脩?hù)可以從他們關(guān)注的機(jī)器或生產(chǎn)線(xiàn)直接跳轉(zhuǎn)到屬于該機(jī)器或生產(chǎn)線(xiàn)的資源。1、新建資產(chǎn)? 點(diǎn)擊新建資產(chǎn)按鈕? 輸入資產(chǎn)信息? 創(chuàng)建? 添加子資產(chǎn)? 保存功能菜單二連接器連接器將外部機(jī)器和軟件接口轉(zhuǎn)換為結(jié)構(gòu)化的 StreamPipes 數(shù)據(jù)流。用戶(hù)無(wú)需為每個(gè)數(shù)據(jù)源構(gòu)建自定義數(shù)據(jù)攝取服務(wù)即可直接在用戶(hù)界面中配置適配器并將結(jié)果發(fā)布到平臺(tái)。1、新建適配器以讀取文件示例? 點(diǎn)擊新建適配器按鈕? 選擇文件流適配器創(chuàng)建? 假設(shè)我們有一個(gè) CSV 文件temperature.csv其中包含來(lái)自溫度傳感器的數(shù)據(jù)該傳感器每秒記錄一次數(shù)據(jù)? 設(shè)置適配器屬性下一步? 配置字段設(shè)置時(shí)間戳字段之后點(diǎn)擊下一步? 設(shè)置適配器名稱(chēng)描述暫時(shí)不立即啟動(dòng)適配器可添加到我們剛剛創(chuàng)建的資產(chǎn)中之后點(diǎn)擊啟動(dòng)適配器? 啟動(dòng)適配器? 單機(jī)適配器可以查看適配器獲取的數(shù)據(jù)功能菜單三數(shù)據(jù)管道在 StreamPipes 中管道是連接數(shù)據(jù)轉(zhuǎn)化為操作邏輯的關(guān)鍵所在。它允許您獲取一個(gè)或多個(gè)實(shí)時(shí)數(shù)據(jù)流將其與處理器和接收器組合并將該數(shù)據(jù)流轉(zhuǎn)化為有用的功能過(guò)濾、豐富、告警、路由、存儲(chǔ)或分析。管道模塊使用一組可擴(kuò)展的組件Extensions例如數(shù)據(jù)處理器和數(shù)據(jù)接收器并允許用戶(hù)基于實(shí)時(shí)數(shù)據(jù)流定義流處理邏輯。1、新建流水線(xiàn)? 點(diǎn)擊新建流水線(xiàn)按鈕? 添加數(shù)據(jù)流將數(shù)據(jù)流拖拽到畫(huà)板中? 啟用實(shí)時(shí)預(yù)覽可以實(shí)時(shí)查看數(shù)據(jù)流接收的數(shù)據(jù)? 添加數(shù)據(jù)接收器以接收數(shù)據(jù)到iotdb為示例? 連接數(shù)據(jù)流和數(shù)據(jù)接收器? 設(shè)置數(shù)據(jù)接收器屬性? 保存設(shè)置? 保存流水線(xiàn)? 應(yīng)用? 點(diǎn)擊 Open pipeline overview創(chuàng)建完成? 啟動(dòng)流水線(xiàn)? 啟動(dòng)完成可以配置數(shù)據(jù)集然后配置圖表查看我們存儲(chǔ)的數(shù)據(jù)功能菜單四數(shù)據(jù)集StreamPipes 中的數(shù)據(jù)集存儲(chǔ)的是運(yùn)行數(shù)據(jù)。它標(biāo)志著實(shí)時(shí)機(jī)器事件不再僅僅是瞬態(tài)流流量而是成為用戶(hù)可以稍后查看、在圖表中分析、在儀表板中重用、導(dǎo)出到其他系統(tǒng)以及進(jìn)行長(zhǎng)期管理的數(shù)據(jù)。這使得數(shù)據(jù)集成為平臺(tái)架構(gòu)的重要組成部分。適配器和管道生成動(dòng)態(tài)數(shù)據(jù)而數(shù)據(jù)集則表示靜態(tài)數(shù)據(jù)。如果您需要進(jìn)行歷史分析、審計(jì)、導(dǎo)出或基于圖表的探索通常最終都需要使用數(shù)據(jù)集。1、數(shù)據(jù)集列表功能菜單五圖表視圖圖表將持久化的工業(yè)數(shù)據(jù)轉(zhuǎn)化為用戶(hù)可讀可操作的信息。在 StreamPipes 中圖表首先使用現(xiàn)有數(shù)據(jù)集將其轉(zhuǎn)換為查詢(xún)結(jié)果然后以與分析問(wèn)題相匹配的可視化方式呈現(xiàn)該結(jié)果。1、新建圖表? 點(diǎn)擊新建圖表按鈕? 選中我們剛剛添加的數(shù)據(jù)集此刻可以看到數(shù)據(jù)? 命名圖表保存功能菜單六儀表盤(pán)儀表盤(pán)將各個(gè)圖表整合為一個(gè)共享的操作視圖。儀表盤(pán)可以重用您已創(chuàng)建的圖表Charts并將它們排列在一個(gè)屏幕上用于監(jiān)控、分析或演示。這種設(shè)計(jì)之所以重要是因?yàn)樗鞔_了職責(zé)劃分。圖表可以很好地回答一個(gè)分析問(wèn)題而儀表盤(pán)則可以整合多個(gè)問(wèn)題的答案使用戶(hù)能夠一目了然地了解一臺(tái)機(jī)器、一條生產(chǎn)線(xiàn)或整個(gè)流程。1、工業(yè)制造場(chǎng)景車(chē)間設(shè)備實(shí)時(shí)狀態(tài)監(jiān)控、產(chǎn)線(xiàn)良率實(shí)時(shí)統(tǒng)計(jì)、設(shè)備故障實(shí)時(shí)預(yù)警、生產(chǎn)時(shí)序數(shù)據(jù)分析、產(chǎn)線(xiàn)能耗實(shí)時(shí)監(jiān)測(cè)助力生產(chǎn)提質(zhì)降本。2、能源管控場(chǎng)景電廠(chǎng)、光伏、水務(wù)、油氣設(shè)備實(shí)時(shí)數(shù)據(jù)采集、能耗智能統(tǒng)計(jì)、設(shè)備異常監(jiān)測(cè)、能源數(shù)據(jù)復(fù)盤(pán)分析實(shí)現(xiàn)能源精細(xì)化管控。3、智慧城市場(chǎng)景安防、交通、市政、環(huán)境設(shè)備海量實(shí)時(shí)數(shù)據(jù)流處理統(tǒng)一數(shù)據(jù)治理、統(tǒng)一監(jiān)控預(yù)警支撐城市智慧化運(yùn)維管理。