def kline(api, contract, period):
    klines = api.get_kline_serial(contract, period, 60) # 获取k线
    while True:
        api.wait_update()
        print("%s: 开盘:%s, 最高价格:%s, 最低价格:%s, 收盘价格:%s" % (
time_to_str(klines.iloc[-1].datetime), klines.iloc[-1].open, klines.iloc[-1].high, klines.iloc[-1].low, klines.iloc[-1].close))
  api = TqApi(backtest=TqBacktest(start_dt=date(2019, 12, 8), end_dt=date(2019, 12, 8)))
kline(api, "SHFE.rb2001", 15*m)
api.close()
ringo 已回答的问题 2019年12月10日