订阅所有市场股票实时行情,全推行情接口,需要连接专业服务器
参数
- callback 回调函数,用户自己实现
返回
- return SubAllQuotesParser
示例
def quotes_all_callback(response:dsxquant.parser):
dd = response.dataframe()
# 第一行默认是字段名称数组 ["amount","close",.....]
names:list = list(dd.values[0])
# 第二行开始是数据
quote = dd.loc[1,:]
code = quote[names.index("code")]
t = quote[names.index("lasttime")]
d = quote[names.index("lastdate")]
t = datetime.datetime.strptime(d+" "+t,"%Y-%m-%d %H:%M:%S")
s = datetime.datetime.now() - t
print("%s 笔 %s 时间 %s 当前时间 %s 延时 %s s" % (dd.__len__(),code,t,datetime.datetime.now(),s.seconds))
# 全量订阅全市场所有股票实时行情
dd_async.sub_all_quotes(quotes_all_callback)