redis_loader_hook.py 文件源码

def get_conn(self):
        """
        Returns a redis connection object
        """
        conn_config = {
            "host": self.conn.host or 'localhost',
            "db": self.conn.schema or ''
        }

        if not self.conn.port:
            conn_config["port"] = 6379
        else:
            conn_config["port"] = int(self.conn.port)

        conn = StrictRedis(**conn_config)
        return conn

    #to set redis ey