為解決一線業務在高并發、高業務量的重大活動中，無法實時獲取最新秒殺數據、無法實時監控系統壓力等問題，太平金科攻關克難，自主研發了流計算數據采集改進解決方案。

方案采用Spark流計算產品對接RocketMQ消息隊列產品，改進消息拉取模式，根據自身處理能力決定數據拉取頻率及拉取增量因子，解決了消息推送模式中無法控制消費速度的問題；采用流計算，運用分布式微批計算模式實現數據實時計算，解決了傳統單體計算時效低、延遲高的問題。

自2018年10月上線以來，方案已多次在賦能計劃重要業務活動中發揮了重要作用，實現了通過業務大屏展示秒殺活動真實情況，通過監控實時反映系統運行壓力狀況等需求。

方案于2020年6月16日正式獲得國家知識產權局授權（專利號：ZL2020103243744），為太平金科全年知識產權專利申報工作取得了良好開端。

太平金科將繼續狠抓科技創新，深入研究人工智能、區塊鏈、云計算、大數據、移動互聯、語音識別等先進技術，不斷提升自主研發能力，加大知識產權保護力度，在滿足業務一線需求的同時持續積累自身技術能力。