1、基本思想
在 xtquant 中,要获取指定资产的实时数据,需要先订阅它(subscribe_quote),然后再用 gmd 函数获取(gmd)使用。
这个逻辑与处理历史数据的一样。
2、常用函数
xtdata.get_full_tick() # 主动获取全推数据
xtdata.subscribe_whole_quote() # 订阅全推数据(被动)
xtdata.subscribe_quote() # 订阅单个资产,K线周期可选,但按tick更新(被动)
xtdata.unsubscribe_quote() # 取消订阅
以下分别介绍。
2.1、主动获取实时数据
get_full_tick 函数被调用一次,就主动实时获取指定资产的全推数据一次。使用方法是:
from xtquant import xtdata
code_list = ['000001.SH', '159649.SZ']
data = xtdata.get_full_tick(code_list)
返回值是一个 dict,key 是各个字段的名称,value 是各个字段获取到的最新值。如果是非交易时间,则返回上个最近交易日的最后一个全推数据。
2.2、被动获取实时数据
subscribe_whole_quote
subscribe_whole_quote 一次性订阅多个资产,并被动地获得这些资产的全推数据,同时可以定义回调函数,以及时处理数据:
from xtquant import xtdata
code_list = ['000001.SH', '159649.SZ']
def on_data(da

本文详细介绍了在xtquant库中如何获取指定资产的实时数据,包括主动获取全推数据、被动订阅实时数据以及退订功能。还讨论了订阅模式下的资源管理和数据处理策略。
最低0.47元/天 解锁文章
2093





