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