quality_tools/tools/从mongo导出数据/mongo_into_mongo.py

from pymongo import MongoClient
from bson import ObjectId
from lib.mogodb_helper import MongoDBInterface

#复制mongo数据源 从一个源1到另一个源3
# 从源1中导入到源3 ，和源2 一样的数据
#mongo库 源1
# MongodbConfig = {
#     "ip_port": "127.0.0.1:27088",
#     "user": "viewdata",
#     "password": "viewdata",
#     "db": "qfw",
# }
MongodbConfig = {
    "ip_port": "172.20.45.129:27002",
    "db": "data_quality",
}
mdb = MongoDBInterface(MongodbConfig)
#mongo库 源3
# MongodbConfigInsert = {
#     "ip_port": "192.168.3.149:27180",
#     "db": "data_quality",
# }
# insertdb = MongoDBInterface(MongodbConfigInsert)

# max_id = ObjectId("0" * 24)
max_id = ObjectId("6826ab875463fc3ceb767fe5")

# 连接MongoDB数据库
with MongoClient('172.20.45.129', 27002) as client:
    #源2
    db = client.data_quality
    coll = db.bidding_202505_main
    # for row in coll.find().sort("_id", 1):
    for row in coll.find({"_id": {"$gt": max_id}}).sort("_id", 1):
        _id = row.get("_id", "")
        # print(row["_id"])
        if _id:
            # m_id = ObjectId(_id)
            result=mdb.find_by_id("bidding_202505",_id)
            if result==None:
                print(f"{_id}+在大库没找到")
            if result:
                result["_id"] = ObjectId(row["_id"])
                mdb.insert2db("bidding_202505_chouqu",result)

# 关闭数据库连接
client.close()