# 实时 K 线回调

参数	类型	说明
rsp_pb	Qot_UpdateKL_pb2.Response	派生类中不需要直接处理该参数

on_recv_rsp(self, rsp_pb)

介绍

实时 K 线回调，异步处理已订阅股票的实时 K 线推送。

在收到实时 K 线数据推送后会回调到该函数，您需要在派生类中覆盖 on_recv_rsp。
参数

参数类型说明

rsp_pb Qot_UpdateKL_pb2.Response 派生类中不需要直接处理该参数

参数	类型	说明
rsp_pb	Qot_UpdateKL_pb2.Response	派生类中不需要直接处理该参数

参数	类型	说明
ret	RET_CODE	接口调用结果
data	pd.DataFrame	当 ret == RET_OK，返回 K 线数据数据
data	str	当 ret != RET_OK，返回错误描述

K 线数据格式如下：

字段	类型	说明
code	str	股票代码
name	str	股票名称
time_key	str	时间格式：yyyy-MM-dd HH:mm:ss 港股和 A 股市场默认是北京时间，美股市场默认是美东时间
open	float	开盘价
close	float	收盘价
high	float	最高价
low	float	最低价
volume	int	成交量
turnover	float	成交额
pe_ratio	float	市盈率
turnover_rate	float	换手率该字段为百分比字段，默认返回小数，如 0.01 实际对应 1%
last_close	float	昨收价即前一个时间的收盘价出于效率原因，第一个数据的昨收价可能为 0
k_type	KLType	K 线类型

Example

import time
from moomoo import *
class CurKlineTest(CurKlineHandlerBase):
    def on_recv_rsp(self, rsp_pb):
        ret_code, data = super(CurKlineTest,self).on_recv_rsp(rsp_pb)
        if ret_code != RET_OK:
            print("CurKlineTest: error, msg: %s" % data)
            return RET_ERROR, data
        print("CurKlineTest ", data) # CurKlineTest 自己的处理逻辑
        return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = CurKlineTest()
quote_ctx.set_handler(handler)  # 设置实时K线回调
ret, data = quote_ctx.subscribe(['HK.00700'], [SubType.K_1M])   # 订阅 K 线数据类型，OpenD 开始持续收到服务器的推送
if ret == RET_OK:
    print(data)
else:
    print('error:', data)
time.sleep(15)  # 设置脚本接收 OpenD 的推送持续时间为15秒
quote_ctx.close()   # 关闭当条连接，OpenD 会在1分钟后自动取消相应股票相应类型的订阅

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

Output

CurKlineTest         code  name             time_key   open  close   high    low   volume     turnover k_type  last_close
0  HK.00700  腾讯控股  2023-07-19 16:00:00  332.6  333.0  333.0  332.4  1766300  588143620.0   K_1M         0.0

1
2

提示

此接口提供了持续获取推送数据的功能，如需一次性获取实时数据，请参考获取实时 K 线接口
获取实时数据和实时数据回调的差别，请参考如何通过订阅接口获取实时行情？
期权，仅提供日K, 1分K，5分K，15分K，60分K。

← 实时摆盘回调实时分时回调 →

# 实时 K 线回调

# Qot_UpdateKL.proto

# Qot_UpdateKL.proto