mongo_operator.py 文件源码

def __init__(self):
        try:
            self.Client = pymongo.MongoClient(host=self.HOST, port=self.PORT)
            self.db = self.Client.yitu8
            assert self.db.authenticate(self.user, self.pwd), "mongo???????!"
        except Exception as err:
            logging.error("mongo connect error: {}".format(str(err)))