使用QMT做量化策略，QMT怎么获取历史行情数据和实时行情数据？

获取行情数据

交易类数据提供股票的交易行情数据，通过API接口调用即可获取相应的数据。

具体请查看API, 数据获取部分行情相关接口数据获取函数。

获取历史行情与实时行情

提示

内置Python

调用方法

内置python

ContextInfo.get_market_data_ex(

fields=[],

展开全文

stock_code=[],

period='follow',

start_time='',

end_time='',

count=-1,

dividend_type='follow',

fill_data=True,

subscribe=True)

释义

获取实时行情与历史行情数据

返回值

返回dict { stock_code1 : value1, stock_code2 : value2, ... }

value1, value2, ... ：pd.DataFrame 数据集，index为time_list，columns为fields,可参考Bar字段

各标的对应的DataFrame维度相同、索引相同

# coding:gbk

def init(C):

start_date = '20231001'# 格式"YYYYMMDD"，开始下载的日期，date = ""时全量下载

end_date = ""

period = "1d"

need_download = 1 # 取数据是空值时，将need_download赋值为1，确保正确下载了历史数据

code_list = ["000001.SZ", "600519.SH"] # 股票列表

if need_download: # 判断要不要下载数据, gmd系列函数都是从本地读取历史数据,从服务器订阅获取最新数据

my_download(code_list, period, start_date, end_date)

############ 仅获取历史行情 #####################

subscribe = False # 设置订阅参数，使gmd_ex仅返回本地数据

count = -1 # 设置count参数，使gmd_ex返回全部数据

data1 = C.get_market_data_ex([],code_list,period = period, start_time = start_date, end_time = end_date,subscribe = subscribe)

############ 仅获取最新行情 #####################

subscribe = True # 设置订阅参数，使gmd_ex仅返回最新行情

count = 1 # 设置count参数，使gmd_ex仅返回最新行情数据

data2 = C.get_market_data_ex([],code_list,period = period, start_time = start_date, end_time = end_date,subscribe = subscribe, count = 1) # count 设置为1，使返回值只包含最新行情

############ 获取历史行情+最新行情 #####################

subscribe = True # 设置订阅参数，使gmd_ex仅返回最新行情

count = -1 # 设置count参数，使gmd_ex返回全部数据

data3 = C.get_market_data_ex([],code_list,period = period, start_time = start_date, end_time = end_date,subscribe = subscribe, count = -1) # count 设置为-1，使返回值包含最新行情和历史行情

print(data1[code_list[0]].tail())# 行情数据查看

print(data2[code_list[0]].tail())

print(data3[code_list[0]].tail())

def handlebar(C):

return

def my_download(stock_list,period,start_date = '', end_date = ''):

用于显示下载进度

if "d" in period:

period = "1d"

elif "m" in period:

if int(period[0]) < 5:

period = "1m"

else:

period = "5m"

elif "tick" == period:

pass

else:

raise KeyboardInterrupt("周期传入错误")

n = 1

num = len(stock_list)

for i in stock_list:

print(f"当前正在下载{n}/{num}")

download_history_data(i,period,start_date, end_date)

n += 1

print("下载任务结束")