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

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

分享
# _*_ coding:utf-8 _*_
import json
import pymongo
import redis
def process_item():
# 创建redis数据库链接
rediscli = redis.Redis(host='127.0.0.1', port=6379, db='0')
# 创建MongoDB数据库链接
mongodbcli = pymongo.MongoClient(host='127.0.0.1', port=27017)
# 创建mongodb数据库名称
dbname = mongodbcli['redis_mongodb']
# 创建mongodb数据库表的名称
sheetname = dbname['redis_mongodb_dgq']
offset = 0
while True:
# redis 数据表名 和 数据
source, data = rediscli.blpop("dongguanquestion:items")
offset += 1
# 将json对象转换为Python对象
data = json.loads(data)
# 将数据插入到sheetname表里
sheetname.insert(data)
print offset
if __name__ == "__main__":
process_item()

最新文章

123

最新摄影

闪念基因

微信扫一扫

第七城市微信公众平台