新增线上数据同步

update_data.py

@@ -0,0 +1,54 @@
+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 吉木萨尔县大有镇人民政府 新疆 昌吉回族自治州 ['建材']  []
+"""

util/mogodb_helper.py

@@ -28,9 +28,10 @@ class MongoDBInterface:
             if self.__user:
                 self.client = MongoClient(
                     "mongodb://{}:{}@{}".format(self.__user, self.__password, self.__host),
-                    unicode_decode_error_handler='ignore')
+                    unicode_decode_error_handler='ignore', directConnection=True)
             else:
-                self.client = MongoClient("mongodb://{}".format(self.__host), unicode_decode_error_handler='ignore')
+                self.client = MongoClient("mongodb://{}".format(self.__host), unicode_decode_error_handler='ignore',
+                                          directConnection=True)
             self.db = self.client[self.__database]
         except AutoReconnect as e:
             self.connect()
@@ -74,3 +75,7 @@ class MongoDBInterface:
         if not row:
             return None
         return row.get("rules_id")
+
+    def insert2db(self, collection_name, data: dict):
+        collection = self.db[collection_name]
+        collection.insert_one(data)