2.16K 浏览
0
def f():
    instrument = "SHFE.pb2201"
    k = api.get_kline_serial(instrument, 60, 250)
    return k

api= TqApi(TqKq(), auth=TqAuth("嘻嘻嘻", "ddd"))
instrument="SHFE.pb2201"
k=f()

while api.wait_update():
    print(datetime.time(datetime.now()).strftime("%H:%M:%S"), "**" )
    if api.is_changing(k.iloc[-1], "datetime"):  #
        print(datetime.time(datetime.now()).strftime("%H:%M:%S"),"--------------"+instrument+"------------------")

结果为:

19:28:49 **

2021-11-25 19:28:49 –  WARNING – 通知: 与 wss://free-api.shinnytech.com/t/nfmd/front/mobile 的网络连接断开,请检查客户端及网络是否正常

2021-11-25 19:28:49 –  WARNING – 通知: 与 wss://otg-sim.shinnytech.com/trade 的网络连接断开,请检查客户端及网络是否正常

19:48:25 **

2021-11-25 19:48:25 –  WARNING – 通知: 开始与 wss://otg-sim.shinnytech.com/trade 的重新建立网络连接

19:48:25 **

2021-11-25 19:48:25 –  WARNING – 通知: 开始与 wss://free-api.shinnytech.com/t/nfmd/front/mobile 的重新建立网络连接

19:48:26 **

19:48:26 ————–SHFE.pb2201——————

2021-11-25 19:48:26 –  WARNING – 通知: 与 wss://free-api.shinnytech.com/t/nfmd/front/mobile 的网络连接已恢复

19:48:26 **

2021-11-25 19:48:26 –     INFO – 通知: 登录成功

2021-11-25 19:48:26 –  WARNING – 通知: 与 wss://otg-sim.shinnytech.com/trade 的网络连接已恢复

19:48:26 **

nabatieqiao 已回答的问题 2021年11月26日

19:48:26,显示k线最后一根柱datetime变化

0
while True:
    api.wait_update()
    print(datetime.time(datetime.now()).strftime("%H:%M:%S"), "**" )
    if api.is_changing(k.iloc[-1], "datetime"):  #
        print(datetime.time(datetime.now()).strftime("%H:%M:%S"),"--------------"+instrument+"------------------")
nabatieqiao 已回答的问题 2021年11月26日
0

后面打印的是啥,应该是不会的,因为会判断交易时间

李思恒 已回答的问题 2021年11月26日