test.py 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. from pymongo import MongoClient
  2. from bson import ObjectId
  3. from lib.mogodb_helper import MongoDBInterface
  4. #复制mongo数据源 从一个源到另一个源
  5. #mongo库 源1
  6. # MongodbConfig = {
  7. # "ip_port": "127.0.0.1:27092",
  8. # "user": "viewdata",
  9. # "password": "viewdata",
  10. # "db": "qfw",
  11. # }
  12. MongodbConfig = {
  13. "ip_port": "192.168.3.149:27180",
  14. "db": "data_quality",
  15. }
  16. mdb = MongoDBInterface(MongodbConfig)
  17. #mongo库 源2
  18. MongodbConfigInsert = {
  19. "ip_port": "192.168.3.149:27180",
  20. "db": "data_quality",
  21. }
  22. insertdb = MongoDBInterface(MongodbConfigInsert)
  23. # 连接MongoDB数据库
  24. with MongoClient('192.168.3.149:27180') as client:
  25. db = client.data_quality
  26. coll = db.bidding_20241107
  27. for row in coll.find({ "_id" : { "$gte" : ObjectId("672c5b7e5c97a83c5a116550") }}).sort("_id", 1):
  28. title = row.get("title", "")
  29. if title:
  30. result=mdb.find_rule_by_title("bidding_20241107_ai",title)
  31. if result:
  32. result_title=result.get("title","")
  33. if result_title==title:
  34. print(row["title"])
  35. result_id = result.get("_id", "")
  36. coll.update_one({"_id": row["_id"]}, {"$set": {"flag": 2}})
  37. mdb.update_by_id("bidding_20241107_ai",result_id,{"flag": 2})
  38. # 关闭数据库连接
  39. client.close()
  40. """
  41. http://172.17.162.35:8880/search
  42. # 深圳分公司安检信息系统维护服务 0.0 南方航空物流股份有限公司 广东 深圳市 ['安检'] []
  43. # 运输事业发展中心信息系统运维-交通委北区机房、视频会议及运输中心终端运维管理技术服务项目 825250.0 北京市运输事业发展中心 北京 北京市 ['运输事业发展中心信息系统运维 交通委北>区机房 视频会议及运输中心终端运维管理技术服务项目', '运输事业发展中心信息系统运维 交通委北区机房 视频会议及运输中心终端运维管理技术服务项目'] 北京航天星桥科技股份有限公司 []
  44. # 软件开发项目(软件开发-拓信智防) 0.0 指定集成公司与河北拓信智防电子科技有限公司 河北 保定市 ['车辆管理平台'] []
  45. # 新乡高新技术产业开发区社会治理委员会“雪亮工程”维保项目 3410000.0 新乡高新技术产业开发区社会治理委员会 河南 新乡市 ['维保', '雪亮工程'] []
  46. # 山西省大同市第三人民医院新建医技、急诊楼配套项目(暂估价)医用箱式中型物流传输系统采购项目 20028500.0 山西省大同市第三人民医院 山西 大同市 ['箱式中型物流'] []
  47. # 山西省大同市第三人民医院新建医技、急诊楼配套项目(暂估价)医用箱式中型物流传输系统采购项目 20028500.0 山西省大同市第三人民医院 山西 大同市 ['物流系统'] []
  48. 广州市白云区三元里群英大街13号加装电梯工程 0.0 广州市白云区三元里群英大街13号加装电梯工程 广东 广州市 ['电梯'] []
  49. 软件开发服务(二次)软件开发服务 6500000.0 呼伦贝尔市住房和城乡建设局 内蒙古 呼伦贝尔市 ['软件', '软件开发服务 二次 软件开发服务'] []
  50. 富顺县救灾物资储备库建设工程项目 2346407.0 富顺县应急管理指挥中心 四川 自贡市 ['备库建设', '救灾物资'] []
  51. 中共成都市委党校明志楼多媒体教室LED屏采购项目 650000.0 中共成都市委党校 四川 成都市 ['LED一体机', '触控一体机'] 成都香草山信息技术有限责任公司 []
  52. 吉木萨尔县大有镇村庄规划(2021-2035年)编制项目 150000.0 吉木萨尔县大有镇人民政府 新疆 昌吉回族自治州 ['建材'] []
  53. """