怎么在CDP上使用NiFi、Kafka和HBase構(gòu)建可擴(kuò)展流程

本篇內(nèi)容介紹了“怎么在CDP上使用NiFi、Kafka和HBase構(gòu)建可擴(kuò)展流程”的有關(guān)知識，在實(shí)際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

十多年的新興網(wǎng)站建設(shè)經(jīng)驗(yàn)，針對設(shè)計(jì)、前端、開發(fā)、售后、文案、推廣等六對一服務(wù)，響應(yīng)快，48小時及時工作處理。營銷型網(wǎng)站的優(yōu)勢是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同，自動調(diào)整新興建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì)，從而大程度地提升瀏覽體驗(yàn)。創(chuàng)新互聯(lián)建站從事“新興網(wǎng)站設(shè)計(jì)”,“新興網(wǎng)站推廣”以來，每個客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。

Navistar 是全球領(lǐng)先的商用卡車制造商。擁有350,000輛車的車隊(duì)，計(jì)劃外的維護(hù)和車輛故障會造成業(yè)務(wù)持續(xù)中斷。Navistar需要一個診斷平臺，該平臺將幫助他們預(yù)測何時需要維修車輛從而最大程度地減少停機(jī)時間。這個平臺需要能夠收集、分析和服務(wù)來自車隊(duì)中每輛車的70多種遠(yuǎn)程信息處理和傳感器數(shù)據(jù)饋送，包括測量發(fā)動機(jī)性能、冷卻液溫度、卡車速度和制動器磨損的數(shù)據(jù)。Navistar求助于Cloudera，以幫助構(gòu)建名為OnCommand?Connection的IoT的遠(yuǎn)程診斷平臺，以監(jiān)控其車輛的健康狀況并增加車輛的正常運(yùn)行時間。

該博客演示了如何使用類似技術(shù)來解決范圍更小的問題，但與Navistar面臨的問題類似。數(shù)據(jù)是從經(jīng)過高度修改的高性能Corvette（請參見圖1）中提取的，顯示了從外部源加載數(shù)據(jù)，使用 Apache NiFi 對其進(jìn)行格式化，通過 Apache Kafka 將其推送到流源以及使用以下方法存儲數(shù)據(jù)的步驟。并使用 Apache HBase 進(jìn)行有關(guān)的其他分析。

怎么在CDP上使用NiFi、Kafka和HBase構(gòu)建可擴(kuò)展流程

圖 1. 2008 年克爾維特（ Corvette ）與改進(jìn)的 6.8 升發(fā)動機(jī)

對于此特定示例，所討論的Corvette已更換了所有原始的原廠發(fā)動機(jī)組件，而采用了性能更高的零件。發(fā)動機(jī)被拆下，殼體打孔，更換了曲軸和凸輪軸，并安裝了新的活塞和連桿，力爭達(dá)到約600馬力的目標(biāo)（見圖2）。為了使新的引擎配置正常運(yùn)行，引擎的軟件進(jìn)行了全面檢修。當(dāng)按下油門變得更加劇烈時，意想不到的結(jié)果是該車的原始診斷和錯誤系統(tǒng)不再準(zhǔn)確，因此必須禁用。

圖 2. 使用所有新的閃亮內(nèi)部零件進(jìn)行引擎中間重建

為了捕獲和分析Corvette的傳感器數(shù)據(jù)，需要一條路徑，使數(shù)據(jù)從汽車流入替代的分析和診斷平臺。第一步是將便攜式計(jì)算機(jī)連接到Corvette的診斷端口（參見圖3），以將傳感器數(shù)據(jù)導(dǎo)入基于云的存儲位置。S3用于該項(xiàng)目。