quality_tools/tools/从mongo导出数据/mongo_into_mongo_ai.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_ai",
}

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("655ec5609aed6eb2ffa654ca")

# 连接MongoDB数据库
with MongoClient('192.168.3.149', 27180) as client:
    #源2
    db = client.data_quality
    coll = db.standard_sample_data
    for row in coll.find().sort("_id", 1):
    # for item in coll_user.find({"_id": {"$gte": max_id}}).sort("_id", 1):
        _id = row.get("_id", "")
        # print(row["_id"])
        if _id:
            m_id = ObjectId(_id)
            result=mdb.find_by_id("bidding",m_id)
            if result==None:
                print(str(row["_id"])+"在大库没找到")
            if result:
                result["_id"] = ObjectId(row["_id"])
                insertdb.insert2db("standard_sample_data_all_ai",result)

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


"""

http://172.17.162.35:8880/search

# 深圳分公司安检信息系统维护服务 0.0 南方航空物流股份有限公司 广东 深圳市 ['安检']  []
# 运输事业发展中心信息系统运维-交通委北区机房、视频会议及运输中心终端运维管理技术服务项目 825250.0 北京市运输事业发展中心 北京 北京市 ['运输事业发展中心信息系统运维 交通委北>区机房 视频会议及运输中心终端运维管理技术服务项目', '运输事业发展中心信息系统运维 交通委北区机房 视频会议及运输中心终端运维管理技术服务项目'] 北京航天星桥科技股份有限公司 []
# 软件开发项目(软件开发-拓信智防) 0.0 指定集成公司与河北拓信智防电子科技有限公司 河北 保定市 ['车辆管理平台']  []
# 新乡高新技术产业开发区社会治理委员会“雪亮工程”维保项目 3410000.0 新乡高新技术产业开发区社会治理委员会 河南 新乡市 ['维保', '雪亮工程']  []
# 山西省大同市第三人民医院新建医技、急诊楼配套项目(暂估价)医用箱式中型物流传输系统采购项目 20028500.0 山西省大同市第三人民医院 山西 大同市 ['箱式中型物流']  []
# 山西省大同市第三人民医院新建医技、急诊楼配套项目(暂估价)医用箱式中型物流传输系统采购项目 20028500.0 山西省大同市第三人民医院 山西 大同市 ['物流系统']  []


广州市白云区三元里群英大街13号加装电梯工程 0.0 广州市白云区三元里群英大街13号加装电梯工程 广东 广州市 ['电梯']  []
软件开发服务(二次)软件开发服务 6500000.0 呼伦贝尔市住房和城乡建设局 内蒙古 呼伦贝尔市 ['软件', '软件开发服务 二次 软件开发服务']  []
富顺县救灾物资储备库建设工程项目 2346407.0 富顺县应急管理指挥中心 四川 自贡市 ['备库建设', '救灾物资']  []
中共成都市委党校明志楼多媒体教室LED屏采购项目 650000.0 中共成都市委党校 四川 成都市 ['LED一体机', '触控一体机'] 成都香草山信息技术有限责任公司 []
吉木萨尔县大有镇村庄规划(2021-2035年)编制项目 150000.0 吉木萨尔县大有镇人民政府 新疆 昌吉回族自治州 ['建材']  []
"""