一般來說,物聯(lián)網物聯(lián)傳輸處理過程,首先要進行數(shù)據接收,也就是將采集的數(shù)據進行匯總,再進行數(shù)據傳輸,到中央處理系統(tǒng)(通常指服務器),再通過數(shù)據存儲、分析、加工,再將需要的結果,通過應用程序反向設備發(fā)送相關操作指令。
一、批處理
批處理的方法就是隔一段時間就分批次的處理一次積攢的數(shù)據。一般情況下先把數(shù)據存入數(shù)據庫里,隔一段時間就從數(shù)據庫里獲取,執(zhí)行處理。這種方式適用于不需要緊急處理的工作環(huán)境,比如氣象溫度、濕度、風向數(shù)據,冰箱及空調等相關數(shù)據,城市監(jiān)控等數(shù)據。批處理需要在規(guī)定的時間內處理規(guī)定范圍的數(shù)據,因此數(shù)據量越多,執(zhí)行處理數(shù)據的服務器就要求性能越好。
隨著物聯(lián)網設備的逐漸增多,人們需要處理的數(shù)據量也越來越大,人們處理這些龐大的設備量得到的圖像、聲音及各種傳感器獲得的數(shù)據,進行存取、分析、處理并得到所需數(shù)據,就是大數(shù)據的應用了。一般大數(shù)據都需要用到分布式數(shù)據處理方式及數(shù)據庫。分布式數(shù)據處理平臺主要有:、Apache Spark、Redis數(shù)據庫、Mongodb數(shù)據庫、Elasticsearch數(shù)據庫等。
二、流處理
流處理的方式,是不保存所有數(shù)據,只搜集需要而且有用的數(shù)據,其它數(shù)據都會直接被丟棄。比如我只想做一個溫度預警的消防裝置,雖然溫度傳感器在實時監(jiān)測溫度數(shù)據,但是只要沒有超過我的預設值,數(shù)據都是直接丟棄不用的。只有超過預設值(比如我可以設置3個數(shù)值),才會向數(shù)據庫存儲,并且通過服務器進行分析,然后做出相應的反應。比如是有消防警示,或者啟動滅火設備等。
批處理是把數(shù)據攢起來,一段時間一次性處理的方法。而流處理,是不保存數(shù)據,按照數(shù)據流的順序依次進行處理。就是沒用的丟棄,沒用的繼續(xù)丟棄,有用的直接存儲。
想實時對數(shù)據做出反應的時候,流處理就是一個很有效的處理方法。可以減少數(shù)據的存儲和提升效率。