spider_engine.py 文件源码

def init_database(self):
        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")
        defer.returnValue(True)