在之前的文章中,我们实现了
基于flask框架和分层分模块的蓝图思想,集成sqlalchemy进行数据库操作
今天,我们要在此基础上,继续集成redis。目录结构如下所示
1.安装redis函数库
注意,python中的redis模块,建议不要太高,版本太高的,容易有其他问题,我这里之前是4.0版本(不是redis服务器的版本,是python模块中redis的版本),有许多冲突,因此我降低到2.10.6版本
pip3 install flask-redis
pip3 install -U redis==2.10.6
加上之前我们安装的函数库,就可以开始使用了。
pip install flask
pip install pymysql
pip install flask-sqlalchemy
2.编写myRedis.py文件
备注。这个文件叫什么名字无所谓,但是绝对不能叫做redis.py,因为已经存在了redis.py这个模块,如果将编写的py文件名字和已经存在的模块名字重复,将会导致覆盖。
from flask_redis import FlaskRedis
redis_store = FlaskRedis()
3.使用redis存储用户信息
从redis获取hash对象:redis_store.hget() 存hash对象到redis:redis_store.hset()
@user.route("/info/one/redis/<name>",methods=['get'])
def info_one_redis(name):
print("开始从redis查询数据")
user = redis_store.hget('user',name)
if user:
user = user.decode("utf-8")
user = ast.literal_eval(user)
print(user)
else:
print("没有查询到用户信息,接下来要查数据库")
user = user_service.query_one_userinfo(name)
print(user)
redis_store.hset('user',name,user)
return R.ok(user)
4.操作演示说明
1.查看数据库表信息 2.查询hutao这条数据 3.运行日志信息 通过日志,我们知道,一次查询没有从redis查询到数据,而是从数据库进行查询,从数据库查询完毕后,接下来我们将查询结果写入到redis。 我们存储到redis的数据库格式是hash模式,其数据格式如下:
{
"user":{
"hutao":{
"属性1":"属性1的值",
"属性2":"属性2的值"
},
"zhagnsan":{
"属性1":"属性1的值",
"属性2":"属性2的值"
},
"lisi":{
"属性1":"属性1的值",
"属性2":"属性2的值"
}
}
}
4.查询redis是否存储用户信息 你可以通过命令查看 也可以通过视图查看 5.重新查询hutao这个用户 可以发现,后台日志,不在查询数据库
5.注意事项问题说明
5.1.redis对于不同数据结构,使用不同的命令
redis五种数据类型:String,Hash,List,Set,Sorted Set,不同的数据类型,需要使用不同的命令存取数据。 例如本案例中,使用的是Hash,因此使用的命令就是hget,hset,hgetall这三个命令。
5.2.字符格式,json序列化,及乱码等问题
本案例中将使用hash存储是字典user,在我们取这个字典user时,存在一些问题 首先发现我们获取的数据类型他是字节类型,而我们存的时候是字典类型,并且中文不么还被转义了,因此这里,我先转成utf-8编码的字符串格式。 转成了字符编格式以后,如果直接返回给接口调用者,我发现,返回的并不是json对象,而是json字符串,因此我们的返回参数变得有点怪异,变成了data这个节点,我们需要的是对象,而不是字符串。 因此我们就需要将json字符串转变成字典,然后再返回,这时候就是一个json对象了。
user = ast.literal_eval(user)
但是仍然有一些问题没有得到解决,比如,当我的字符串里面有时间格式的时候,这时候无法转成字典,所以我在实体类里面把时间干掉了,因为我也没办法解决,毕竟我学习python才几天啊。
|