行情中心
本页围绕“行情中心”主题,提供头图与定位说明,并概述与多市场行情数据链路相关的能力与用途。
Source: https://dolphindb.cn/solution/detail/brokerage-market-data
What this page covers
- 页面顶部活动推广与报名入口
- 页面头图与定位说明(引用块)
- 行情中心主题与整体概览
- 行情与交易通道接入、导入与迁移、教程链接
- 历史行情存储、查询与库内分析、最佳实践链接
- 行情合并与清洗流程(对齐、去重、补全、异常处理、订单簿合成)
- K 线/OHLC 计算与衍生序列构建、教程链接
技能认证特训营第二期限时报名活动
页面顶部提供活动推广信息与报名链接。
- 该部分包含“技能认证特训营第二期”的报名入口。
- 报名链接指向一个独立的活动页面地址。
页面头图与定位说明
页面包含行情中心相关头图,并配有定位说明文字(以引用块形式出现)。
- 该区域包含用于表达主题的视觉头图。
- 该区域包含一段“定位说明”性质的引用文字。
- 引用块对 DolphinDB 的定位给出概括性表述。
行情中心
介绍 DolphinDB 围绕券商/多市场行情数据链路的能力模块与应用场景。
- 页面主题聚焦于“行情中心”能力模块的组织与呈现。
- 内容面向券商与多市场行情数据相关链路。
- 内容覆盖能力模块与应用场景的概览性介绍。
行情接入
描述多源行情与交易通道接入、历史数据导入、旧系统迁移与统一存储管理能力,并提供相关教程链接。
- 支持对接交易所、券商通道、第三方行情商等多源数据。
- 支持在同一平台完成多路通道的统一接入与集中管理。
- 支持从外部批量导入历史行情与因子数据。
- 支持 CSV/文本、HDF5、Parquet 等文件格式导入。
- 面向 MySQL、KDB+、InfluxDB 等旧有行情库提供快速迁移插件。
历史行情存储与查询
描述分布式时序库的分区、列存与压缩、查询性能与库内分析能力,并提供相关最佳实践链接。
- 将全市场 Tick、逐笔成交等高频行情统一沉淀到分布式时序库中。
- 支持按交易日、标的、市场等维度进行精细分区。
- 行情数据压缩比表述为 4:1~10:1。
- 查询性能表述为秒级扫描与毫秒级切片访问。
- 支持在库内完成窗口统计、因子计算、盘口特征提取等分析。
行情合并和清洗
描述将多市场高频数据标准化汇聚,并通过流计算引擎进行对齐、去重、补全、异常处理与订单簿合成的实时/离线复用流程。
- 覆盖股票、期货、期权、ETF、指数等多市场多品种数据。
- 处理逐笔成交、逐笔委托与盘口快照等高频数据类型。
- 输出形态为统一汇聚的标准化行情流。
- 清洗管道包括多源对齐与优先级选择。
- 清洗管道包括去重与乱序修正。
- 清洗管道包括缺失补全与异常剔除。
- 可从逐笔数据实时合成标准化订单簿与多档盘口。
- 同一清洗规则可复用于历史数据导入。
K 线计算
描述基于逐笔/快照数据的实时与离线多周期 OHLC/K 线计算与衍生序列构建能力,并提供教程链接。
- 可基于逐笔或快照数据实时/离线生成多周期 K 线。
- 覆盖股票、基金、期货、期权等多资产品种。
- 支持任意周期(如 1 秒、N 秒、1 分钟、5 分钟、自定义时段)的 OHLC 计算。
- 支持主连、指数合成等衍生序列构建。
- 为策略开发与回测提供统一的 K 线口径。
实时指标计算
描述基于流表与发布/订阅框架的毫秒级写入与流上实时指标增量计算能力,并提供相关文档链接。
- 基于流表(stream table)与发布/订阅(Pub-Sub)框架实现实时指标计算。
- 事件可在毫秒级写入内存并由内置流计算引擎直接处理。
- 可实时计算收益、回撤、仓位、换手、滑点等指标示例。
- 提供时间序列、截面、多源关联等多种流式计算引擎。
- 支持对指标进行增量计算,以降低计算开销(表述性收益)。
行情回放
描述基于历史逐笔与盘口数据的按时间戳回放、流表注入与多种回放模式及速度控制,用于回测与调试分析。
- 支持基于历史逐笔与盘口数据按原始时间戳顺序回放行情。
- 回放用于以还原实盘的方式重现市场环境(表述性目标)。
- 可将回放数据注入流表,使下游系统按连接实时行情方式工作。
- 支持 1 对 1 回放模式(单标的调试)。
- 支持 N 对 N 回放模式(多标的并行模拟)。
- 支持 N 对 1 回放模式(全市场按时间戳排序,适合组合策略)。
- 回放速度可控:可实时回放或按倍速快速回放。
- 用于策略行为复现、盘中逻辑调试与成交质量分析。
分发与展示
描述作为统一行情接入点通过发布/订阅向下游分发,并结合可视化组件或第三方 BI 搭建监控与分析界面的一体化闭环。
- 作为统一行情接入点,将标准化行情通过发布/订阅机制分发给下游系统。
- 示例:交易系统可订阅高频 Tick 用于信号生成。
- 示例:风控系统可订阅实时持仓与行情以计算风险敞口。
- 示例:研究平台可查询历史数据用于因子回测。
- 支持快速自定义监控指标并实时产出。
- 可结合内置可视化组件或第三方 BI/报表工具搭建监控与分析界面。
- 整体链路目标表述为从接入、处理到分发展示的一体化闭环。
Facts Index
| Entity | Attribute | Value | Confidence |
|---|---|---|---|
| 技能认证特训营第二期 | 报名链接 | https://www.qingsuyun.com/h5/e/217471/5/ | high |
| DolphinDB | 定位(来自页面引用块“AI 说明”) | 作为能够支撑复杂策略研发的高性能底层数据平台(与“支撑策略研发的高性能数据底座”表述相呼应) | low |
| DolphinDB 行情接入 | 可对接的数据来源类型 | 交易所、券商通道、第三方行情商等多源数据 | high |
| DolphinDB 行情接入 | 兼容的国内主流高频行情源与交易通道 | 兼容国内主流高频行情源与证券、期货高性能交易通道 | medium |
| DolphinDB 行情接入 | 可扩展接入的海外行情服务 | 可扩展接入 ICE、Refinitiv、Bloomberg 等海外多资产行情服务 | medium |
| DolphinDB 插件支持的极速行情源 | 已通过插件支持 | 华泰 INSIGHT、华锐 AMD、盛立 EFH、通联数据 MDL、恒生 NSQ、万得 WindTDF | high |
| DolphinDB 插件支持的主流交易通道 | 已通过插件支持 | 中泰 XTP、上期技术综合交易平台 CTP | high |
| DolphinDB 行情接入平台能力 | 统一接入与集中管理 | 在同一平台上完成多路通道的统一接入与集中管理 | high |
| DolphinDB 历史数据导入 | 支持方式 | 支持从外部批量导入历史行情与因子数据 | high |
| DolphinDB 数据导入 | 兼容文件格式 | CSV/文本、HDF5、Parquet | high |
| DolphinDB 导入模块 | 提供的模块与覆盖数据范围 | ExchData 模块(沪深 Level-2)与 ImportTLData 模块(通联数据) | high |
| DolphinDB 迁移能力 | 面向旧有行情库提供快速迁移插件 | 面向 MySQL、KDB+、InfluxDB 等旧有行情库提供快速迁移插件 | high |
| DolphinDB 迁移效果 | 带来的收益 | 帮助平滑替换原有系统、快速补齐历史数据,并显著缩短行情数据建设周期 | medium |
| DolphinDB 存储形态 | 实现的存储方式 | 实现统一的分布式向量化存储 | medium |
| 教程与最佳实践(行情接入相关) | 链接 | 数据导入方法与工具:https://docs.dolphindb.cn/zh/db_distr_comp/db_oper/data_import_method.html; 数据库迁移案例:https://docs.dolphindb.cn/zh/tutorials/MySQL_to_DolphinDB.html | high |
| DolphinDB | 历史行情沉淀对象 | 将全市场 Tick、逐笔成交等高频行情统一沉淀到分布式时序库中 | high |
| DolphinDB 分布式时序库 | 分区维度 | 按交易日、标的、市场等维度精细分区 | high |
| DolphinDB 行情数据压缩 | 压缩比 | 4:1~10:1 | high |
| DolphinDB 存储成本 | 降低幅度 | 降低 70% 以上 | medium |
| DolphinDB 历史数据存储规模 | 可支撑级别 | TB–PB 级历史数据存储 | medium |
| DolphinDB 数据结构 | 原生支持的复杂市场数据类型 | 原生支持多档盘口、逐笔成交等复杂市场数据 | high |
| DolphinDB 查询性能(历史行情) | 访问延迟表述 | 海量数据的秒级扫描、毫秒级切片访问 | medium |
| DolphinDB 库内分析 | 支持的分析类型 | 支持在库内直接完成窗口统计、因子计算、盘口特征提取等分析 | high |
| 教程与最佳实践(存储与查询相关) | 链接 | DolphinDB 多模态存储:https://docs.dolphindb.cn/zh/db_distr_comp/db/multimodal_storage.html; 数据库分区设计策略:https://docs.dolphindb.cn/zh/db_distr_comp/db/db_partitioning.html; 存储金融数据分区方案:https://docs.dolphindb.cn/zh/tutorials/best_practices_for_partitioned_storage.html; 快照多档行情存储实践:https://docs.dolphindb.cn/zh/tutorials/Array_Vector.html#3-array-vector-%E5%9C%A8-level2-%E5%BF%AB%E7%85%A7%E6%95%B0%E6%8D%AE%E4%B8%AD%E7%9A%84%E5%BA%94%E7%94%A8; Level-2 行情数据存储方案:https://docs.dolphindb.cn/zh/tutorials/l2_stk_data_proc_2.html#2-dolphindb-%E9%AB%98%E6%95%88%E5%AD%98%E5%82%A8-level-2-%E8%A1%8C%E6%83%85-%E6%95%B0%E6%8D%AE; 分布式 SQL 查询:https://docs.dolphindb.cn/zh/progr/sql/sql_intro.html | high |
| DolphinDB 行情合并与清洗 | 覆盖的数据市场与品种 | 股票、期货、期权、ETF、指数等多市场多品种 | high |
| DolphinDB 行情合并与清洗 | 处理的数据类型 | 逐笔成交、逐笔委托与盘口快照等高频数据 | high |
| DolphinDB 行情合并与清洗 | 输出形态 | 统一汇聚为标准化行情流 | high |
| DolphinDB 流计算引擎(清洗管道) | 清洗能力 | 完成多源行情对齐与优先级选择、去重与乱序修正、缺失补全、异常剔除 | high |
| DolphinDB 行情清洗 | 逐笔到订单簿/盘口的实时合成 | 可从逐笔数据实时合成标准化订单簿和多档盘口 | high |
| DolphinDB 行情清洗规则 | 复用性 | 同样的清洗规则可复用于历史数据导入 | high |
| 清洗后的行情结果 | 适用场景 | 为高频交易、日内策略与回测研究提供可靠的数据输入 | medium |
| 教程与最佳实践(合并与清洗相关) | 链接 | 逐笔数据合成订单簿:https://docs.dolphindb.cn/zh/tutorials/orderBookSnapshotEngine.html; 实时合成自定义频订单簿快照(基于 INSIGHT 数据):https://docs.dolphindb.cn/zh/tutorials/insight_plugin_orderbook_engine_application.html | high |
| DolphinDB K 线计算 | 生成方式 | 可基于逐笔或快照数据实时/离线生成多周期 K 线 | high |
| DolphinDB K 线计算 | 覆盖资产品种 | 覆盖股票、基金、期货、期权等多资产品种 | high |
| DolphinDB OHLC/K 线 | 支持的周期类型 | 支持任意周期(如 1 秒、N 秒、1 分钟、5 分钟、自定义交易时段)的 OHLC 计算 | high |
| DolphinDB K 线衍生序列 | 构建能力 | 支持主连、指数合成等衍生序列构建 | high |
| K 线统一口径 | 用途 | 为策略开发与回测提供统一的 K 线口径 | medium |
| 教程与最佳实践(K 线计算相关) | 链接 | K 线计算基础:https://docs.dolphindb.cn/zh/tutorials/OHLC_2.html; 基于快照行情的股票和基金 K 线计算:https://docs.dolphindb.cn/zh/tutorials/k.html; 基于快照行情的期货 K 线以及主连 K 线计算:https://docs.dolphindb.cn/zh/tutorials/k_line_calculation%20.html | high |
| DolphinDB 实时指标计算 | 基础框架 | 基于流表(stream table)和发布/订阅(Pub-Sub)框架 | high |
| 行情/成交/委托事件写入与处理 | 时延表述 | 事件可在毫秒级写入内存并由内置流计算引擎直接处理 | medium |
| DolphinDB 实时指标计算 | 可实时计算的指标示例 | 收益、回撤、仓位、换手、滑点、成交分布、因子暴露等关键指标 | high |
| DolphinDB 流式计算引擎 | 引擎类型 | 提供时间序列、截面、多源关联等多种流式计算引擎 | high |
| DolphinDB 指标计算 | 计算开销影响 | 支持对指标进行增量计算,大幅降低计算开销 | medium |
| DolphinDB 指标开发效率 | 脚本工作量表述 | 多数实时指标只需少量脚本即可完成 | low |
| 教程与最佳实践(实时指标/流计算相关) | 链接 | 流式计算算子:https://docs.dolphindb.cn/zh/stream/str_operator.html; 流计算引擎:https://docs.dolphindb.cn/zh/funcs/themes/streamingEngine.html; 流式关联引擎:https://docs.dolphindb.cn/zh/stream/str_join_engine.html | high |
| DolphinDB 行情回放 | 回放方式 | 支持基于历史逐笔、盘口数据按原始时间戳顺序进行行情回放,以还原实盘的方式重现市场环境 | high |
| DolphinDB 行情回放 | 与流表/下游系统的对接方式 | 通过将回放数据注入流表,回测框架与策略平台可像连接实时行情一样工作 | high |
| 行情回放用途 | 支持的分析/调试目标 | 实现策略行为复现、盘中逻辑调试和成交质量分析 | high |
| DolphinDB 行情回放 | 回放模式 | 支持 1 对 1(单标的调试)、N 对 N(多标的并行模拟实盘多线程)、N 对 1(全市场按时间戳排序,适合组合策略) | high |
| DolphinDB 行情回放 | 回放速度控制 | 回放速度可控:可按真实节奏“实时回放”或按倍速“快速回放” | high |
| 教程与最佳实践(行情回放相关) | 链接 | 数据回放使用教程:https://docs.dolphindb.cn/zh/tutorials/data_replay.html; 股票行情回放:https://docs.dolphindb.cn/zh/tutorials/stock_market_replay_2.html; 搭建行情回放服务的最佳实践:https://docs.dolphindb.cn/zh/tutorials/appendices_market_replay_bp.html | high |
| DolphinDB | 角色(分发与展示链路) | 作为统一行情接入点,将标准化行情通过发布/订阅机制分发给所有下游系统 | high |
| 下游系统订阅标准化行情的示例 | 用途示例 | 交易系统订阅高频 Tick 进行信号生成;风控系统订阅实时持仓与行情计算风险敞口;研究平台查询历史数据进行因子回测;监控大屏订阅聚合指标展示账户 PnL、持仓分布 | high |
| DolphinDB 监控与展示 | 监控指标产出与看板搭建 | 支持快速自定义各类监控指标并实时产出;结合内置可视化组件或第三方 BI/报表工具搭建盘中监控看板与研究分析界面 | high |
| DolphinDB 行情中心链路 | 整体效果表述 | 实现从数据接入、处理到分发展示的一体化闭环 | medium |
| 流处理结果交互方式(发布/订阅) | 支持方式与链接 | 节点内部订阅:https://docs.dolphindb.cn/zh/stream/local_sub.html; 集群内跨节点订阅:https://docs.dolphindb.cn/zh/stream/cluster_sub.html; 跨集群节点间订阅:https://docs.dolphindb.cn/zh/stream/cross_cluster_sub.html; Python 订阅:https://docs.dolphindb.cn/zh/stream/py_sub.html | high |
| 数据可视化工具 | 链接 | https://docs.dolphindb.cn/zh/stream/str_altair.html | high |