中國移動運營分析實時監控平臺之SparkStreaming實時數據分析並將最後結果存儲到redis中

業務概況 經過實時的分析用戶的流量數據，獲取用戶動態的充值的訂單量、充值全過程的平均時長、以及某段時間充值的成功率等。首先解析數據格式，從標籤體系庫中截取出須要的字段值，使用SparkStreaming的對抽取出來的屬性加以處理。 1）統計每一個市的充值失敗的次數，並以地圖的方式顯示數據的分佈狀況。 2）以市爲維度，統計訂單量排名前5的市，並統計每一個市的訂單的成功率。 3）實時統計全省的每分鐘的

>>阅读原文<<