3月16日消息，阿里云提供技术支持的上海证券交易所（下称“上交所”）新交易监管系统已于近期正式上线运行。新系统部署在上交所私有云上，其交易数据实时处理能力扩展达50万笔/秒以上，总体消息处理能力可达每秒千万级。
新系统基于阿里云全实时计算分析引擎组合Flink+Hologres和云原生数据仓库AnalyticDB的核心技术私有化部署，自主研发设计，完成实时数据处理、计算和存储架构的重构升级，全面提升了系统的处理性能和综合分析能力，并重点考虑了数据处理时效性和数据分析敏捷性的要求。
来源：阿里云公众号
系统消息队列中的大规模数据接入实时计算Flink后，关联实时存储Hologres中的数据快速处理，结果实时输出至Kafka或直接入库Hologres，并经入库程序统一将实时数据汇聚写入AnalyticDB，支撑实时分析查询应用。满足了在稳定和性能双保障基础上的多样化数据分析需求。
作为预警规则的一种实现方式，Flink 可以满足实时和秒级监管需求。对于复杂实时预警规则，Flink实时关联维度指标提升预警规则计算实时性。
从新架构落地来看，上交所新交易监管系统交易数据实时处理能力扩展达50万笔/秒以上（上线首日交易数据处理峰值达15.4万笔/秒），总体消息处理能力可达每秒千万级，计算时延大幅降低；功能上，紧密结合监管最新实践，更加敏捷和丰富的支持完善监管模型，科技赋能推动监管能力得到进一步提升。
截取自上交所官网
据介绍，阿里云实时计算是基于Apache Flink构建的一站式、高性能实时大数据处理引擎平台，广泛适用于流式数据处理、离线数据处理等多种场景。相对开源Flink，阿里云实时计算Flink商业化产品的多项创新技术与性能和功能稳定性优化很好的满足了上交所新交易监管系统的需求。具体优势如下：
阿里云实时计算Flink的关键性能指标比开源Flink优化提升了3到4倍。数据计算延迟优化到秒级甚至毫秒级。
阿里云实时计算Flink天然集成数据存储、数据开发、数据运维、监控报警等功能，方便客户以较小成本试用，管理和迁移流式计算。同时，实时计算提供完全租户隔离的托管运行服务。从最上层工作空间，到最底层执行机器，提供高度有效的隔离和全面防护，更加符合证券行业场景特点。
截取自阿里云实时计算Flink产品简介宣传视频
Hologres实时数仓专注实时分析场景，与Flink原生集成，支持数据高性能实时写入、实时更新，写入即可见，一套系统和一套数据模型，同时支撑了预警规则所需的高性能点查和业务洞察需要的OLAP分析。
阿里云自研云原生数据仓库AnalyticDB提供了高性能、高可靠、高稳定性的PB级数据仓库解决方案。上交所新交易监管系统采用AnalyticDB作为数据底座并完成新老系统平滑迁移。AnalyticDB接收实时数据流，利用其高性能写入和深入分析查询能力，满足了业务应用数据实时存储及查询分析等需求。
,
