# 实时逐笔回调

# TickerHandlerBase

on_recv_rsp(self, rsp_pb)

  • 介绍

    实时逐笔回调,异步处理已订阅股票的实时逐笔推送。
    在收到实时逐笔数据推送后会回调到该函数,您需要在派生类中覆盖 on_recv_rsp。

  • 参数

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

    参数 类型 说明
    ret RET_CODE 接口调用结果
    data pd.DataFrame 当 ret == RET_OK,返回逐笔数据
    str 当 ret != RET_OK,返回错误描述
    • 逐笔数据格式如下:
      字段 类型 说明
      code str 股票代码
      sequence int 逐笔序号
      time str 成交时间
      price float 成交价格
      volume int 成交数量
      turnover float 成交金额
      ticker_direction TickerDirect 逐笔方向
      type TickerType 逐笔类型
      push_data_type PushDataType 数据来源
  • Example

import time
from futu import *

class TickerTest(TickerHandlerBase):
    def on_recv_rsp(self, rsp_pb):
        ret_code, data = super(TickerTest,self).on_recv_rsp(rsp_pb)
        if ret_code != RET_OK:
            print("TickerTest: error, msg: %s" % data)
            return RET_ERROR, data
        print("TickerTest ", data) # TickerTest 自己的处理逻辑
        return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = TickerTest()
quote_ctx.set_handler(handler)  # 设置实时逐笔推送回调
quote_ctx.subscribe(['HK.00700'], [SubType.TICKER]) # 订阅逐笔类型,FutuOpenD 开始持续收到服务器的推送
time.sleep(15)  # 设置脚本接收 FutuOpenD 的推送持续时间为15秒
quote_ctx.close()   # 关闭当条连接,FutuOpenD 会在1分钟后自动取消相应股票相应类型的订阅	
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
  • Output
    TickerTest         code                 time  price  volume  turnover ticker_direction             sequence        type push_data_type
0  HK.00700  2020-03-27 15:15:17  382.4     100   38240.0             SELL  6808782951082376714  AUTO_MATCH          CACHE
    TickerTest          code                 time   price  volume  turnover ticker_direction             sequence     type push_data_type
0  HK.00700  2020-03-27 15:15:19  382.6     900   344340.0             BUY  6808782951082378963  AUTO_MATCH       REALTIME

1
2
3
4
5

提示

  • 此接口提供了持续获取推送数据的功能,如需一次性获取实时数据,请参考 获取实时逐笔 接口
  • 获取实时数据 和 实时数据回调 的差别,请参考 如何通过订阅接口获取实时行情?
  • 行情连接断开重连后,FutuOpenD 拉取断开期间,距离当前最近的(最多 50 根)逐笔数据并推送,可通过逐笔推送类型字段区分