電信行業海量實時數據技術架構_第1頁
電信行業海量實時數據技術架構_第2頁
電信行業海量實時數據技術架構_第3頁
電信行業海量實時數據技術架構_第4頁
電信行業海量實時數據技術架構_第5頁
已閱讀5頁，還剩17頁未讀， 繼續免費閱讀

下載本文檔

版權說明：本文檔由用戶提供并上傳，收益歸屬內容提供方，若內容存在侵權，請進行舉報或認領

文檔簡介

1、面向電信領域的海量實時數據技術與實踐目錄CONTENTCONTENT01電信領域實時數據處理場景1324每天凈增用戶16.6萬每秒無線上網流量33G每天話單數據10T每日信令數據100T電信領域實時數據處理場景2014簡單實時營銷2015+實時位置運營2016+復雜實時營銷+內容業務處理CONTENT02Patent US 1242872實時處理平臺基本架構業務輸出標簽附加數據接入平臺架構數據接入flumeagent 12，3G位置信令flume agent2，3，44G位置信令flume agent 5內容信令 Kafka分區靈活的數據源轉換Kafkatransformtransformtr

2、ansformSchema 2Schema 3SelectFilterSelect Expr 1 主被叫imsiFilter Expr 1 imsi！=0Select Expr 2Filter Expr 2Select Expr 3Filter Expr 3SelectFilterSelectFilterUniformSchema 18個字段附加標簽流程復雜計算簡單查詢Codis所在區域駐留時間往來頻次用戶姓名imsi手機號碼基站位置并發業務輸出CodisKafka標簽增強數據其他業務輸出用戶實時位置統計更換設備信息推送新辦卡信息推送實時旅游信息推送易用的業務定制標簽增強數據處理結束Check

3、IntervalFilterSelectOutputCodis平臺架構插件SDTP Socket SourceHDFS I/OCodis I/O系統I/O可視化配置界面自勱化部署部署/配置 實時處理平臺 CONTENT03性能表現平行擴展flumeflumeflumeflumeflumeCodisCodisCodis標簽附加Spark數據接入kafKaSpark業務輸出KafkaSpark性能表現平行擴展圖一 測試環境Spark Streaming執行時間圖二 任務詳細執行時間性能表現速度場景30s數據量Spark集群Codis集群KafkaPartition業務數量案例160萬條20/128G/32 core10/128G2003案例21000萬條28/512G/64 core10/512G120011附加標簽（與Codis交互）附加標簽（計算）業務輸出案例一 5秒0.5秒3秒1秒1.5秒數據轉換1秒11秒3秒2秒案例二 17秒性能表現HAHA ProxyFlume AgentFlume AgentCodis HACodis ProxyCodis ProxyCONTENT04演進方向更多元化的場景同時支持Spark streaming，Storm等主流計算引擎以支持不同的需求 支持啟勱多個實時處理作業，將每個作業的結果納入事

溫馨提示

  • 1. 本站所有資源如無特殊說明，都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
  • 2. 本站的文檔不包含任何第三方提供的附件圖紙等，如果需要附件，請聯系上傳者。文件的所有權益歸上傳用戶所有。
  • 3. 本站RAR壓縮包中若帶圖紙，網頁內容里面會有圖紙預覽，若沒有圖紙預覽就沒有圖紙。
  • 4. 未經權益所有人同意不得將文件中的內容挪作商業或盈利用途。
  • 5. 人人文庫網僅提供信息存儲空間，僅對用戶上傳內容的表現方式做保護處理，對用戶上傳分享的文檔內容本身不做任何修改或編輯，并不能對任何下載內容負責。
  • 6. 下載文件中如有侵權或不適當內容，請與我們聯系，我們立即糾正。
  • 7. 本站不保證下載資源的準確性、安全性和完整性, 同時也不承擔用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。

評論

0/150

提交評論