场景化示例

判断市场状态，获取市场最新分钟K线

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()