redis

安装驱动

pip3 install redis

一个简单的数据库封装

import redis
import config


class RedisPool:
    pool = None

    def __init__(self, host=config.REDIS_HOST, port=config.REDIS_PORT, db=config.REDIS_DB):
        self.pool = redis.ConnectionPool(host=host, port=port, db=db, decode_responses=True)

    def getPool(self):
        return self.pool


class RedisConn:
    conn = None
    prefix = None

    def __init__(self, host=config.REDIS_HOST, port=config.REDIS_PORT, db=config.REDIS_DB, prefix=config.REDIS_PREFIX,
                 pool=None):

        self.prefix = prefix

        if pool is None:
            self.conn = redis.Redis(host=host, port=port, db=db, decode_responses=True)
        else:
            self.conn = redis.Redis(connection_pool=pool)

    def processName(self, name):
        return self.prefix + ":" + name

    def set(self, name, value, ex=None, px=None, nx=False, xx=False, keepttl=False):
        return self.conn.set(self.processName(name), value, ex, px, nx, xx, keepttl)

    def get(self, name):
        return self.conn.get(self.processName(name))

    '''
        用到再补充，把常用的填充进来就行了
    '''


def example():
    redisConn = RedisConn()
    redisConn.set("test", "value")
    print(redisConn.get("test"))

    redisPool = RedisPool().getPool()
    redisConn = RedisConn(pool=redisPool)
    redisConn.set("test_pool", "value_pool")
    print(redisConn.get("test_pool"))

    return True