@classmethod
def _getPipeline(cls, mode='master', transaction=False):
    """
        Create a pipeline object
        @TODO: support master/slave
        """
    conn = cls._getConnection(mode=mode)
    return conn.pipeline(transaction=transaction)
