百度云天工推出流式計(jì)算服務(wù)，全面支持?jǐn)?shù)據(jù)流實(shí)時(shí)處理

2015-03-13    分類(lèi)： 網(wǎng)站建設(shè)

近日，百度云天工物聯(lián)網(wǎng)場(chǎng)景正式推出流式計(jì)算服務(wù)，填補(bǔ)了規(guī)則引擎、函數(shù)計(jì)算等只能針對(duì)單個(gè)數(shù)據(jù)流、單個(gè)消息處理的局限性。流式計(jì)算服務(wù)的推出，意味著用戶(hù)在物聯(lián)網(wǎng)場(chǎng)景中可利用流式計(jì)算服務(wù)對(duì)單個(gè)數(shù)據(jù)流的前后多個(gè)消息，或者多個(gè)數(shù)據(jù)流之間進(jìn)行聚合計(jì)算。

通過(guò)流式計(jì)算的聚合運(yùn)算能力，比如求平均、和、大值、最小值等，可以關(guān)聯(lián)分析多個(gè)流之間的聯(lián)系等。接下來(lái)，讓我們通過(guò)具體案例來(lái)了解下流式計(jì)算的作用。

以某煙草公司為例，其擁有1000多個(gè)烤煙房，每個(gè)烤煙房通過(guò)一個(gè)物解析網(wǎng)關(guān)，每分鐘采集一次烤煙房的溫度、濕度等數(shù)據(jù)，報(bào)送到云端，以實(shí)時(shí)監(jiān)控烤煙房?jī)?nèi)部溫濕度是否正常。通過(guò)為每一個(gè)烤煙房建立一條告警，設(shè)定越限條件，當(dāng)該烤煙房的溫濕度越限，則觸發(fā)短信告警。

不過(guò)這種解決方案有個(gè)先決條件，即：網(wǎng)關(guān)總是能正常地上報(bào)數(shù)據(jù)。但是，導(dǎo)致網(wǎng)關(guān)無(wú)法上報(bào)數(shù)據(jù)的內(nèi)外在因素存在很多，比如供電故障、設(shè)備故障、網(wǎng)絡(luò)信號(hào)差、環(huán)境溫度過(guò)高等等，這些因素都有可能導(dǎo)致網(wǎng)關(guān)意外停止工作。

設(shè)計(jì)流式計(jì)算監(jiān)控。針對(duì)這種情況，流式計(jì)算就可以派上大用場(chǎng)，可以巧妙利用流式計(jì)算的窗口和時(shí)間概念，設(shè)計(jì)出流式監(jiān)控，可以實(shí)現(xiàn)一個(gè)任務(wù)就監(jiān)控上述1000多個(gè)設(shè)備，并且可以實(shí)時(shí)、準(zhǔn)確報(bào)告具體哪個(gè)網(wǎng)關(guān)在什么時(shí)候停止了數(shù)據(jù)的上報(bào)；而增加網(wǎng)關(guān)設(shè)備時(shí)，無(wú)需修改任務(wù)。

具體解決辦法。在物解析的輪詢(xún)請(qǐng)求設(shè)置中，設(shè)置網(wǎng)關(guān)對(duì)Modbus設(shè)備的采集周期為60秒，并且每個(gè)解析項(xiàng)目解析后的數(shù)據(jù)轉(zhuǎn)到統(tǒng)一的物接入主題：/modbus/parsed；隨后在流式計(jì)算中創(chuàng)建名為:device_offine_monitor_src的數(shù)據(jù)源，數(shù)據(jù)源的物接入主題即來(lái)自上面解析后的主題：/modbus/parsed；流式計(jì)算任務(wù)中使用的時(shí)間類(lèi)型為PROCESSTIME，可以實(shí)現(xiàn)即便監(jiān)控一個(gè)設(shè)備，也照樣工作；當(dāng)流式計(jì)算任務(wù)中的會(huì)話(huà)窗口一直有數(shù)據(jù)流進(jìn)來(lái)時(shí)，窗口始終不會(huì)關(guān)閉，不會(huì)觸發(fā)告警；而當(dāng)一旦某個(gè)設(shè)備在規(guī)定時(shí)間內(nèi)沒(méi)有數(shù)據(jù)流進(jìn)來(lái)，則對(duì)應(yīng)的會(huì)話(huà)窗口就會(huì)關(guān)閉，并輸出一條信息，觸發(fā)告警。

比如，會(huì)話(huà)窗口選擇了65秒。理想情況下，只要60秒沒(méi)有收到消，即認(rèn)為網(wǎng)關(guān)故障，考慮到網(wǎng)絡(luò)傳輸可能導(dǎo)致的延遲，增加了5秒的等待時(shí)間，以免因細(xì)小的傳輸延遲導(dǎo)致誤報(bào)。

分享標(biāo)題：百度云天工推出流式計(jì)算服務(wù)，全面支持?jǐn)?shù)據(jù)流實(shí)時(shí)處理
文章起源：http://www.bm7419.com/news43/33943.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、手機(jī)網(wǎng)站建設(shè)、面包屑導(dǎo)航、網(wǎng)站制作、做網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

成都app開(kāi)發(fā)公司