公司动态

应对 24/7 “不打烊交易”时代:用 QuantDash 构建全球资产分钟级实时监控 Pipeline

📅 2026/7/27 18:04:41
应对 24/7 “不打烊交易”时代:用 QuantDash 构建全球资产分钟级实时监控 Pipeline
步入 2026 年传统金融市场的物理边界正在瓦解。“24/7 不打烊交易Always-On Trading”正在成为新的行业标准夜间 ETF 衍生品交易、跨国 ADR 溢价套利等让资金在全球范围内无间断流转。对于量化工程师而言这意味着传统的“收盘后批处理”工作流已经不合时宜。我们需要构建一个能够非阻塞运行的、日内分钟级实时行情监控系统。本文将展示如何利用QuantDash 统一日内分时接口Intraday在免费账户下搭建高可用 A 股分钟级实时监控 Pipeline。一、 日内分时监控的工程难点在设计分钟级监控系统时开发者往往会遇到以下三个技术深渊工程难点传统数据方案AkShare/网页解析QuantDash 统一 Pipeline 方案时空对齐延迟网页爬取容易卡顿多股合并时容易产生严重的时间轴漂移采用极简的 qd.klines.intraday极快响应降低请求开销数据格式混乱原始分时数据常带有空值或非常规交易时间段的数据清洗困难自动过滤异常时段返回规整统一的 Pandas DataFrame接口连接稳定性极易因频繁调用而触发 IP 限制导致系统中断专门为高频量化设计连接稳定支持结构化重试二、 实战A股分钟级分时 K 线对齐监控代码以下代码使用 A 股三大行业巨头贵州茅台、宁德时代、比亚迪的分时数据。这些标的在 QuantDash 的所有计划包括免费注册账户中均完全开放日内分钟级权限直接复制即可无痛跑通import time import logging import pandas as pd from quantdash import QuantDash # 初始化配置与日志 logging.basicConfig(levellogging.INFO, format%(asctime)s - %(levelname)s - %(message)s) # 初始化 API Key (免费注册通道https://quantdash.net/dashboard/keys/) qd QuantDash(api_keyyour_api_key_here) def track_cn_intraday_pipeline(portfolio): 非阻塞分钟级轮询拉取 A 股最新 1 分钟分时 K 线并对齐 logging.info( 启动 A 股分钟级行情监控 Pipeline ) latest_states {} for symbol in portfolio: try: # 严格使用官方全账户兼容的日内分时接口period1m 代表分钟线 # 提示基础版/免费版账户目前开放 CN 市场的日内分时权限US/HK 分时查询需要更高版本 df qd.klines.intraday(symbol, period1m, to_dataframeTrue) if df is not None and not df.empty: # 排序获取最新的最后一笔分钟线数据 df df.sort_values(trade_time) latest_bar df.iloc[-1] latest_states[symbol] { time: latest_bar[trade_time], close: float(latest_bar[close]), volume: float(latest_bar[volume]) } logging.info(f[{symbol}] 最新1分钟线拉取成功 | 时间: {latest_bar[trade_time]} | 收盘价: {latest_bar[close]:.2f}) else: logging.warning(f[{symbol}] 未返回有效的日内数据) except Exception as e: logging.error(f拉取 [{symbol}] 分时行情失败: {e}) # 打印对齐结果 if len(latest_states) 0: print(\n--- 盘中 1 分钟数据矩阵对齐状况 ---) for sym, data in latest_states.items(): print(f标的: {sym:12} | 最新分钟价: {data[close]:8.2f} | 撮合时间: {data[time]}) print(- * 50) if __name__ __main__: # 使用 A 股高流动性核心资产保障 100% 权限可达 monitor_list [600519.SH, 300750.SZ, 002594.SZ] # 模拟盘中轮询监控 for run in range(3): logging.info(f开始第 {run 1} 轮分钟级扫描...) track_cn_intraday_pipeline(monitor_list) time.sleep(5) # 循环刷新生产环境可调整真实数据输出2026-07-26 21:11:12,606 - INFO - 开始第 1 轮分钟级扫描... 2026-07-26 21:11:12,606 - INFO - 启动 A 股分钟级行情监控 Pipeline 2026-07-26 21:11:14,277 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol600519.SHperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:14,292 - INFO - [600519.SH] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 1297.41 2026-07-26 21:11:15,641 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol300750.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:16,048 - INFO - HTTP Request: GET https://api.quantdash.net/v1/instruments?symbols300750.SZ HTTP/1.1 200 OK 2026-07-26 21:11:16,048 - INFO - [300750.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 383.01 2026-07-26 21:11:16,473 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol002594.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:16,762 - INFO - [002594.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 91.89 --- 盘中 1 分钟数据矩阵对齐状况 --- 标的: 600519.SH | 最新分钟价: 1297.41 | 撮合时间: 2026-07-24 15:00:00 标的: 300750.SZ | 最新分钟价: 383.01 | 撮合时间: 2026-07-24 15:00:00 标的: 002594.SZ | 最新分钟价: 91.89 | 撮合时间: 2026-07-24 15:00:00 -------------------------------------------------- 2026-07-26 21:11:21,773 - INFO - 开始第 2 轮分钟级扫描... 2026-07-26 21:11:21,773 - INFO - 启动 A 股分钟级行情监控 Pipeline 2026-07-26 21:11:22,176 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol600519.SHperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:22,202 - INFO - [600519.SH] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 1297.41 2026-07-26 21:11:22,581 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol300750.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:22,887 - INFO - [300750.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 383.01 2026-07-26 21:11:23,843 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol002594.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:23,843 - INFO - [002594.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 91.89 --- 盘中 1 分钟数据矩阵对齐状况 --- 标的: 600519.SH | 最新分钟价: 1297.41 | 撮合时间: 2026-07-24 15:00:00 标的: 300750.SZ | 最新分钟价: 383.01 | 撮合时间: 2026-07-24 15:00:00 标的: 002594.SZ | 最新分钟价: 91.89 | 撮合时间: 2026-07-24 15:00:00 -------------------------------------------------- 2026-07-26 21:11:28,889 - INFO - 开始第 3 轮分钟级扫描... 2026-07-26 21:11:28,889 - INFO - 启动 A 股分钟级行情监控 Pipeline 2026-07-26 21:11:30,070 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol600519.SHperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:30,070 - INFO - [600519.SH] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 1297.41 2026-07-26 21:11:30,460 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol300750.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:30,498 - INFO - [300750.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 383.01 2026-07-26 21:11:30,982 - INFO - HTTP Request: GET https://api.quantdash.net/v1/klines/intraday?symbol002594.SZperiod1m HTTP/1.1 200 OK 2026-07-26 21:11:32,105 - INFO - [002594.SZ] 最新1分钟线拉取成功 | 时间: 2026-07-24 15:00:00 | 收盘价: 91.89 --- 盘中 1 分钟数据矩阵对齐状况 --- 标的: 600519.SH | 最新分钟价: 1297.41 | 撮合时间: 2026-07-24 15:00:00 标的: 300750.SZ | 最新分钟价: 383.01 | 撮合时间: 2026-07-24 15:00:00 标的: 002594.SZ | 最新分钟价: 91.89 | 撮合时间: 2026-07-24 15:00:00 --------------------------------------------------三、 极客开发提示 (Developer Notes)Q1如何解锁美股US和港股HK的日内分时数据权限如果您需要进行跨国如港美股 ADR 套利日内分时研究需要升级您的 QuantDash 订阅计划。对于日常学习和算法回测使用免费版自带的 A 股CN日内分时数据和跨国历史日 K 线数据已足够开发完整的策略原型。Q2获取实时行情快照Quotes和获取分时 K 线Intraday有什么区别qd.quotes.get 返回的是当前那一毫秒的最新报价和成交量快照最适合实时价格监视。qd.klines.intraday 返回的是已经归集好的分钟级 OHLC 数据最适合计算 MACD、RSI 等盘中指标。注册获取 API Keyhttps://quantdash.net/dashboard/keys/详细接口开发文档https://docs.quantdash.net/zh-Hans/sdk/python-quickstart