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

例子只是作为异步用法的一个演示,我试过例子是没问题的,但是不是唯一写法,可以看看python的异步

李思恒 已回答的问题 2023年2月10日