base_mongodb.py 文件源码

def mongo_wait_connected_on_coro(coro, *args, **kwargs):
    retry = 0
    while True:
        retry += 1
        try:
            res = await coro(*args, **kwargs)
            if retry > 1:
                print('Restored mongo connection in {}'.format(coro))
            return res
        except AutoReconnect:
            print('Waiting for mongo connection in {}'.format(coro))
            await asyncio.sleep(1.0)