首页 > 代码库 > python-redis-pipe文件
python-redis-pipe文件
redis导入数据比较头疼的事情，涉及几千万，导入还是很耗时，通过生成pipe文件的方式比较快捷。
python3.6.1版本 在linux环境下运行
with open("data1", "w") as f: for d in data: k = d["key"] v = d[‘value‘] f.write(‘*3\r\n$3\r\nset\r\n$%d\r\n%s\r\n$%d\r\n%s\r\n‘ %(len(bytes(k, ‘utf-8‘)), k, len(bytes(v, ‘utf-8‘)), v))
python2.7
for line in lines: line=line.strip(‘\n‘) jsonLine = json.loads(line) province = jsonLine["province"] if province == henan: key = jsonLine["company_name"] k = key.encode(‘utf-8‘) v = line print ‘*3\r\n$3\r\nset\r\n$%d\r\n%s\r\n$%d\r\n%s\r\n‘ %(len(k), k, len(v), v),
127.0.0.1:6379> select 10OK127.0.0.1:6379[10]> dbsize(integer) 2907521
python-redis-pipe文件
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。