import pandas as pd
from xtquant import xtdata
market = 'SH'
# 获取市场的品种列表
sl = xtdata.get_stock_list_in_sector(market)
def on_data(datas):
# 获取当前市场时间
# 根据推送的数据统计最新的tick时间作为当前市场时间
market_time = max([datas[i]["time"] for i in datas])
# 判断是否到达57秒,认为这时的分钟K线已经结束
if market_time % 60 >= 57:
print('reach 57 seconds, market_time:' + str(market_time))
# 获取这个时刻的分钟K线数据
data = xtdata.get_full_kline([], sl, '1m')
print(data)
return
# 订阅全推数据
xtdata.subscribe_whole_quote([market], callback = on_data)
# 保持程序运行
xtdata.run()