一般來(lai)說(shuo),物聯網(wang)物聯傳輸處理(li)過程,首先要(yao)(yao)進行數據(ju)接收,也就是將采集的(de)數據(ju)進行匯總,再(zai)進行數據(ju)傳輸,到中央處理(li)系統(tong)(通(tong)常指服務器),再(zai)通(tong)過數據(ju)存儲、分析(xi)、加工(gong),再(zai)將需要(yao)(yao)的(de)結果(guo),通(tong)過應用程序反向設備發送相關操作指令。
一(yi)、批(pi)處理
批處(chu)(chu)理的(de)(de)(de)方(fang)法就是隔一(yi)(yi)段(duan)時(shi)(shi)間(jian)就分批次(ci)的(de)(de)(de)處(chu)(chu)理一(yi)(yi)次(ci)積攢的(de)(de)(de)數(shu)(shu)(shu)據(ju)(ju)。一(yi)(yi)般情(qing)況下先把(ba)數(shu)(shu)(shu)據(ju)(ju)存(cun)入數(shu)(shu)(shu)據(ju)(ju)庫(ku)里,隔一(yi)(yi)段(duan)時(shi)(shi)間(jian)就從數(shu)(shu)(shu)據(ju)(ju)庫(ku)里獲(huo)取,執行處(chu)(chu)理。這種方(fang)式適(shi)用于不(bu)需(xu)要(yao)緊(jin)急處(chu)(chu)理的(de)(de)(de)工作(zuo)環境,比(bi)如氣象溫度(du)、濕(shi)度(du)、風向數(shu)(shu)(shu)據(ju)(ju),冰箱及空(kong)調等(deng)相關數(shu)(shu)(shu)據(ju)(ju),城市監控等(deng)數(shu)(shu)(shu)據(ju)(ju)。批處(chu)(chu)理需(xu)要(yao)在規定的(de)(de)(de)時(shi)(shi)間(jian)內處(chu)(chu)理規定范(fan)圍的(de)(de)(de)數(shu)(shu)(shu)據(ju)(ju),因此數(shu)(shu)(shu)據(ju)(ju)量(liang)越多,執行處(chu)(chu)理數(shu)(shu)(shu)據(ju)(ju)的(de)(de)(de)服務器就要(yao)求性(xing)能越好(hao)。
隨著物聯網設備的(de)逐(zhu)漸(jian)增多,人們(men)需要處(chu)理的(de)數據(ju)(ju)(ju)(ju)量(liang)也越來越大(da),人們(men)處(chu)理這些龐大(da)的(de)設備量(liang)得到(dao)的(de)圖像(xiang)、聲音及各種(zhong)傳感器獲得的(de)數據(ju)(ju)(ju)(ju),進行(xing)存取、分(fen)析、處(chu)理并得到(dao)所需數據(ju)(ju)(ju)(ju),就(jiu)是大(da)數據(ju)(ju)(ju)(ju)的(de)應用了。一般大(da)數據(ju)(ju)(ju)(ju)都(dou)需要用到(dao)分(fen)布(bu)式數據(ju)(ju)(ju)(ju)處(chu)理方式及數據(ju)(ju)(ju)(ju)庫(ku)。分(fen)布(bu)式數據(ju)(ju)(ju)(ju)處(chu)理平臺主要有:、Apache Spark、Redis數據(ju)(ju)(ju)(ju)庫(ku)、Mongodb數據(ju)(ju)(ju)(ju)庫(ku)、Elasticsearch數據(ju)(ju)(ju)(ju)庫(ku)等。
二、流(liu)處理(li)
流處理的方式(shi),是(shi)不保存所有數(shu)據(ju),只搜集需要而且(qie)有用的數(shu)據(ju),其它數(shu)據(ju)都會(hui)直接被丟棄。比如我只想做一個溫度預(yu)警(jing)(jing)的消防(fang)裝置,雖然(ran)溫度傳感器(qi)在實時監測溫度數(shu)據(ju),但是(shi)只要沒有超(chao)過我的預(yu)設(she)值,數(shu)據(ju)都是(shi)直接丟棄不用的。只有超(chao)過預(yu)設(she)值(比如我可以設(she)置3個數(shu)值),才會(hui)向(xiang)數(shu)據(ju)庫存儲,并且(qie)通過服務器(qi)進行(xing)分析,然(ran)后做出相應的反應。比如是(shi)有消防(fang)警(jing)(jing)示,或者啟動滅火設(she)備等。
批處(chu)理(li)是把(ba)數(shu)據(ju)攢起來,一段時間一次性處(chu)理(li)的方法(fa)。而流處(chu)理(li),是不保存數(shu)據(ju),按照(zhao)數(shu)據(ju)流的順序(xu)依次進行處(chu)理(li)。就是沒用(yong)的丟(diu)棄,沒用(yong)的繼(ji)續(xu)丟(diu)棄,有用(yong)的直接存儲。
想(xiang)實時(shi)(shi)對(dui)數據做出反應的時(shi)(shi)候,流處理(li)就是一個很有效的處理(li)方法(fa)。可以減少(shao)數據的存儲和提升效率。