klines = api.get_kline_serial(symbol='SHFE.rb2410', duration_seconds=60, data_length=50, chart_id='NONE')
kline100 = api.get_kline_serial(symbol='SHFE.rb2410', duration_seconds=30, data_length=50, chart_id='NONE')
while True:
    api.wait_update()
    copied_kline = klines.copy()
    copied_kline.rename(columns={'datetime': 'datetime'}, inplace=True)
    copied_kline.datetime = copied_kline.datetime.apply(tafunc.time_to_datetime)
    print(copied_kline.iloc[-1]["datetime"])
    print(type(copied_kline.iloc[-1]["datetime"]), copied_kline.iloc[-1]["datetime"])
     copied_kline100 = kline100.copy()
    copied_kline100.rename(columns={'datetime': 'datetime'}, inplace=True)
    copied_kline100.datetime = copied_kline100.datetime.apply(tafunc.time_to_datetime)
    print('@@@@@@@@@@@@@@@@@@@@@@@@@')
    print(copied_kline100.iloc[-1]["datetime"])
    print(type(copied_kline100.iloc[-1]["datetime"]), copied_kline100.iloc[-1]["datetime"])
我同时订阅同合约 不同时间段的数据流 代码只更新最下边的KLINE100 天勤是不是不支持同时订阅多个数据流 不同的时间段数据流 需要根据一个get_kline_serial 的data_length 进行 运算拼接?
李思恒 已回答的问题 2024年4月25日