3.24K 浏览
0

replay = TqReplay(date(2020, 10, 21))
api = TqApi(backtest=replay, auth=TqAuth("yyy", "uuu"))
 replay.set_replay_speed(10)
 klines = api.get_kline_serial(SYMBOL, 60*5, 160)   # 5分钟k线
 while True:
    api.wait_update()
     if api.is_changing(klines.iloc[-1], "datetime"):
        print("复盘推送的时间========", quote.datetime)
                  print(klines.iloc[-1].open)
        print(klines.iloc[-1].high)
        print(klines.iloc[-1].low)
        print(klines.iloc[-1].close)
          复盘推送的时间======== 2020-10-20 21:00:23.000000
3616.0
3622.0
3616.0
3619.0
复盘推送的时间======== 2020-10-20 21:05:00.000000
3621.0
3621.0
3621.0
3621.0
复盘推送的时间======== 2020-10-20 21:10:01.500000
3621.0
3621.0
3621.0
3621.0
复盘推送的时间======== 2020-10-20 21:15:00.500000
3617.0
3617.0
3617.0
3617.0
复盘推送的时间======== 2020-10-20 21:20:01.000000
3616.0
3616.0
3615.0
3615.0
复盘推送的时间======== 2020-10-20 21:25:01.000000
3617.0
3617.0
3617.0
3617.0
复盘推送的时间======== 2020-10-20 21:30:01.000000
3614.0
3614.0
3614.0
3614.0

ringo 已回答的问题 2020年10月26日
1

kline.iloc[-1] 表示的是最新的这一根正在变化的kline,在他刚刚生成的时候,他的高开低收均为上一根kline的close

ringo 已回答的问题 2020年10月26日