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

# _*_ coding:utf-8 _*_

import redis
import MySQLdb
import json


def 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()