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

熱線電話:13121318867

登錄
首頁精彩閱讀大數(shù)據(jù)量快速處理的架構(gòu)設(shè)計(jì)
大數(shù)據(jù)量快速處理的架構(gòu)設(shè)計(jì)
2017-12-27
收藏

大數(shù)據(jù)量快速處理的架構(gòu)設(shè)計(jì)

在業(yè)務(wù)數(shù)據(jù)的處理過程中,經(jīng)常會(huì)遇到夜間批次處理大量的數(shù)據(jù),而且會(huì)有時(shí)效的要求。特別是當(dāng)應(yīng)用系統(tǒng)跑了2年以上時(shí),就會(huì)有大表或者特大表的操作了,數(shù)據(jù)量達(dá)到百萬甚至上億。 這時(shí)回顧前期的設(shè)計(jì),就會(huì)發(fā)現(xiàn)好多問題。 可能是數(shù)據(jù)模型設(shè)計(jì)的時(shí)候沒有考慮表的分區(qū)和及時(shí)歸檔、sql的設(shè)計(jì)沒有考慮索引或全表掃描、數(shù)據(jù)的處理沒有考慮及時(shí)的分批切分、并發(fā)處理的多線程可配置化等等, 為了以后的設(shè)計(jì)不要走相同的錯(cuò)路。這里暫時(shí)簡(jiǎn)要總結(jié)一下。


1 最初要考慮歸檔和分區(qū)。所有可能的大表設(shè)計(jì),都要在最初的時(shí)候考慮歸檔和分區(qū)。

數(shù)據(jù)沖上高水位(HighWaterMark)后,即使有歸檔也不會(huì)降低高水位,性能可能也存在消耗,所以要及時(shí)歸檔轉(zhuǎn)移數(shù)據(jù)。 最好是設(shè)置分區(qū)表,這樣分區(qū)表可以進(jìn)行及時(shí)的truncate或者drop再重新add分區(qū)。 可以靈活的控制存儲(chǔ)。

2 sql條件精準(zhǔn)定位。大的關(guān)聯(lián)sql查詢,一定要盡量的精準(zhǔn)抽取數(shù)據(jù)范圍,不要模糊抽取過多數(shù)據(jù),含好多無用的后面再過濾,這很可能影響數(shù)據(jù)庫的執(zhí)行計(jì)劃判斷導(dǎo)致性能下降。

3 快速定位數(shù)據(jù),分批支持流水并發(fā)。大批量數(shù)據(jù)處理,首先要用最簡(jiǎn)單的方式找到目標(biāo)最小集群的數(shù)據(jù),從大范圍中抽出來,并進(jìn)行切分。切分的目的是可以使用多線程并發(fā)處理數(shù)據(jù),并且隔離各分區(qū)的數(shù)據(jù)不會(huì)重復(fù),也不能有遺漏,這樣并發(fā)時(shí)不會(huì)造成數(shù)據(jù)干擾。

4 流水線并發(fā)處理提升時(shí)效。

采用3的切分多批+多線程并發(fā)的方式,就可以針對(duì)有多個(gè)步驟的業(yè)務(wù)邏輯處理時(shí),不用瀑布模式等待執(zhí)行,而是可以流水線樣的多條執(zhí)行,實(shí)現(xiàn)了多并發(fā),無時(shí)間和空間的浪費(fèi)。 對(duì)于有高時(shí)效的任務(wù)處理,具有可觀的價(jià)值。


數(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); }