近日，百度云天工物聯(lián)網(wǎng)場(chǎng)景正式推出流式計算服務(wù)，填補了規則引擎、函數計算等只能針對單個(gè)數據流、單個(gè)消息處理的局限性。

流式計算服務(wù)的推出，意味著(zhù)用戶(hù)在物聯(lián)網(wǎng)場(chǎng)景中可利用流式計算服務(wù)對單個(gè)數據流的前后多個(gè)消息，或者多個(gè)數據流之間進(jìn)行聚合計算。?通過(guò)流式計算的聚合運算能力，比如求平均、和、最大值、最小值等，可以關(guān)聯(lián)分析多個(gè)流之間的聯(lián)系等。接下來(lái)，讓我們通過(guò)具體案例來(lái)了解下流式計算的作用。?? ? ? ?以某煙草公司為例，其擁有1000多個(gè)烤煙房，每個(gè)烤煙房通過(guò)一個(gè)物解析網(wǎng)關(guān)，每分鐘采集一次烤煙房的溫度、濕度等數據，報送到云端，以實(shí)時(shí)監控烤煙房?jì)炔繙貪穸仁欠裾?。通過(guò)為每一個(gè)烤煙房建立一條告警，設定越限條件，當該烤煙房的溫濕度越限，則觸發(fā)短信告警。?不過(guò)這種解決方案有個(gè)先決條件，即：網(wǎng)關(guān)總是能正常地上報數據。但是，導致網(wǎng)關(guān)無(wú)法上報數據的內外在因素存在很多，比如供電故障、設備故障、網(wǎng)絡(luò )信號差、環(huán)境溫度過(guò)高等等，這些因素都有可能導致網(wǎng)關(guān)意外停止工作。?? ? ?設計流式計算監控。針對這種情況，流式計算就可以派上大用場(chǎng)，可以巧妙利用流式計算的窗口和時(shí)間概念，設計出流式監控，可以實(shí)現一個(gè)任務(wù)就監控上述1000多個(gè)設備，并且可以實(shí)時(shí)、準確報告具體哪個(gè)網(wǎng)關(guān)在什么時(shí)候停止了數據的上報；而增加網(wǎng)關(guān)設備時(shí)，無(wú)需修改任務(wù)。??? ? ? 具體解決辦法。在物解析的輪詢(xún)請求設置中，設置網(wǎng)關(guān)對Modbus設備的采集周期為60秒，并且每個(gè)解析項目解析后的數據轉到統一的物接入主題：/modbus/parsed；隨后在流式計算中創(chuàng )建名為:device_offine_monitor_src的數據源，數據源的物接入主題即來(lái)自上面解析后的主題：/modbus/parsed；流式計算任務(wù)中使用的時(shí)間類(lèi)型為PROCESSTIME，可以實(shí)現即便監控一個(gè)設備，也照樣工作；當流式計算任務(wù)中的會(huì )話(huà)窗口一直有數據流進(jìn)來(lái)時(shí)，窗口始終不會(huì )關(guān)閉，不會(huì )觸發(fā)告警；而當一旦某個(gè)設備在規定時(shí)間內沒(méi)有數據流進(jìn)來(lái)，則對應的會(huì )話(huà)窗口就會(huì )關(guān)閉，并輸出一條信息，觸發(fā)告警。?? ? ? 比如，會(huì )話(huà)窗口選擇了65秒。理想情況下，只要60秒沒(méi)有收到消，即認為網(wǎng)關(guān)故障，考慮到網(wǎng)絡(luò )傳輸可能導致的延遲，增加了5秒的等待時(shí)間，以免因細小的傳輸延遲導致誤報。

百度云天工推出流式計算服務(wù)，全面支持數據流由東莞網(wǎng)站設計編輯 http://www.futanlvdanban.cn/gy/news/9202.html如需轉載請注明出處

東莞做網(wǎng)站 東莞小程序開(kāi)發(fā) 東莞小程序商城開(kāi)發(fā) 東莞建站費用 東莞網(wǎng)絡(luò )推廣 東莞網(wǎng)頁(yè)設計 東莞小程序制作 東莞建網(wǎng)站 門(mén)戶(hù)網(wǎng)站建設 河源網(wǎng)站建設 商城網(wǎng)站建設 深圳網(wǎng)站建設 珠海網(wǎng)站建設 惠州網(wǎng)站建設 專(zhuān)業(yè)網(wǎng)站建設 陽(yáng)江網(wǎng)站建設 免費網(wǎng)站建設 單頁(yè)網(wǎng)站建設 SEO外包 網(wǎng)站托管 關(guān)鍵詞優(yōu)化