python导入导出redis数据的实现
目录
一.导出redis某个库的数据使用python向Redis批量导入数据二.导入redis某个库的数据注:以String类型为例
一.导出redis某个库的数据
import redis import json file_path = "why.json" redis_conn = redis.Redis(host="192.168.1.123", port=6387, password="123zxcv", db=2, decode_responses=True) data_keys = redis_conn.keys() all_data = {} for i in data_keys: all_data[i] = json.loads(redis_conn.get(i)) file_object = open(file_path, "w", encoding="utf8") json.dump(all_data, file_object, ensure_ascii=False) file_object.close()
使用python向Redis批量导入数据
使用pipeline进行批量导入数据。包含先使用rpush插入数据,然后使用expire改动过期时间
class Redis_Handler(Handler): def connect(self): #print self.host,self.port,self.table self.conn = Connection(self.host,self.port,self.table) def execute(self, action_name): filename = "/tmp/temp.txt" batch_size = 10000 with open(filename) as file: try: count = 0 pipeline_redis = self.conn.client.pipeline() for lines in file: (key,value) = lines.split(",") count = count + 1 if len(key)>0: pipeline_redis.rpush(key,value.strip()) if not count % batch_size: pipeline_redis.execute() count = 0 #send the last batch pipeline_redis.execute() except Exception: print "redis add error"
二.导入redis某个库的数据
import redis import json file_path = "why.json" redis_conn = redis.Redis(host="192.168.1.123", port=6387, password="123zxcv", db=1, decode_responses=True) file_object = open(file_path, "r", encoding="utf8") all_data = json.load(file_object) for key in all_data: redis_conn.set(key, json.dumps(all_data[key], ensure_ascii=False)) file_object.close()
到此这篇关于python导入导出redis数据的实现的文章就介绍到这了,更多相关python导入导出redis内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
X 关闭
X 关闭
- 15G资费不大降!三大运营商谁提供的5G网速最快?中国信通院给出答案
- 2联想拯救者Y70发布最新预告:售价2970元起 迄今最便宜的骁龙8+旗舰
- 3亚马逊开始大规模推广掌纹支付技术 顾客可使用“挥手付”结账
- 4现代和起亚上半年出口20万辆新能源汽车同比增长30.6%
- 5如何让居民5分钟使用到各种设施?沙特“线性城市”来了
- 6AMD实现连续8个季度的增长 季度营收首次突破60亿美元利润更是翻倍
- 7转转集团发布2022年二季度手机行情报告:二手市场“飘香”
- 8充电宝100Wh等于多少毫安?铁路旅客禁止、限制携带和托运物品目录
- 9好消息!京东与腾讯续签三年战略合作协议 加强技术创新与供应链服务
- 10名创优品拟通过香港IPO全球发售4100万股 全球发售所得款项有什么用处?