将数据从redis数据库中存储到本地的mysql数据库中

2018-03-01 11:15:36来源:oschina作者:邪云人点击

分享
# _*_ coding:utf-8 _*_
import redis
import MySQLdb
import jsondef process_item():
# 创建redis数据库连接
rediscli = redis.Redis(host='127.0.0.1', port=6379, db='0')
# 创建mysql数据库连接
mysqlcli = MySQLdb.connect(host='127.0.0.1', port=3306, user='root', password='123456', db="DG")
offset = 0
while True:
# 将数据从redis数据库中pop出来
source,data = rediscli.blpop("dongguanquestion:items")
item = json.loads(data)
# 创建mysql操作游标对象,可以执行myql语句
cursor = mysqlcli.cursor()
cursor.execute("insert into dg (表中的字段名) values(%s ...) " % [item['字段1'], item['字段2'], item['字段3'], item['字段n']])
# 提交事务
mysqlcli.commit()
# 关闭游标
cursor.close()
offset += 1
print offset
if __name__ == "__main__":
process_item()

最新文章

123

最新摄影

闪念基因

微信扫一扫

第七城市微信公众平台