基于InfoSphere Streams的流數(shù)據(jù)分析及應(yīng)用.pdf

1、當(dāng)前，一種被稱為流數(shù)據(jù)的新數(shù)據(jù)形態(tài)在越來(lái)越多的應(yīng)用領(lǐng)域內(nèi)出現(xiàn)，與傳統(tǒng)的靜態(tài)數(shù)據(jù)不同，流數(shù)據(jù)具有持續(xù)性、海量性、高時(shí)效性的特點(diǎn)。若使用傳統(tǒng)數(shù)據(jù)處理方法則會(huì)導(dǎo)致處理延遲太高無(wú)法滿足實(shí)時(shí)性的要求，同時(shí)嘗試將分布式計(jì)算引入流數(shù)據(jù)處理領(lǐng)域也是不可行的，需要尋找一種新的數(shù)據(jù)處理方法來(lái)支持流數(shù)據(jù)的處理，這種方法就是流計(jì)算。
　　現(xiàn)在對(duì)智能交通領(lǐng)域的海量實(shí)時(shí)流數(shù)據(jù)的處理還主要采用的是傳統(tǒng)數(shù)據(jù)處理方法，這已經(jīng)逐漸無(wú)法滿足現(xiàn)實(shí)需要。本文提出了一種將流

2、計(jì)算和流計(jì)算平臺(tái)引入智能交通領(lǐng)域的海量實(shí)時(shí)流數(shù)據(jù)處理的方案，提高處理速度，降低處理延遲，以滿足日漸增長(zhǎng)的實(shí)時(shí)性要求。并深入分析了流計(jì)算和InfoSphere Streams平臺(tái)的工作原理，在此基礎(chǔ)上設(shè)計(jì)并實(shí)現(xiàn)了基于InfoSphere Streams的實(shí)時(shí)路況監(jiān)測(cè)系統(tǒng)。
　　為了驗(yàn)證新方案的優(yōu)勢(shì)，在本文的研究工作中，分別使用傳統(tǒng)數(shù)據(jù)處理方法、單條流水線的流計(jì)算方法和多流水線的流計(jì)算方法實(shí)現(xiàn)相同業(yè)務(wù)功能的應(yīng)用，并對(duì)三個(gè)案例的實(shí)際性能