scripts/vas/sync_zone_moment_price.py

32 lines
796 B
Python

from lib.all import *
col_zone_moment = MongoDB(
host="mongodb://root:Wishpal2024@dds-bp1a72ede37c55d4242490.mongodb.rds.aliyuncs.com:3717/admin",
port=3717,
db="zone_moment",
collection="zone_moment"
)
col_zone_moment_price = MongoDB(
host="mongodb://root:Wishpal2024@dds-bp1a72ede37c55d4242490.mongodb.rds.aliyuncs.com:3717/admin",
port=3717,
db="vas",
collection="zone_moment_price"
)
lis = col_zone_moment.find(
{"c_type": 1}, projection={"_id": 1, "price": 1}
)
for m in lis:
mmid = safe_get_int(m, "_id")
price = safe_get_int(m, "price")
vas_moment = col_zone_moment_price.find_one({"_id": mmid})
vas_price = safe_get_int(vas_moment, "price")
print(mmid, price, vas_price)
col_zone_moment.close()
col_zone_moment_price.close()