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日