时间:2021-07-01 10:21:17 帮助过:14人阅读
def op_redis(host,password,k,v=None,port=6379,db=0):
r = redis.Redis(host=host,password=password,port=port,db=db)
if v:
r.set(k,v)
res = ‘ok‘
else:
res = r.get(k)
if res: #这里是判断有没有get到数据
res = res.decode()
else:
res = None
return res
# print(__name__)
# print(‘哈哈哈哈,我在这里头‘)
# if __name__==‘__main__‘:
# #别人导入这个python文件的时候,下面的代码不会被执行
# #自己测试的时候用
# print(__name__) # __main__
# # print(‘哈哈哈哈哈哈 到底有没有执行‘)
# sql = ‘select * from bt_stu limit 5;‘
# sql2 = ‘update bt_stu set class="天蝎座3" where id=503;‘
# res = op_mysql(
# host=‘211.149.218.16‘,
# user=‘jxz‘,password=‘123456‘,#port这里一定要写int类型
# port=3306,db=‘jxz‘,charset=‘utf8‘,sql=sql2)
# print(res)
redis 数据迁移
import redis
src_redis = redis.Redis(host=‘211.149.218.16‘,port=6379,password=‘123456‘,db=2)#连上redis
target_redis = redis.Redis(host=‘211.149.218.16‘,port=6379,password=‘123456‘,db=14)#连上redis
for key in src_redis.keys():
if src_redis.type(key) == b‘string‘: #判断key的类型,因为redis数据取出来都是二进制的,所以这里也用bytes
v = src_redis.get(key) #先获取到原来的数据
target_redis.set(key,v) #再set到新的里面
else:
all_hash_data = src_redis.hgetall(key) #先获取到hash类型里面所有的数据
for k,v in all_hash_data.items(): #因为hash类型的获取到之后是一个字典,所以这里循环字典
target_redis.hset(key,k,v) #key是外面的大key,k是里面的小k,v就是小k对应的value
day6-Python学习笔记(十三)redis数据库
标签:get update delete 判断 文件 导入 学习笔记 自己 word