base_mongodb.py 文件源码

def _connect(self):
        self._conn = motor.motor_asyncio.AsyncIOMotorClient(
            self._build_connection_string(),
            io_loop=self.loop
        )
        try:
            await self.wait_db()
        except AutoReconnect as e:
            self.logger.error("Couldn't connect to db %s", self.fingerprint)
            await self.wait_db()