99999久久久久久亚洲,欧美人与禽猛交狂配,高清日韩av在线影院,一个人在线高清免费观看,啦啦啦在线视频免费观看www

熱線電話：13121318867

登錄
首頁精彩閱讀大數(shù)據(jù)的思維、思考和思路
大數(shù)據(jù)的思維、思考和思路
2017-11-01
收藏

大數(shù)據(jù)的思維、思考和思路

真正搞大數(shù)據(jù)的可能在于思維的變化，用數(shù)據(jù)來思考，用數(shù)據(jù)來做決定。

1、最早的數(shù)據(jù)分析可能就報(bào)表

目前很多數(shù)據(jù)分析后的結(jié)果，展示的形式很多，有各種圖形以及報(bào)表，最早的應(yīng)該是簡(jiǎn)單的幾條數(shù)據(jù)，然后搞個(gè)web頁面，展示一下數(shù)據(jù)。早期可能數(shù)據(jù)量也不大，隨便搞個(gè)數(shù)據(jù)庫，然后SQL搞一下，數(shù)據(jù)報(bào)表就出來了。但是數(shù)據(jù)量大起來怎么分析呢？數(shù)據(jù)分析完了怎么做傳輸呢？這么大的數(shù)據(jù)量怎么做到實(shí)時(shí)呢？分析的結(jié)果數(shù)據(jù)如果不是很大還行，如果分析的結(jié)果數(shù)據(jù)還是很大改怎么辦呢？這些問題在這篇文章中都能找到答案，下面各個(gè)擊破。

2、要做數(shù)據(jù)分析，首先要有數(shù)據(jù)

這個(gè)標(biāo)題感覺有點(diǎn)廢話，不過要做飯需要食材一樣。有些數(shù)據(jù)時(shí)業(yè)務(wù)積累的，像交易訂單的數(shù)據(jù)，每一筆交易都會(huì)有一筆訂單，之后再對(duì)訂單數(shù)據(jù)作分析。但是有些場(chǎng)景下，數(shù)據(jù)沒法考業(yè)務(wù)積累，需要依賴于外部，這個(gè)時(shí)候外部如果有現(xiàn)成的數(shù)據(jù)最好了，直接join過來，但是有時(shí)候是需要自己獲取的，例如搞個(gè)爬蟲爬取網(wǎng)頁的數(shù)據(jù)，有時(shí)候單臺(tái)機(jī)器搞爬蟲可能還爬不完，這個(gè)時(shí)候可能就開始考慮單機(jī)多線程爬取或者分布式多線程爬取數(shù)據(jù)，中間涉及到一個(gè)步驟，就是在線的業(yè)務(wù)數(shù)據(jù)，需要每天晚上導(dǎo)入到離線的系統(tǒng)中，之后才可以進(jìn)行分析。

3、有了數(shù)據(jù)，咋分析呢？

先將數(shù)據(jù)量小的情況下，可能一個(gè)復(fù)雜的SQL就可以搞出來，之后搞個(gè)web服務(wù)器，頁面請(qǐng)求的時(shí)候，執(zhí)行這個(gè)SQL，然后展示數(shù)據(jù)，好了，一個(gè)最簡(jiǎn)單的數(shù)據(jù)分析，嚴(yán)格意義上講是統(tǒng)計(jì)的分析。這種情況下，分析的數(shù)據(jù)源小，分析的腳本就是在線執(zhí)行的SQL，分析的結(jié)果不用傳輸，結(jié)果的展示就在頁面上，整個(gè)流程一條龍。

4、數(shù)據(jù)量大了，無法在線分析了，咋辦呢？

這個(gè)時(shí)候，數(shù)據(jù)量已經(jīng)大的無法用在線執(zhí)行SQL的形式進(jìn)行統(tǒng)計(jì)分析了。這個(gè)時(shí)候順應(yīng)時(shí)代的東西產(chǎn)生了（當(dāng)然還有其他的，我就知道這個(gè)呵呵），數(shù)據(jù)離線數(shù)據(jù)工具h(yuǎn)adoop出來了。這個(gè)時(shí)候，你的數(shù)據(jù)以文件的形式存在，可能各個(gè)屬性是逗號(hào)分隔的，數(shù)據(jù)條數(shù)有十幾個(gè)億。這時(shí)候你可能需要構(gòu)建一個(gè)hadoop集群，然后把自己的文件導(dǎo)入到集群上面去，上了集群之后，文件就是HDFS的格式了，然后如果要做統(tǒng)計(jì)分析，需要寫mapreduce程序，所謂的mapreduce程序，就是實(shí)現(xiàn)map和reduce的接口，按照自己的業(yè)務(wù)邏輯寫分析流程，之后把程序打成jar包上傳到集群，之后開始執(zhí)行。分析后的結(jié)果還是文件的形式產(chǎn)生。

5、分析個(gè)數(shù)據(jù)還要寫java代碼是不是效率低了點(diǎn)

這個(gè)確實(shí)是，mapreduce的程序，本身的可測(cè)性沒有執(zhí)行一個(gè)簡(jiǎn)單的單元測(cè)試來的爽，所以效率確實(shí)不高。這個(gè)時(shí)候，hive出現(xiàn)了，hive是一個(gè)數(shù)據(jù)倉庫分析的語言，語法類似于數(shù)據(jù)庫的SQL，但是有幾個(gè)地方是不同的。有了hive之后，數(shù)據(jù)分析就好之前寫SQL一樣了，按照邏輯編寫hiveSQL，然后控制臺(tái)執(zhí)行?？赡茏畲蟮母杏X是，數(shù)據(jù)庫的sql很快就能有結(jié)果，但是hive的，即使很小的一個(gè)數(shù)據(jù)分析，也需要幾分鐘時(shí)間。構(gòu)建hive，需要在hadoop的集群上，原理很簡(jiǎn)單，就是把文件構(gòu)建成表的形式（有一個(gè)數(shù)據(jù)庫或者內(nèi)存數(shù)據(jù)庫維護(hù)表的schema信息），之后提交寫好的hivesql的時(shí)候，hadoop集群里面的程序把hive腳本轉(zhuǎn)換成對(duì)應(yīng)的mapreduce程序執(zhí)行。這個(gè)時(shí)候，做離線的數(shù)據(jù)分析簡(jiǎn)單寫腳本就行了，不用再搞java代碼，然后上傳執(zhí)行了。

6、數(shù)據(jù)產(chǎn)生的結(jié)果，怎么搞到線上提供服務(wù)的數(shù)據(jù)庫中呢？

這個(gè)時(shí)候分析的結(jié)果有了，可能是一個(gè)很寬很長的excel表格，需要導(dǎo)入到線上的數(shù)據(jù)庫中，可能你想到了，如果我的數(shù)據(jù)庫是mysql，我直接執(zhí)行l(wèi)oad命令就搞進(jìn)去了，哪有那么麻煩。但是數(shù)據(jù)源可能有多了，mysql/oracle/hbase/hdfs按照笛卡爾積的形式，這樣搞要搞死程序員了。這個(gè)時(shí)候datax（已經(jīng)開源）出現(xiàn)了，能夠?qū)崿F(xiàn)異構(gòu)數(shù)據(jù)源的導(dǎo)入和導(dǎo)出，采用插件的形式設(shè)計(jì)，能夠支持未來的數(shù)據(jù)源。如果需要導(dǎo)數(shù)據(jù)，配置一下datax的xml文件或者在web頁面上點(diǎn)擊下就可以實(shí)現(xiàn)了。

7、離線分析有時(shí)間差，實(shí)時(shí)的話怎么搞呢？

要建實(shí)時(shí)的分析系統(tǒng)，其實(shí)在結(jié)果數(shù)據(jù)出來之前，架構(gòu)和離線是截然不同的。數(shù)據(jù)時(shí)流動(dòng)的，如果在大并發(fā)海量數(shù)據(jù)流動(dòng)過程中，進(jìn)行自己的業(yè)務(wù)分析呢？這里其實(shí)說簡(jiǎn)單也簡(jiǎn)單，說復(fù)雜也復(fù)雜。目前我接觸過的，方案是這樣的，業(yè)務(wù)數(shù)據(jù)在寫入數(shù)據(jù)庫的時(shí)候，這里的數(shù)據(jù)庫mysql，在數(shù)據(jù)庫的機(jī)器上安裝一個(gè)程序，類似JMS的系統(tǒng)，用于監(jiān)聽binlog的變更，收到日志信息，將日志信息轉(zhuǎn)換為具體的數(shù)據(jù)，然后以消息的形式發(fā)送出來。這個(gè)時(shí)候?qū)崿F(xiàn)了解耦，這樣的處理并不影響正常的業(yè)務(wù)流程。這個(gè)時(shí)候需要有個(gè)Storm集群，storm集群干啥事情呢？就一件事情，分析數(shù)據(jù)，這個(gè)集群來接收剛才提到的JMS系統(tǒng)發(fā)送出來的消息，然后按照指定的規(guī)則進(jìn)行邏輯合并等計(jì)算，把計(jì)算的結(jié)果保存在數(shù)據(jù)庫中，這樣的話，流動(dòng)的數(shù)據(jù)就可以過一遍篩子了。

8、分析的結(jié)果數(shù)據(jù)特別大，在線請(qǐng)求這些結(jié)果數(shù)據(jù)數(shù)據(jù)扛不住了，咋搞？

一般的結(jié)果數(shù)據(jù)，數(shù)據(jù)量沒有那么大，也就幾十萬的樣子，這樣的數(shù)據(jù)級(jí)別，對(duì)于mysql這樣的數(shù)據(jù)庫沒有任何壓力，但是這個(gè)數(shù)據(jù)量如果增加到千萬或者億級(jí)別，同時(shí)有復(fù)雜的SQL查詢，這個(gè)時(shí)候mysql肯定就扛不住了。這個(gè)時(shí)候，可能需要構(gòu)建索引（例如通過lucene來對(duì)于要檢索的字段添加索引），或者用分布式的內(nèi)存服務(wù)器來完成查詢?？傊瑑商姿悸?，一個(gè)是用文件索引的形式，說白來就是空間換時(shí)間，另外一種是用內(nèi)存，就是用更快的存儲(chǔ)來抗請(qǐng)求。

9、在線的數(shù)據(jù)庫，除了mysql、oracle之外，還有其他選擇不？

其實(shí)目前大家的思維定勢(shì)，往往第一個(gè)選擇就是oracle或者mysql，其實(shí)完全可以根據(jù)場(chǎng)景來進(jìn)行選擇，mysql和oracle是傳統(tǒng)的關(guān)系型數(shù)據(jù)庫，目前nosql類的數(shù)據(jù)庫也很多，例如HBase就是其中一個(gè)重要的代表。如果數(shù)據(jù)離散分布比較強(qiáng)，且根據(jù)特定的key來查詢，這個(gè)時(shí)候HBase其實(shí)是一個(gè)不錯(cuò)的選擇。

10、空間的數(shù)據(jù)怎么分析

上面的分析大都是統(tǒng)計(jì)維度的，其實(shí)最簡(jiǎn)單的描述就是求和或者平均值等，這個(gè)時(shí)候問題來了，大數(shù)據(jù)量的空間數(shù)據(jù)如何分析呢？對(duì)于我們電子商務(wù)而言，空間數(shù)據(jù)可能就是海量的收貨地址數(shù)據(jù)了。需要做分析，第一步就是先要把經(jīng)緯度添加到數(shù)據(jù)中（如果添加經(jīng)緯度，這個(gè)可以搞http的請(qǐng)求來通過地圖服務(wù)提供商來或者，或者是根據(jù)測(cè)繪公司的基礎(chǔ)數(shù)據(jù)來進(jìn)行文本切割分析），之后空間數(shù)據(jù)是二維的，但是我們常見的代數(shù)是一維的，這個(gè)時(shí)候一個(gè)重要的算法出現(xiàn)了，geohash算法，一種將經(jīng)緯度數(shù)據(jù)轉(zhuǎn)換為一個(gè)可比較，可排序的字符串的算法。然后，這樣就可以再空間距離方面進(jìn)行分析了，例如遠(yuǎn)近，例如方圓周邊等數(shù)據(jù)的分析。

11、上面這些僅僅是統(tǒng)計(jì)，如果想搞算法或者挖掘之類的，怎么搞呢

上述的分析，大多數(shù)是統(tǒng)計(jì)分析，這個(gè)時(shí)候如果想高一點(diǎn)高級(jí)的，例如添加一個(gè)算法，咋搞呢？其他復(fù)雜的算法我沒咋接觸過。將拿一個(gè)我練過手的算法來講吧。邏輯回歸，如果樣本數(shù)據(jù)量不是很大，可以采用weka來做了個(gè)回歸，獲得一個(gè)表達(dá)式，然后在線上系統(tǒng)中應(yīng)用這個(gè)表達(dá)式，這種類似的表達(dá)式獲取對(duì)于實(shí)時(shí)性要求不是很高，所以公式每天跑一次就行了。如果數(shù)據(jù)量比較大，單機(jī)的weka無法滿足需求了，可以將weka的jar包集成在系統(tǒng)中分析，當(dāng)然也可以通過hadoop中的mahout來進(jìn)行離線分析，獲取這個(gè)表達(dá)式。

12、我就是想離線分析數(shù)據(jù)，但是受不了hive或者h(yuǎn)adoop的速度，咋搞

其實(shí)搞過一段時(shí)間hadoop的人肯定有一點(diǎn)不爽，就是離線分析的速度太慢了，可能需要等很久，這個(gè)時(shí)候spark出現(xiàn)了，他和hadoop類似，不過由于是內(nèi)存中計(jì)算，所以速度快了很多，底層可以介入HDFS的文件系統(tǒng)，具體我沒有使用過，但是公司內(nèi)部一個(gè)團(tuán)隊(duì)目前已經(jīng)用spark來進(jìn)行分析了。

13、這就是搞大數(shù)據(jù)了？

有了這些工具就是搞大數(shù)據(jù)了？答案肯定不是，這個(gè)僅僅是工具罷了。真正搞大數(shù)據(jù)的可能在于思維的變化，用數(shù)據(jù)來思考，用數(shù)據(jù)來做決定。目前的無線和大數(shù)據(jù)啥關(guān)系？我覺得無線的終端是數(shù)據(jù)的來源和消費(fèi)端，中間需要大數(shù)據(jù)的分析，兩者密不可分啊。


數(shù)據(jù)分析咨詢請(qǐng)掃描二維碼

若不方便掃碼，搜微信號(hào)：CDAshujufenxi

數(shù)據(jù)分析師資訊
更多

OK
客服在線
立即咨詢
客服在線
立即咨詢
') } function initGt() { var handler = function (captchaObj) { captchaObj.appendTo('#captcha'); captchaObj.onReady(function () { $("#wait").hide(); }).onSuccess(function(){ $('.getcheckcode').removeClass('dis'); $('.getcheckcode').trigger('click'); }); window.captchaObj = captchaObj; }; $('#captcha').show(); $.ajax({ url: "/login/gtstart?t=" + (new Date()).getTime(), // 加隨機(jī)數(shù)防止緩存 type: "get", dataType: "json", success: function (data) { $('#text').hide(); $('#wait').show(); // 調(diào)用 initGeetest 進(jìn)行初始化 // 參數(shù)1：配置參數(shù) // 參數(shù)2：回調(diào)，回調(diào)的第一個(gè)參數(shù)驗(yàn)證碼對(duì)象，之后可以使用它調(diào)用相應(yīng)的接口 initGeetest({ // 以下 4 個(gè)配置參數(shù)為必須，不能缺少 gt: data.gt, challenge: data.challenge, offline: !data.success, // 表示用戶后臺(tái)檢測(cè)極驗(yàn)服務(wù)器是否宕機(jī) new_captcha: data.new_captcha, // 用于宕機(jī)時(shí)表示是新驗(yàn)證碼的宕機(jī) product: "float", // 產(chǎn)品形式，包括：float，popup width: "280px", https: true // 更多配置參數(shù)說明請(qǐng)參見：http://docs.geetest.com/install/client/web-front/ }, handler); } }); } function codeCutdown() { if(_wait == 0){ //倒計(jì)時(shí)完成 $(".getcheckcode").removeClass('dis').html("重新獲取"); }else{ $(".getcheckcode").addClass('dis').html("重新獲取("+_wait+"s)"); _wait--; setTimeout(function () { codeCutdown(); },1000); } } function inputValidate(ele,telInput) { var oInput = ele; var inputVal = oInput.val(); var oType = ele.attr('data-type'); var oEtag = $('#etag').val(); var oErr = oInput.closest('.form_box').next('.err_txt'); var empTxt = '請(qǐng)輸入'+oInput.attr('placeholder')+'！'; var errTxt = '請(qǐng)輸入正確的'+oInput.attr('placeholder')+'！'; var pattern; if(inputVal==""){ if(!telInput){ errFun(oErr,empTxt); } return false; }else { switch (oType){ case 'login_mobile': pattern = /^1[3456789]\d{9}$/; if(inputVal.length==11) { $.ajax({ url: '/login/checkmobile', type: "post", dataType: "json", data: { mobile: inputVal, etag: oEtag, page_ur: window.location.href, page_referer: document.referrer }, success: function (data) { } }); } break; case 'login_yzm': pattern = /^\d{6}$/; break; } if(oType=='login_mobile'){ } if(!!validateFun(pattern,inputVal)){ errFun(oErr,'') if(telInput){ $('.getcheckcode').removeClass('dis'); } }else { if(!telInput) { errFun(oErr, errTxt); }else { $('.getcheckcode').addClass('dis'); } return false; } } return true; } function errFun(obj,msg) { obj.html(msg); if(msg==''){ $('.login_submit').removeClass('dis'); }else { $('.login_submit').addClass('dis'); } } function validateFun(pat,val) { return pat.test(val); }