python操作mongodb之五大量写操作

import pymongo

#库名

db = pymongo.MongoClient('192.168.30.252',27017).bulk_example

#test集合插入

db.test.insert_many([{'i':i} for i in xrange(10000)]).inserted_ids

db.test.count()

＃有条理的大规模数据写入

bulk = db.test.initialize_ordered_bulk_op()

# Remove all documents from the previous example.

bulk.find({}).remove()

bulk.insert({'_id': 1})

bulk.insert({'_id': 2})

bulk.insert({'_id': 3})

#更新

bulk.find({'_id': 1}).update({'$set': {'foo': 'bar'}})

＃插入替换

bulk.find({'_id': 4}).upsert().update({'$inc': {'j': 1}})

#替换

bulk.find({'j': 1}).replace_one({'j': 2})

#execute是执行

result = bulk.execute()

pprint(result)

#存在异常 的处理

from  pymongo.errors import BulkWriteError

#缓存队列

bulk=db.test.initialize_ordered_bulk_op()

#查找j=2 然后替换成j=5

bulk.find({'j': 2}).replace_one({'i': 5})

#插入id＝4

bulk.insert({'_id':4})

bulk.find({'i':5}).remove_one()

try:

	bulk.execute()

except BulkWriteError as bwe:

	pprint(bwe.details)  

from  pymongo.errors import BulkWriteError

bulk = db.test.initialize_unordered_bulk_op()

bulk.insert({'_id': 1})

bulk.find({'_id': 2}).remove_one()

bulk.insert({'_id': 3})

bulk.find({'_id': 4}).replace_one({'i': 1})

try:

	bulk.execute()

except BulkWriteError as bwe:

	pprint(bwe.details) 

#初始化队列

bulk = db.test.initialize_ordered_bulk_op()

bulk.insert({'a': 0})

bulk.insert({'a': 1})

bulk.insert({'a': 2})

bulk.insert({'a': 3})

try:

	bulk.execute({'wtimeout': 1})

except BulkWriteError as bwe:

	pprint(bwe.details)