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

# _*_ 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()