ETL如何進(jìn)行數(shù)據(jù)的清洗轉(zhuǎn)換？

數(shù)據(jù)的清洗轉(zhuǎn)換是指將抽取到的數(shù)據(jù)源表中的數(shù)據(jù)，根據(jù)數(shù)據(jù)倉(cāng)庫(kù)系統(tǒng)模型的要求進(jìn)行數(shù)據(jù)的清洗、轉(zhuǎn)換等操作,保證來自不同系統(tǒng)、不同格式數(shù)據(jù)的一致性和完整性,并且要按照業(yè)務(wù)要求加載到目標(biāo)表。數(shù)據(jù)的清洗轉(zhuǎn)換是ETL中最復(fù)雜的部分，主要任務(wù)是過濾掉不符合要求的數(shù)據(jù)。不符合要求的數(shù)據(jù)主要是有不完整的數(shù)據(jù)、錯(cuò)誤的數(shù)據(jù)、重復(fù)的數(shù)據(jù)三大類。下面針對(duì)不符合要求的三大類數(shù)據(jù)進(jìn)行詳細(xì)介紹。

1.不完整的數(shù)據(jù)

數(shù)據(jù)上報(bào)、接口調(diào)用時(shí)都會(huì)產(chǎn)生大量的不完整數(shù)據(jù)，不完整數(shù)據(jù)的產(chǎn)生是不可避免的現(xiàn)象，而不完整的數(shù)據(jù)對(duì)大數(shù)據(jù)環(huán)境下的決策具有一定的影響。不完整數(shù)據(jù)主要包括缺失部分信息的數(shù)據(jù)。檢測(cè)不完整數(shù)據(jù)的方法具體如下。

缺失部分或全部?jī)?nèi)容的數(shù)據(jù)主要是采用計(jì)算機(jī)和人工相結(jié)合的方法進(jìn)行查找,并對(duì)缺失的內(nèi)容進(jìn)行填充處理。不完整數(shù)據(jù)的清洗流程如圖所示。

在上圖中，不完整數(shù)據(jù)的清洗流程主要分為3個(gè)步驟，具體如下。

(1)對(duì)獲得的數(shù)據(jù)源進(jìn)行不完整數(shù)據(jù)的檢測(cè)，為后續(xù)的數(shù)據(jù)處理提供所需的數(shù)據(jù)。

(2)對(duì)檢測(cè)出來的不完整數(shù)據(jù)進(jìn)行處理，如修復(fù)缺失部分或全部?jī)?nèi)容的數(shù)據(jù)。

(3)輸出處理后的符合要求的完整數(shù)據(jù)。

2. 錯(cuò)誤的數(shù)據(jù)

大數(shù)據(jù)環(huán)境下數(shù)據(jù)量的劇增使得獲取到的數(shù)據(jù)源會(huì)由于各種原因存在大量的錯(cuò)誤數(shù)據(jù)。

錯(cuò)誤數(shù)據(jù)產(chǎn)生的原因是業(yè)務(wù)系統(tǒng)不夠健全,在接收輸人數(shù)據(jù)后沒有進(jìn)行過濾判斷,而是直接將數(shù)據(jù)寫人后臺(tái)數(shù)據(jù)庫(kù)造成的，如數(shù)值數(shù)據(jù)輸成全角數(shù)字字符、字符串?dāng)?shù)據(jù)后面出現(xiàn)一個(gè)回車操作、日期格式不正確、日期越界等錯(cuò)誤。錯(cuò)誤數(shù)據(jù)的清洗流程如下圖所示。

在上圖中，錯(cuò)誤數(shù)據(jù)的清洗流程主要分為3個(gè)步驟，具體如下。

(1)將數(shù)據(jù)源按照規(guī)定的數(shù)據(jù)格式進(jìn)行檢測(cè),并執(zhí)行數(shù)據(jù)預(yù)處理，為后續(xù)的處理步驟做準(zhǔn)備。

(2)對(duì)預(yù)處理后的數(shù)據(jù)進(jìn)行一致性檢測(cè)，如果預(yù)處理后的數(shù)據(jù)與原始數(shù)據(jù)存在完整性不一致的問題，則通過數(shù)據(jù)修改過程使數(shù)據(jù)統(tǒng)一。為避免再次出現(xiàn)該問題，應(yīng)重復(fù)進(jìn)行檢測(cè)與修改過程，直到符合要求為止。

(3)輸出修改后的數(shù)據(jù)。

3.重復(fù)的數(shù)據(jù)

產(chǎn)生重復(fù)的數(shù)據(jù)原因較多，如數(shù)據(jù)集成、系統(tǒng)重復(fù)錄人等,通常表現(xiàn)為多條記錄表達(dá)的含義相同，或同一目標(biāo)實(shí)體的記錄雖然在形式上有所不同，但其描述的目標(biāo)卻相同。這些重復(fù)記錄的數(shù)據(jù)特征并不明顯,但是對(duì)數(shù)據(jù)識(shí)別和數(shù)據(jù)清洗造成了很大的難度。因此,對(duì)重復(fù)記錄數(shù)據(jù)進(jìn)行清洗，可以提高數(shù)據(jù)庫(kù)的使用率，降低系統(tǒng)消耗,并提高數(shù)據(jù)的質(zhì)量。

重復(fù)數(shù)據(jù)檢測(cè)主要分為基于字段和基于記錄的重復(fù)檢測(cè)?；谧侄蔚闹貜?fù)檢測(cè)算法主要為編輯距離算法基于記錄的重復(fù)檢測(cè)算法主要包括排序鄰居算法、優(yōu)先隊(duì)列算法、NGram聚類算法。采用排序合并算法清洗重復(fù)數(shù)據(jù)的流程如圖所示。

在圖中，重復(fù)數(shù)據(jù)的清洗流程主要分為4個(gè)步驟，具體如下。

(1)通過對(duì)源數(shù)據(jù)庫(kù)屬性段的分析,找到屬性的唯-值，并根據(jù)唯值對(duì)源 數(shù)據(jù)庫(kù)中的數(shù)據(jù)記錄進(jìn)行排序，可以選擇自上而下或者自下而上的順序排序。

(2)按順序掃描數(shù)據(jù)庫(kù)中的每一條記錄 ,并將它與相鄰的記錄進(jìn)行比較，進(jìn)行記錄的相似度匹配計(jì)算，輸出修改后的數(shù)據(jù)。

(3)如果計(jì)算出的相似度數(shù)值大于系統(tǒng)設(shè)定的閾值，說明該記錄或連續(xù)的幾條記錄為相似重復(fù)記錄，則進(jìn)行數(shù)據(jù)記錄的合并或刪除操作;否則掃描下一條數(shù)據(jù)記錄，重復(fù)以上第(2)、(3)步驟。

(4)當(dāng)所有數(shù)據(jù)記錄檢測(cè)完畢后，輸出清洗后的數(shù)據(jù)結(jié)果。

猜你喜歡：

Hadoop如何實(shí)現(xiàn)二次排序？

數(shù)據(jù)倉(cāng)庫(kù)的結(jié)構(gòu)詳細(xì)介紹

大數(shù)據(jù)Hadoop生態(tài)圈包含哪些子系統(tǒng)？

傳智教育高級(jí)python+大數(shù)據(jù)培訓(xùn)課程