train.py 文件源码

def __init__(self):
        super(TrainCenter, self).__init__()

        info = config['pubsub']
        self.host = info[0]
        self.port = int(info[1])
        self.raw_conn = redis.StrictRedis(host=self.host, port=self.port, db=0)
        self.conn = Connection(self.raw_conn)

        self.train_sessions = []