作為推送行業領導者，截止目前個推SDK累計安裝覆蓋量達100億（含海外），接入應用超過43萬，獨立終端覆蓋超過10億 （含海外）。個推系統每天會產生大量的日志和數據，面臨許多數據處理方面的挑戰。

首先數據存儲方面，個推每天產生10TB以上的數據，并且累積數據已在PB級別。其次，作為推送技術服務商，個推有很多來自客戶和公司各部門的數據分析和統計需求，例如：消息推送技術和數據報表。雖然部分數據分析工作是離線模式，但開源數據處理系統穩定性并不很高，保障數據分析服務的高可用性也是一個挑戰。另外，推送業務并不是單純的消息下發，它需幫助客戶通過數據分析把合適的內容在合適的場景送達給合適的人,這要求系統支持數據挖掘，并保證數據實時性。最后，個推要求快速響應數據分析需求。因此，個推大數據系統面臨著數據存儲、日志傳輸、日志分析處理、大量任務調度和管理、數據分析處理服務高可用、海量多維度報表和快速響應分析和取數需求等方面的挑戰。

大數據系統演進之路

面臨諸多挑戰，個推大數據系統在逐步發展中不斷完善。其發展可分為三個階段。一是統計報表，即傳統意義的BI；二是大數據系統的基礎建設階段；三是工具、服務和產品化。

個推大數據系統演進第一階段：統計報表計算

早期由于數據處理無太復雜的需求，個推選擇幾臺高性能的機器，把所有數據分別放在這些機器上計算。只需在機器上多進程運行PHP或Shell腳本即可完成處理和統計。數據處理更多關注客戶今天推送多少條消息，某個推送任務有多少回執等，執行相對較簡單的報表。

此階段個推大數據系統的特點是，只需運維定時腳本傳輸到指定中間節點；用戶雖然有億級別但日志種類較單一；只需使用PHP、Shell腳本來運行和數據只需短期保存（結果集長期保存、中間數據和原始數據保存很短時間）。

個推大數據系統演進第二階段：大數據基礎建設，離線批處理系統

2014年個推推出智能推送解決方案。用戶體量大的明星App接入，系統覆蓋用戶數爆增。且客戶接入個推系統后，提出了很多新的需求如：報表統計維度更豐富，它要求在數據量翻倍的情況下進行更復雜的計算，計算壓力增大。其次，智能推送本質是數據深度挖掘，數據保存周期越長，覆蓋維度越多越好。

這樣的情況下，個推引進Hadoop生態體系，用HDFS基本解決存儲的問題，使用Hive做數據倉庫和離線分析,并且使用Mahout做機器學習。個推完成了由單機或多機模式向集群方向的轉變。整個運轉流程和原來類似，差別在于將日志傳輸到中轉節點之后，使用hdfs命令put數據到hdfs，并添加hive表分區，然后對日志做進一步的處理，導入到數據倉儲里去。最后個推對數據倉庫中數據進行挖掘，給用戶打標簽，入庫到HBase和線上ES等。這是離線批處理系統的基本建設。

個推大數據系統演進第二階段：大數據基礎建設，實時處理系統

隨著業務不斷發展，需求也相應增加。如很多統計分析任務提出了要求在T+0的時間內滿足，或者客戶上午推送的消息，下午要求給到反映推送效果的數據報表，而不能等到T+1的時間，這些需求都對數據處理實時性提出了更高要求。而且很多客戶會提出要檢索一些數據，或查看某種標簽相關數據，這類取數需要快速響應。于是個推對原有的架構進行了一些調整，引入了一個主要包含離線處理、實時處理和數據服務（包含檢索）的架構模式。

從上方看，原有的數據存到HDFS，使用Spark，MR等進行離線批處理。引入Kafka來解決日志收集問題，用Flume收集各個業務節點的日志，并寫入到Kafka集群，再依照業務的分級進行小時級別和秒級別處理。最終個推會落地一份數據，將它同步給業務線的DB或ES中使用。

基礎建設階段個推完成幾項工作：采用Lambda架構（Batch Layer、Speed Layer、ServingLayer）；引入Hadoop（Hdfs、Hive/MR、Hbase、Mahout等）；采用ES、SolrCloud+ HBase方案 實現多維度檢索；引入Flume 、Kafka、Camus和優化改造日志傳輸和引入和優化國產開源的Redis集群方案-Codis 。

個推大數據系統演進第三階段：工具化+服務化+產品化

基礎建設過程中，個推發現雖有了整體框架，但依然不能比較便捷地響應業務方的需求。所以個推選擇提供工具給業務方，并增加一個服務代理層，也就是上圖紅色部分，把批處理任務等抽象成任務模板，配置到代理層，最終提給業務方調用，他們只要做簡單的二次開發，就可以使用個推集群的計算服務，提高業務開發速度。

這個階段，個推在架構上主要完成了以下工作：增加Job調度管理：引入Azkaban和進行改造（變量共享、多集群支持等）；增加服務代理層：引入DataService和Job Proxy(開放給更多產品線使用并解耦)；增加應用層：基于服務代理層研發相應的工具和取數產品。

個推大數據系統演進的經驗與總結

第一，探索數據和理解數據是開發前必備工作。數據處理之前需要探索有哪些臟數據，這些臟數據的分布，以及無效數據和缺省情況的發現等。第二，數據存儲方案向分析和計算需要靠攏。可以考慮使用類似Carbondata等帶有索引的文件格式。第三，數據標準化是提高后續處理首要手段。絕大部分數據需要標準化后供給后續使用（基本清洗、統一內部ID、增加必備屬性），如對實時性數據，應先做標準化處理后，再發布到Kafka里，最后供所有其他實時系統做處理，減少常規清洗和轉化處理在多個業務中重復做，并且統一ID，便于和數據打通。第四，工具化、服務化、產品化提高整體效率。在開發層面可以將MR、Spark進行API封裝并且提供足夠的工具包。第五，大數據系統全鏈路監控很重要。批處理監控主要包括：日常任務運行時間監控、是否出現傾斜、結果集每日曲線、異常數據曲線，GC監控；流式處理監控包括：原數據波動監控、消費速率監控報警、計算節點delay監控等。