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日