mongo批量操作存在更新否则插入
def save_data(ok_ps): ns = [] for ok in ok_ps: ok['last_use_time'] = 0 ok['protocol'] = 0 # 协议类型 0:http ok['is_own'] = 1 ok['is_ok'] = 0 # 可用 ok['date'] = datetime.datetime.utcnow() ns.append(ReplaceOne({'ip': ok['ip']}, ok, upsert=True)) if len(ns) > 0: res = coll.bulk_write(ns)
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。