光大证券成立于1996年，总部位于上海，是中国证监会首批创新试点证券公司之一，也是中国光大集团核心金融服务平台。公司先后在上海证券交易所和香港联合交易所主板上市，围绕财富管理、企业融资、机构客户、投资交易、资产管理、股权投资构建六大业务集群。截至2026年一季度末，公司拥有7家控股子公司、13家分公司和211家证券营业部，业务覆盖全国107个城市，并获得“中国证券业数字化实践全能君鼎奖”“金牛成长证券公司”等多项荣誉。

随着证券业务数字化、智能化水平持续提升，光大证券在智能投研、实时风控、极速交易、个性化投顾等场景中，对数据实时性、一致性和可用性提出了更高要求。传统T+1批处理和人工脚本方式，已难以满足“大模型+实时计算”背景下对海量资讯、高频交易数据和客户服务数据的低延迟流转需求。同时，达梦、OceanBase、MySQL、TDSQL等多源异构数据库并存，也带来了数据孤岛、同步延迟和运维复杂度提升等挑战。

基于上述需求，光大证券携手DataPipeline建设实时数据平台，通过统一接入、实时同步、自动化运维与全链路可观测能力，打通多个异构业务系统，形成“多源汇聚—ODS清洗—智能应用”的实时数据流转架构。

DataPipeline助力光大证券，实时数据融合平台顺利上线

在本次项目中，DataPipeline 企业级实时数据融合平台适配了光大证券包括达梦、OceanBase、MySQL、TDSQL在内的多种数据库管理技术，支撑万得与资讯系统、极速交易系统、话务工作台、资金管理等核心场景的数据实时接入与同步。

其中，万得与资讯系统作为投研与风控的外部数据源，实时接入宏观经济、行业研报、新闻舆情等非结构化数据，并通过大模型解析与Text-to-SQL能力转化为结构化信号，为智能投研和实时风险预警提供数据支撑。极速交易系统作为核心交易链路，实时同步逐笔委托、逐笔成交及行情数据至ODS层，支撑流批一体引擎进行实时状态计算。话务工作台依托交易与资讯数据的实时触发，在客户致电时秒级调取账户变动、持仓盈亏及市场资讯，辅助一线投顾提供更及时、个性化的服务。资金管理系统则将头寸变动与清算结果实时同步至ODS交易库，保障高频交易场景下资金流转的准确性与合规性。

实时数据融合平台架构

▶ 高性能实时处理

平台针对不同数据节点类型提供高吞吐、低延迟的增量数据处理能力，能够支撑金融核心业务场景下大规模、多链路、持续性的实时数据流转。

▶ 极稳定高可靠

平台采用分布式架构，核心组件均支持高可用部署，并提供丰富的容错策略，可应对上下游结构变化、数据异常、网络波动等突发情况，满足金融业务对连续性和稳定性的高要求。

▶ 全链路数据可观测

配备容器、应用、线程、业务四级监控体系，全景驾驶舱守护任务稳定运行。自动化运维体系，灵活扩缩容，合理管理和分配系统资源。

平台上线后，光大证券依托“阳光e数”中台打造统一、智能的数据服务门户，服务内部6000+用户，年访问量超过1500万次，赋能财富管理、机构业务、合规风控等20+部门。其中，万得与资讯系统覆盖约3条链路、200+张表，延迟达到毫秒级，日均增量数百GB；极速交易系统覆盖1条链路、100+张表，延迟为毫秒级，单表数据量过亿；话务工作台与资金管理覆盖1条链路、150+张表，延迟为秒级，数据量以千万级为主、百万级为辅。

从业务价值看，实时数据平台将外部资讯与内部交易数据进行毫秒级融合，支撑流式计算与AI模型实时推理，帮助机构客户在复杂市场环境中更高效地捕捉投资机会；同时，将风控关口前移至交易执行环节，实现异常交易的实时识别、拦截与合规审计，提升高频交易场景下的穿透式监管能力。在财富管理场景中，平台打通投顾、交易与资讯链路，帮助客户需求实现秒级响应，进一步提升个性化投顾服务的专业度与体验。

从技术价值看，DataPipeline 一站式兼容达梦、OceanBase、MySQL、TDSQL等多源异构数据库，降低复杂环境下的数据融合与运维难度，为国产化信创改造提供平滑支撑。同时，基于Flink与OB数据库能力，平台将传统ETL批处理模式升级为流批一体实时计算，将数据延迟从T+1压缩至毫秒级，为实时风控、极速交易和智能投研提供稳定、高性能的数据底座。

光大证券表示，DataPipeline 在异构数据源适配、实时同步性能、任务稳定性和自动化运维方面表现稳定，有效支撑了光大证券关键业务场景对低延迟、高一致性和高可用的要求，为后续数据智能应用建设打下了坚实基础。

未来，DataPipeline 将继续围绕证券、银行、保险等金融行业核心场景，持续提升实时数据融合平台在高性能处理、国产数据库适配、数据可观测与智能运维方面的能力，助力更多金融机构构建稳定、敏捷、可信的数据基础设施，为数字金融、科技金融与智能化业务创新提供持续支撑。