华大网站建设,sem投放是什么意思,书法网站优化关键词,wordpress支持md么实时行情数据是量化交易策略、看板系统和交易决策系统的重要输入。本文将以 Infoway API 提供的 WebSocket API 为例#xff0c;教你如何使用 Python 快速接入并获取 A 股的实时 K线数据 和 盘口数据。一、准备工作安装 WebSocket 库#xff1a;pip install websockets二、查…实时行情数据是量化交易策略、看板系统和交易决策系统的重要输入。本文将以 Infoway API 提供的 WebSocket API 为例教你如何使用 Python 快速接入并获取 A 股的实时 K线数据 和 盘口数据。一、准备工作安装 WebSocket 库
pip install websockets
二、查询 1 分钟 K 线数据以下是订阅 A 股平安银行1 分钟 K 线的完整代码
import asyncio
import json
import websocketsWS_URL wss://data.infoway.io/ws?businessstockapikeyyourApiKey# API KEY申请: www.infoway.ioasync def connect_and_receive():async with websockets.connect(WS_URL) as websocket:init_message {code: 10004, # K线订阅请求号trace: trace-id-001, # 自定义追踪IDdata: {arr: [{type: 1, # 1 表示 1 分钟K线codes: 000001.SZ # A股代码}]}}await websocket.send(json.dumps(init_message))async def send_ping():while True:await asyncio.sleep(30)ping {code: 10010, trace: trace-id-001}await websocket.send(json.dumps(ping))ping_task asyncio.create_task(send_ping())try:while True:message await websocket.recv()print(K线数据, message)finally:ping_task.cancel()asyncio.run(connect_and_receive())
返回数据说明
{c: 11.25, // 收盘价h: 11.28, // 最高价l: 11.22, // 最低价o: 11.23, // 开盘价v: 258400, // 成交量单位股vw: 11.2458, // 加权平均价pca: 0.02, // 价格变化pfr: 0.18%, // 涨跌幅t: 1747550648097, // 时间戳s: 000001.SZ, // 股票代码ty: 1 // K线类型1分钟
}
三、查询盘口数据Level 2以下是订阅平安银行盘口数据的完整代码
import asyncio
import json
import websocketsWS_URL wss://data.infoway.io/ws?businessstockapikeyyourApiKey# 申请API KEY: www.infoway.ioasync def connect_and_receive():async with websockets.connect(WS_URL) as websocket:init_message {code: 10002, # 盘口订阅请求号trace: trace-id-002,data: {codes: 000001.SZ}}await websocket.send(json.dumps(init_message))async def send_ping():while True:await asyncio.sleep(30)ping {code: 10010, trace: trace-id-002}await websocket.send(json.dumps(ping))ping_task asyncio.create_task(send_ping())try:while True:message await websocket.recv()print(盘口数据, message)finally:ping_task.cancel()asyncio.run(connect_and_receive())
返回数据说明
{a: [ // 卖盘数据[11.25, 11.26, 11.27, 11.28, 11.29], // 卖五档价格[23000, 18000, 9500, 6000, 7200] // 对应数量],b: [ // 买盘数据[11.24, 11.23, 11.22, 11.21, 11.20], // 买五档价格[26000, 20000, 10000, 7500, 8500] // 对应数量],s: 000001.SZ, // 股票代码t: 1747553102161 // 时间戳
}
四、注意事项Ping 心跳机制WebSocket 连接必须维持心跳否则服务端会自动断开连接。每隔 30 秒发送一次 code10010 的心跳消息。股票代码格式A 股股票代码格式为 000001.SZ 或 600000.SH需要带交易所后缀。数据使用限制免费账号有速率限制或订阅数量限制五、扩展应用建议看板系统将返回的实时 K 线和盘口数据接入到图表看板中如 Grafana WebSocket。自动交易系统用盘口数据驱动微观结构策略如买卖盘力量对比。AI 策略研究K 线与盘口联合建模用于训练 LSTM 或 Transformer 型模型。
