from tqsdk import TqApi, TqAuth
from datetime import datetime
import logging
import coloredlogs
# api = TqApi(_stock=True)
api = TqApi(auth=TqAuth("acct", "pw"))
# quote = api.get_quote("SHFE.ni2010")
ticks = api.get_tick_serial('SSE.000016', data_length=2)
# ticks = api.get_tick_serial('SHFE.ni2110', data_length=2)
logging.getLogger('TqApi.TqSim').disabled = True
logging.basicConfig(
level=logging.DEBUG,
format='%(asctime)s - [%(filename)s:%(lineno)d] - %(levelname)s - %(message)s',
handlers=[
logging.StreamHandler()
])
coloredlogs.install(
fmt='%(asctime)s - [%(filename)s:%(lineno)d] - %(levelname)s - %(message)s',
milliseconds=True
)
while api.wait_update():
dt = datetime.fromtimestamp(ticks.iloc[-1]['datetime']/1e9)
ts = dt.strftime('%Y-%m-%d %H:%M:%S.%f')[:-3].split(' ')
last_price = ticks.iloc[-1]['last_price']
volume = int(ticks.iloc[-1]['volume']-ticks.iloc[-2]['volume'])
logging.info('%s %s %s %s time delay: %ss',ts[0], ts[1], last_price, volume, (datetime.now()-dt).total_seconds())
# time delay
api.close()
昨天正常， 今天就获取不到了。 获取期货行情ok， 股票指数不行， 请问什么问题？ 谢谢
ringo 已回答的问题 2021年7月29日
from tqsdk import TqApi, TqAuth
from datetime import datetime
import logging
import coloredlogs
# api = TqApi(_stock=True)
api = TqApi(auth=TqAuth(“acct”, “pw”))
# quote = api.get_quote(“SHFE.ni2010”)
ticks = api.get_tick_serial(‘SSE.000016’, data_length=2)
# ticks = api.get_tick_serial(‘SHFE.ni2110’, data_length=2)
logging.getLogger(‘TqApi.TqSim’).disabled = True
logging.basicConfig(
level=logging.DEBUG,
format=’%(asctime)s – [%(filename)s:%(lineno)d] – %(levelname)s – %(message)s’,
handlers=[
logging.StreamHandler()
])
coloredlogs.install(
fmt=’%(asctime)s – [%(filename)s:%(lineno)d] – %(levelname)s – %(message)s’,
milliseconds=True
)
while api.wait_update():
dt = datetime.fromtimestamp(ticks.iloc[-1][‘datetime’]/1e9)
ts = dt.strftime(‘%Y-%m-%d %H:%M:%S.%f’)[:-3].split(‘ ‘)
last_price = ticks.iloc[-1][‘last_price’]
volume = int(ticks.iloc[-1][‘volume’]-ticks.iloc[-2][‘volume’])
logging.info(‘%s %s %s %s time delay: %ss’,ts[0], ts[1], last_price, volume, (datetime.now()-dt).total_seconds())
# time delay
api.close()
代码格式怎么有点乱