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