# 实时报价回调

on_recv_rsp(self, rsp_pb)

  • 介绍

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

  • 参数

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

    参数 类型 说明
    ret RET_CODE 接口调用结果
    data pd.DataFrame 当 ret == RET_OK,返回报价数据
    str 当 ret != RET_OK,返回错误描述
    • 报价数据格式如下:
      字段 类型 说明
      code str 股票代码
      data_date str 日期
      data_time str 当前价更新时间
      last_price float 最新价格
      open_price float 今日开盘价
      high_price float 最高价格
      low_price float 最低价格
      prev_close_price float 昨收盘价格
      volume int 成交数量
      turnover float 成交金额
      turnover_rate float 换手率
      amplitude int 振幅
      suspension bool 是否停牌
      listing_date str 上市日期
      price_spread float 当前向上的价差
      dark_status DarkStatus 暗盘交易状态
      sec_status SecurityStatus 股票状态
      strike_price float 行权价
      contract_size float 每份合约数
      open_interest int 未平仓合约数
      implied_volatility float 隐含波动率
      premium float 溢价
      delta float 希腊值 Delta
      gamma float 希腊值 Gamma
      vega float 希腊值 Vega
      theta float 希腊值 Theta
      rho float 希腊值 Rho
      index_option_type IndexOptionType 指数期权类型
      net_open_interest int 净未平仓合约数
      expiry_date_distance int 距离到期日天数
      contract_nominal_value float 合约名义金额
      owner_lot_multiplier float 相等正股手数
      option_area_type OptionAreaType 期权类型(按行权时间)
      contract_multiplier float 合约乘数
      pre_price float 盘前价格
      pre_high_price float 盘前最高价
      pre_low_price float 盘前最低价
      pre_volume int 盘前成交量
      pre_turnover float 盘前成交额
      pre_change_val float 盘前涨跌额
      pre_change_rate float 盘前涨跌幅
      pre_amplitude float 盘前振幅
      after_price float 盘后价格
      after_high_price float 盘后最高价
      after_low_price float 盘后最低价
      after_volume int 盘后成交量
      after_turnover float 盘后成交额
      after_change_val float 盘后涨跌额
      after_change_rate float 盘后涨跌幅
      after_amplitude float 盘后振幅
      last_settle_price float 昨结
      position float 持仓量
      position_change float 日增仓
  • Example

import time
from futu import *

class StockQuoteTest(StockQuoteHandlerBase):
    def on_recv_rsp(self, rsp_pb):
        ret_code, data = super(StockQuoteTest,self).on_recv_rsp(rsp_pb)
        if ret_code != RET_OK:
            print("StockQuoteTest: error, msg: %s" % data)
            return RET_ERROR, data
        print("StockQuoteTest ", data) # StockQuoteTest 自己的处理逻辑
        return RET_OK, data
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
handler = StockQuoteTest()
quote_ctx.set_handler(handler)  # 设置实时报价回调
ret, data = quote_ctx.subscribe(['HK.00700'], [SubType.QUOTE])  # 订阅实时报价类型,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
21
  • Output
    StockQuoteTest         code   data_date data_time  last_price  open_price  high_price  low_price  prev_close_price    volume      turnover  turnover_rate  amplitude  suspension listing_date  price_spread dark_status sec_status strike_price contract_size open_interest implied_volatility premium delta gamma vega theta  rho net_open_interest expiry_date_distance contract_nominal_value owner_lot_multiplier option_area_type contract_multiplier last_settle_price position position_change pre_price pre_high_price pre_low_price pre_volume pre_turnover pre_change_val pre_change_rate pre_amplitude after_price after_high_price after_low_price after_volume after_turnover after_change_val after_change_rate after_amplitude
0  HK.00700  2020-03-27  14:43:35       384.0       390.0       390.0      381.8             381.8  21573862  8.298364e+09          0.226      2.148       False   2004-06-16           0.2         N/A     NORMAL          N/A           N/A           N/A                N/A     N/A   N/A   N/A  N/A   N/A  N/A               N/A                  N/A                    N/A                  N/A              N/A                 N/A               N/A      N/A             N/A       N/A            N/A           N/A        N/A          N/A            N/A             N/A           N/A         N/A              N/A             N/A          N/A            N/A              N/A               N/A             N/A
1
2

提示