import json
import pymongo
from redis import StrictRedis
rediscli=StrictRedis(host='192.168.6.223',port=6379,db=0,decode_responses=True)
client=pymongo.MongoClient('mongoip',27017)
db=client.xixian
collention=db.demo
while True:
source, data = rediscli.blpop(["jincai_data:items"])
item = json.loads(data)
collention.insert_one(item)
print(item)
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
