# 获取实时经纪队列

# get_broker_queue

get_broker_queue(code)

  • 介绍

    获取已订阅股票的实时经纪队列数据,必须要先订阅。

  • 参数

    参数 类型 说明
    code str 股票代码
  • 返回

    参数 类型 说明
    ret RET_CODE 接口调用结果
    bid_frame_table pd.DataFrame 当 ret == RET_OK,bid_frame_table 返回买盘经纪队列数据
    str 当 ret != RET_OK,bid_frame_table 返回错误描述
    ask_frame_table pd.DataFrame 当 ret == RET_OK,ask_frame_table 返回卖盘经纪队列数据
    str 当 ret != RET_OK,ask_frame_table 返回错误描述
    • 买盘经纪队列格式如下:
      字段 类型 说明
      code str 股票代码
      bid_broker_id int 经纪买盘 ID
      bid_broker_name str 经纪买盘名称
      bid_broker_pos int 经纪档位
      order_id int 交易所订单 ID
      order_volume int 单笔委托数量
    • 卖盘经纪队列格式如下:
      字段 类型 说明
      code str 股票代码
      ask_broker_id int 经纪卖盘 ID
      ask_broker_name str 经纪卖盘名称
      ask_broker_pos int 经纪档位
      order_id int 交易所订单 ID
      order_volume int 单笔委托数量
  • Example

from futu import *
quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)
ret_sub, err_message = quote_ctx.subscribe(['HK.00700'], [SubType.BROKER], subscribe_push=False)
# 先订阅经纪队列类型。订阅成功后 FutuOpenD 将持续收到服务器的推送,False 代表暂时不需要推送给脚本
if ret_sub == RET_OK:   # 订阅成功
    ret, bid_frame_table, ask_frame_table = quote_ctx.get_broker_queue('HK.00700')   # 获取一次经纪队列数据
    if ret == RET_OK:
        print(bid_frame_table)
    else:
        print('error:', bid_frame_table)
else:
    print('subscription failed')
quote_ctx.close()   # 关闭当条连接,FutuOpenD 会在1分钟后自动取消相应股票相应类型的订阅
1
2
3
4
5
6
7
8
9
10
11
12
13
  • Output
    code  bid_broker_id bid_broker_name  bid_broker_pos order_id order_volume
0   HK.00700            140      海通国际证券有限公司               1      N/A          N/A
..       ...            ...             ...             ...      ...          ...
35  HK.00700           4978  法国兴业证券(香港)有限公司               5      N/A          N/A

[36 rows x 6 columns]
1
2
3
4
5
6

提示