klines = await api.get_kline_serial(SYMBOL, 24*60*60) target_pos = TargetPosTask(api, SYMBOL) async with api.register_update_notify() as update_chan: async for _ in update_chan: if api.is_changing(klines.iloc[-1], "datetime"): 策略略过 # 为每个合约创建异步任务 api.create_task(demo("SHFE.rb2305")) api.create_task(demo("DCE.m2305")) while True: api.wait_update()
李思恒 已回答的问题 2023年2月10日