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)