1.40K 浏览
0
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日
0

支持,但是尽量别copy和改动原来的K,会影响某些推进

李思恒 已回答的问题 2024年4月25日
您正在查看1个答案中的1个,单击此处查看所有答案。