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

from pymongo import MongoClient
from bson import ObjectId
from lib.mongo_tools import MongoUtil,Data_save,MongoSentence
#拉取mongo数据
#复制mongo数据源 从一个源1到源2

#mongo库 源1
# 连接到源数据库
collection = MongoClient(f'mongodb://127.0.0.1:27099/',unicode_decode_error_handler="ignore", directConnection=True)['jyqyfw']['usermail']
query = {"appid": "jyGQ1XQQsEAwNeSENOFR9D", "comeintime": {"$gte": 1735488000, "$lt": 1735574400}}
source_coll_user = collection.find(query)

# 连接到目标数据库
db = MongoClient('192.168.3.149', 27180, unicode_decode_error_handler="ignore").data_quality
target_coll_user = db["liantong"]

for item in source_coll_user:
    target_coll_user.insert_one(item)
    print("数据复制完成")