【Django】配置MySQL数据库、Redis数据库、调用Redis（封装批量读取）

叁歲伎倆 2022-12-03 01:35 230阅读 0赞

#### 1.配置MySQL数据库 ####

关于在Django中安装MySQL数据库的方法可以参考之前的文章  
[Django数据库改成MySQL、ORM的字段类型和约束][Django_MySQL_ORM]

安装完之后我们只要在配置文件里（这里是dev.py）修改DATABASES列表即可

DATABASES = { 
        'default': { 
            'ENGINE': 'django.db.backends.mysql', # 数据库引擎
            'HOST': '127.0.0.1', # 数据库主机
            'PORT': 3306, # 数据库端口
            'USER': 'root', # 数据库用户名
            'PASSWORD': '123456', # 数据库用户密码
            'NAME': 'XXXX' # 数据库名字
        },
    }

在Django里使用MySQL一般会ORM操作，请参考  
[【Django】ORM模型类对数据库的增删改查][Django_ORM]  
[【Django】数据库改成MySQL、ORM的字段类型和约束][Django_MySQL_ORM]

#### 2.配置Redis数据库 ####

安装django-redis

pip install django-redis -i https://pypi.tuna.tsinghua.edu.cn/simple/

在配置文件（settings.py）里添加Redis的相关配置

CACHES = { 
        # 默认存储信息: 存到 0 号库
        "default": {  
            "BACKEND": "django_redis.cache.RedisCache",
            "LOCATION": "redis://127.0.0.1:6379/0",
            "OPTIONS": { 
                "CLIENT_CLASS": "django_redis.client.DefaultClient",
            }
        },
        # session 信息: 存到 1 号库
        "session": {  
            "BACKEND": "django_redis.cache.RedisCache",
            "LOCATION": "redis://127.0.0.1:6379/1",
            "OPTIONS": { 
                "CLIENT_CLASS": "django_redis.client.DefaultClient",
            }
        },
    }
    # 指定session的存储
    SESSION_ENGINE = "django.contrib.sessions.backends.cache"
    SESSION_CACHE_ALIAS = "session"

#### 3.Redis使用方法 ####

##### 3.1 方法1 #####

from django.core.cache import cache
    cache.set("key", "value", timeout=None) # timeout=0 立即过期，timeout=None 永不超时
    cache.get("key")

##### 3.2 方法2 #####

from django_redis import get_redis_connection
    conn = get_redis_connection("default")
    conn.hgetall('xxx')

有关django-redis的使用可以参考GitHub  
https://github.com/bluedazzle/django-redis-doc-chs/blob/master/source/index.rst

##### 3.3 封装Redis #####

在使用Redis队列的时候，我们需要批量取出，通过pipeline批量操作可提供效率，当然也保证了操作的原子性

from django_redis import get_redis_connection
    
    class RedisWrapper(object):
        def __init__(self, con, key):
            self.conn = con
            self.key = key
    
        def lpush(self, data):
            return self.conn.lpush(self.key, data)
    
        def llen(self):
            return self.conn.llen(self.key)
    
        def rpush(self, data):
            return self.conn.rpush(self.key, data)
    
        def lpop(self):
            return self.conn.lpop()
    
        def batch_lpop(self, n):
            pipeline = self.conn.pipeline()
            pipeline.lrange(self.key, 0, n - 1)
            pipeline.ltrim(self.key, n, -1)
            res = pipeline.execute()
            return res
    
    if __name__ == '__main__':
    	redis_ = RedisWrapper(get_redis_connection("default"), "ops_journal")

[Django_MySQL_ORM]: https://blog.csdn.net/qq_39147299/article/details/108277345
[Django_ORM]: https://blog.csdn.net/qq_39147299/article/details/108283013