1.首先我们需要连接上vip行情
#coding:utf-8
"""
连接token
"""
import sys
print("Python 版本:", sys.version)
from xtquant import xtdatacenter as xtdc
from xtquant import xtdata
'''
设置用于登录行情服务的token,此接口应该先于 init_quote 调用
'''
xtdc.set_token('填写自己的token')
xtdc.init()
xtdc.listen()
# xtdata.connect()
print('-----连接上了------')
print(xtdata.data_dir)
xtdata.run()
2.采用订阅函数xtdata.subscribe_quote,period的参数为snapshotindex
#coding:utf-8
"""获取涨速"""
import sys
print("Python 版本:", sys.version)
import time
from xtquant import xtdatacenter as xtdc
from xtquant import xtdata
# 连接自己的端口
# xtdata.connect(port=58610)
print(xtdata.data_dir)
s = '000001.SZ'
def on_data(datas):
"""
主推送实时涨速
"""
print(datas)
# 盘中实时获取涨速
xtdata.subscribe_quote(s, period='snapshotindex', start_time='', end_time='', count=-1, callback=on_data)
# 如果想获取历史的(在盘后进行订阅下)可将此代码放开
# seq = xtdata.subscribe_quote(s, period='snapshotindex', start_time='', end_time='', count=-1,)
# day_data = xtdata.get_market_data_ex([], [s], period='snapshotindex', start_time='', end_time='', count=-1,dividend_type='none', fill_data=True)
# print(day_data)
xtdata.run()
3.展示效果(展示为当日每分钟涨速)

|