数据库与数据库之间的交互

redis与mongodb之间的交互

import redis
from pymongo import MongoClient
from json import loads

# 连接redis数据库
r_client = redis.Redis(host='localhost',port=6378,db=0)
# 连接 mongo数据库
m_client = MongoClien()

# 获取指定的集合
collect = m_client.db.collect

# 获取数据
while True:
    try:
        s,d=r_client.bloop(["dmoz:items"],timeout=2)
    execpt Execption as e:
        # 关闭连接
        m_client.close()
        r_client.close()
    # 转换数据
    data = loads(d)
    collect.insert_one(data)