from pymongo import MongoClient
from pymongo import UpdateOne
import hashlib
import json

client1 = MongoClient(‘mongodb://188******6:27017’)

连接所需数据库

db1 = client1.yelp

连接所表

collection1 = db1.us_comments
print(collection1.find().count())

client2 = MongoClient(‘mongodb://:270***17’)

连接所需数据库

db2 = client2.yelp

连接所表

collection2 = db2.us_comments

print(collection1.find().limit(100))

print(list(collection1.find().limit(100)))

print(type(list(collection1.find().limit(100))))

1\insert_many 直接插入

try:
collection2.insert_many(list(collection1.find().limit(101)))
except Exception as e:
print(e)

2\bulk_write 插入并更新去重，必须结合UpdateOne使用，one是对象

arr = [] # 初始化一个空列表
for line in collection1.find():
one = UpdateOne(line,{’$set’:line}, upsert=True)
arr.append(one)
print(arr)
collection2.bulk_write(arr)

或者一段段插入


arr = []  # 初始化一个空列表
for line in collection1.find().limit(10):one = UpdateOne(line,{'$set':line}, upsert=True)arr.append(one)nums = len(arr)try:if nums == 3:collection2.bulk_write(arr)arr = []print("又一个5万")else:continueexcept Exception as e:print(e)pass
collection2.bulk_write(arr)

3、update_one

or item in collection1.find():
print(item)
try:
if item[‘comment_source’] == ‘ctrip’:
item["_id"] = item[“comment_detail”][‘id’]
print(item["_id"])
collection2.update_one({"_id": item["_id"]}, {"$set":item}, upsert=True)

mongo python大量插入insert_mang\bulk_write与更新update_one相关推荐

Python pymysql 插入数据一直不成功
Python pymysql 插入数据一直不成功明明插入语句正确,往MySQL插入数据时却怎么都不成功要使用commit()函数! import pymysqlprint("准备开始创建 ...
SqlBulkCopy与触发器，批量插入表(存在则更新,不存在则插入)
原文:SqlBulkCopy与触发器,批量插入表(存在则更新,不存在则插入) 临时表:Test /****** 对象: Table [dbo].[Test] 脚本日期: 05/10/2013 11:4 ...
判断触发器正在处理的是插入，删除还是更新触发
平常时写触发器(TRIGGER),一般会分别写插入(INSERT),删除(DELETE)和更新(UPDATE)单独的触发器. 但是有时候,可以视看处进逻辑程度,可以把三者写成一个触发器,只是在其中稍作 ...
mybatis批量插入(insert)和批量更新(update)
文章目录一.Mybatis批量插入二.批量更新前言:这两天在做mybatis批量插入和更新的时候,对这块不是很清楚,所以今天写篇文章,巩固加深印象. 一.Mybatis批量插入批量插入的sql ...
Python MySQL 插入表
Python MySQL 插入表 - 吴吃辣 - 博客园 Python MySQL 插入表章节 Python MySQL 入门 Python MySQL 创建数据库 Python MySQL 创建表 ...
arcengine,深入理解游标Cursors，实现数据的快速查找，插入，删除，更新
风过无痕原文 arcengine,深入理解游标Cursors,实现数据的快速查找,插入,删除,更新深入理解游标Cursors,实现数据的快速查找,插入,删除,更新 1.查找数据Search Cu ...
JDBC连接(MySql)数据库步骤，以及查询、插入、删除、更新等十一个处理数据库信息的功能。...
主要内容: JDBC连接数据库步骤. 一个简单详细的查询数据的例子. 封装连接数据库,释放数据库连接方法. 实现查询,插入,删除,更新等十一个处理数据库信息的功能.(包括事务处理,批量更新等) 把十 ...
jdbc mysql 存储过程查询数据_JDBC连接(MySql)数据库步骤，以及查询、插入、删除、更新等十一个处理数据库信息的功能。...
主要内容: JDBC连接数据库步骤. 一个简单详细的查询数据的例子. 封装连接数据库,释放数据库连接方法. 实现查询,插入,删除,更新等十一个处理数据库信息的功能.(包括事务处理,批量更新等) 把十一 ...
mysql插入实现存在更新_mysql 记录不存在时插入记录存在则更新的实现方法
mysql 记录不存在时插入在 MySQL 中,插入(insert)一条记录很简单,但是一些特殊应用,在插入记录前,需要检查这条记录是否已经存在,只有当记录不存在时才执行插入操作,本文介绍的就是这个问 ...

mongo python大量插入insert_mang\bulk_write与更新update_one

连接所需数据库

连接所表

连接所需数据库

连接所表

print(collection1.find().limit(100))

print(list(collection1.find().limit(100)))

print(type(list(collection1.find().limit(100))))

mongo python大量插入insert_mang\bulk_write与更新update_one相关推荐

最新文章

热门文章