近日，據阿里云公眾號，阿里云提供技術支持的上海證券交易所(下稱“上交所”)新交易監管系統已于近期正式上線運行。新系統部署在上交所私有云上，其交易數據實時處理能力擴展達50萬筆/秒以上，總體消息處理能力可達每秒千萬級，計算時延大幅降低，能夠應對未來業務持續增長的交易量和復雜性需求。

新系統基于阿里云全實時計算分析引擎組合Flink+Hologres和云原生數據倉庫AnalyticDB的核心技術私有化部署，自主研發設計，完成實時數據處理、計算和存儲架構的重構升級，全面提升了系統的處理性能和綜合分析能力，并重點考慮了數據處理時效性和數據分析敏捷性的要求。

(1)實時數據的全面分析能力

系統消息隊列中的大規模數據接入實時計算Flink后，關聯實時存儲Hologres中的數據快速處理，結果實時輸出至Kafka或直接入庫Hologres，并經入庫程序統一將實時數據匯聚寫入AnalyticDB，支撐實時分析查詢應用。滿足了在穩定和性能雙保障基礎上的多樣化數據分析需求。

(2)實時預警的敏捷處理能力

作為預警規則的一種實現方式，Flink 可以滿足實時和秒級監管需求。對于復雜實時預警規則，Flink實時關聯維度指標提升預警規則計算實時性。

從新架構落地來看，上交所新交易監管系統交易數據實時處理能力擴展達50萬筆/秒以上(上線首日交易數據處理峰值達15.4萬筆/秒)，總體消息處理能力可達每秒千萬級，計算時延大幅降低;功能上，緊密結合監管最新實踐，更加敏捷和豐富的支持完善監管模型，科技賦能推動監管能力得到進一步提升。

阿里云實時計算是基于Apache Flink構建的一站式、高性能實時大數據處理引擎平臺，廣泛適用于流式數據處理、離線數據處理等多種場景。相對開源Flink，阿里云實時計算Flink商業化產品的多項創新技術與性能和功能穩定性優化很好的滿足了上交所新交易監管系統的需求。具體優勢如下：

(1)阿里云實時計算Flink的關鍵性能指標比開源Flink優化提升了3到4倍。數據計算延遲優化到秒級甚至毫秒級。

(2)阿里云實時計算Flink天然集成數據存儲、數據開發、數據運維、監控報警等功能，方便客戶以較小成本試用，管理和遷移流式計算。同時，實時計算提供完全租戶隔離的托管運行服務。從最上層工作空間，到最底層執行機器，提供高度有效的隔離和全面防護，更加符合證券行業場景特點。

(3)Hologres實時數倉專注實時分析場景，與Flink原生集成，支持數據高性能實時寫入、實時更新，寫入即可見，一套系統和一套數據模型，同時支撐了預警規則所需的高性能點查和業務洞察需要的OLAP分析。

阿里云自研云原生數據倉庫AnalyticDB提供了高性能、高可靠、高穩定性的PB級數據倉庫解決方案。上交所新交易監管系統采用AnalyticDB作為數據底座并完成新老系統平滑遷移。AnalyticDB接收實時數據流，利用其高性能寫入和深入分析查詢能力，滿足了業務應用數據實時存儲及查詢分析等需求。

AnalyticDB在多項功能和性能上的提升，滿足了上交所新交易監管系統的需求：

(1)MPP全并行架構實現處理性能可擴展。通過水平擴展多Master節點(協調節點)、擴展Segment節點(計算節點)的并行計算能力，系統整體能力尤其是數據安全性、時效性以及讀寫性能得到進一步提升，更好地滿足系統對高并發數據寫入的需求，業務數據入庫和混合業務處理性能提升數倍以上。

(2)支持分布式事務，數據ACID一致性支持。所有節點跨機器冗余部署，數據多副本存儲，任意硬件故障，自動化監控切換，保持服務在線，保證數據一致性、完整性和準確性。

(3)廣泛兼容PostgreSQL/Oracle的語法生態，支持PL/SQL存儲過程，提供多種SQL優化器和詳盡的執行計劃，降低調優復雜度，提升遷移效率，降低遷移復雜度。

(4)提供穩定、高性能、高可靠的PB級數據存儲分析，支持大批量實時成交數據高性能導入云原生數據倉庫AnalyticDB，加速不同級別業務數據集中存儲分析，實現業務數據共享，業務數據價值最大化。

阿里云將利用在大數據、數據庫和云原生方面的技術持續加強數據治理和數據應用的能力，促進科技與金融業務深度融合，服務金融市場平穩健康發展。