spider_tx.py 文件源码

def init_db(self):

        self.redis = None
        self.mongo_conf = None
        self.mongo = None

        try:
            self.mongo_conf = yield txmongo.MongoConnection(host=self.setting.CONF_MONGO_HOST, port=self.setting.CONF_MONGO_PORT)
            self.mongo = yield txmongo.MongoConnection(host=self.setting.DATA_MONGO_HOST, port=self.setting.DATA_MONGO_PORT)
            self.redis = yield txredisapi.Connection(host=self.setting.QUEUE_REDIS_HOST, port=self.setting.QUEUE_REDIS_PORT)
            yield self.mongo.admin.authenticate("root", "chenfuzhi")
            yield self.mongo_conf.admin.authenticate("root", "chenfuzhi")

            defer.returnValue(True)
        except Exception, e:
            import traceback
            traceback.print_exc()
            defer.returnValue(False)