data_quality_server/update_data.py

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

MongodbConfig = {
    "ip_port": "127.0.0.1:27092",
    "user": "viewdata",
    "password": "viewdata",
    "db": "qfw",
}
mdb = MongoDBInterface(MongodbConfig)

MongodbConfigInsert = {
    "ip_port": "192.168.3.166:27082",
    "db": "zhengluming_27082",
}
insertdb = MongoDBInterface(MongodbConfigInsert)

# 连接MongoDB数据库
with MongoClient('192.168.3.166', 27082) as client:
    db = client.zhengluming
    coll = db.f_sourceinfo_HP_channel_succes_data
    for row in coll.find({"historyId": "655707de7f39550da1f59d3d"}, {"id": 1}).sort("_id", 1):
        _id = row.get("id", "")
        print(row["_id"])
        if _id:
            m_id = ObjectId(_id)
            result=mdb.find_by_id("bidding",m_id)
            result["id"]=str(row["_id"])
            if result:
                insertdb.insert2db("update_data",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 吉木萨尔县大有镇人民政府 新疆 昌吉回族自治州 ['建材']  []
"""