90807 发表于 2016-11-3 09:33:19

基于python+mysql+redis缓存设计与数据库关联数据处理

1、添加表
CREATE TABLE tb_signin(
id INT,
user_name VARCHAR(10),
signin_num INT ,
signin_time DATETIME ,
gold_coin INT
);
INSERT INTO tb_signin
VALUES(1, 'ma', 0, NULL, 0),
(2, 'he', 0, NULL, 0),
(3, 'yu', 0, NULL, 0),
(4, 'hai', 0, NULL, 0),
(5, 'fang', 0, NULL, 0);
2、redis缓存键值设计
key               value
表名:主键值:列名   列值
或者:
表名:主键值:列值1:列名1
示例:把id为1的人的签到次数(假设为5)存储到redis中则可如下操作:
set('tb_signin_rank:1:signin_num', 5)
类似数据库一样,通过主键便可获取其它值
3、redis关联数据库的数据处理模式:
如图,先判断是否存在缓存(通常是根据key),如果存在则从缓存读取,否则从数据库读取并更新缓存

适用场景:对数据实时性要求不高,更新比较不频繁

如下图,先写入redis然后,利用守护进程等方式,定时写入到数据库


如下图,先写入数据库,然后再更新到缓存

####

import ConfigParserimport sysimport redisimport MySQLdb__name__ ==:    pool=redis.ConnectionPool(=,=,=)    r=redis.Redis(=pool)    config=ConfigParser.ConfigParser()    :      dbcon=MySQLdb.connect(=,=,=,=,=,=)    MySQLdb.Error,e:      ,e      sys.exit()    :         db_cursor=dbcon.cursor()         id (,):             db_cursor.execute(,id)             db_cursor.execute()         r.zincrby(, id, )    e:         (% e)         db_cursor.execute()         db_cursor.close()         ()    id (,):      result=r.zscore(,id)      result:            :                db_cursor=dbcon.cursor()                db_cursor.execute(,id)                result=db_cursor.fetchone()[]                r.zadd(,id,result)            e:                % e                db_cursor.close()      :            ()            result = (result)      (% (id, result))###
zadd:命令用于将一个或多个成员元素及其分数值加入到有序集当中
zscore:命令返回成员的有序集合在键比分。如果成员没有在排序集合存在,或键不存在,则返回nil。

页: [1]
查看完整版本: 基于python+mysql+redis缓存设计与数据库关联数据处理