import redis

 r = redis.Redis(host='127.0.0.1',password='',db=1,port=6379)  # 连接redis

 r.set('jack','狂')    # 数据库里面新增了一个key

 r.set('jack','疯癫')  # key存在用set就可以修改值

 r.delete('jack')      # 删除指定的key

 r.setex('rose','漂亮',100)  # 设置key的失效时间，单位是秒

 hwt = r.get('jack')         # 获取key的值，返回的是二进制数据，如果key不存在则返回None

 print(hwt.decode())         # 把二进制（bytes）转成字符串

 print(r.keys())             # 获取所有key

 print(r.keys('niu*'))       # 获取所有'niu'开头的key

 r.set('双鱼座:niuniu','浪') # 冒号前面就是加的目录名字

 print(r.get('user:luolei').decode())  # 获取key的值并将二进制（bytes）转化为字符串

 r.flushdb()                # 清空redis

 # 删除所有的key

 for k in r.keys():

     r.delete(k)

 import redis

 r = redis.Redis(host='127.0.0.1',password='',db=1,port=6379)  # 连接redis

 r.hset('stu_info','刘伟','1000万')     # 新增一个key，大key是stu_info，小key是'刘伟'

 r.hset('stu_info','张流量','交作业0')  # 新增一个key，大key是stu_info，小key是'张流量'

 r.hset('stu_info','董春光','发红包0')  # 新增一个key，大key是stu_info，小key是'董春光'

 print(r.type('stu_info'))                    # 查看key是什么类型的

 print(r.hget('stu_info','张流量').decode())  # 指定大key和小key获取对应的value

 print(r.hgetall('stu_info'))   # 获取里面所有的key和value，返回的是一个字典,里面的key和value都是二进制的

 r.hdel('stu_info','张流量')    # 删除指定的key

 r.delete('stu_info')           # 删除整个大key

 r.expire('jack',100)           # 对一个key设置失效时间,string类型和hash类型都可以用

 # 把r.hgetall返回的字典里面的key和value转成字符串

 dic = {}

 for key,value in r.hgetall('stu_info').items():

     dic[key.decode()] = value.decode()

 print(dic)

 import pymysql,redis,json

 r = redis.Redis(host='127.0.0.1',password='',db=1,port=6379)

 conn = pymysql.connect(host='192.168.1.112',user='test',passwd='',port=3306,db='test',charset='utf8')

 sql = 'select * from my_user;'

 cur = conn.cursor(cursor=pymysql.cursors.DictCursor)

 cur.execute(sql)

 all_data = cur.fetchall()

 for data in all_data:

     key = data.get('username')

     r.hset('stu_info_test',key,json.dumps(data))

 cur.close()

 conn.close()