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 **
19:48:26,显示k线最后一根柱datetime变化