18

使用 PyMongo,我在一个列表中有一组字典,我想提交给我的 MongoDB。列表中的一些项目是新条目,有些是要更新的。

例子:

在服务器数据库上:

[{"_id" : 1, "foo" : "bar}]

发送到数据库:

[{"_id" : 1, "foo" : "HELLO"}, {"_id" : 2, "Blah" : "Bloh"}]

我目前正在使用以下内容插入文档,但我将如何执行上述操作?任何帮助表示赞赏!

collection.insert(myDict)
4

4 回答 4

28

使用upsert选项:

from pymongo import MongoClient
cl = MongoClient()
coll = cl["local"]["test2"]

data = [{"_id" : 1, "foo" : "HELLO"}, {"_id" : 2, "Blah" : "Bloh"}]
for d in data:
    coll.update({'_id':d['_id']}, d, True)
于 2013-08-22T05:43:53.250 回答
8

您也可以使用保存

import pymongo
con = pymongo.MongoClient()
coll = con.db_name.collection_name

docs = [{"_id" : 1, "foo" : "HELLO"}, {"_id" : 2, "Blah" : "Bloh"}]

for doc in docs:
    coll.save(doc)
于 2013-08-22T12:30:40.460 回答
6

您必须使用upsert更新(或插入)您的数据

from pymongo import MongoClient
client = MongoClient()
collection = client.my_database.my_collection

objects = [{"_id" : 1, "foo" : "HELLO"}, {"_id" : 2, "Blah" : "Bloh"}]
for obj in objects:
     collection.replace_one({"_id": obj["_id"]}, obj, upsert=True) 

不推荐使用replace_oneupdate方法:

https://api.mongodb.com/python/current/api/pymongo/collection.html#pymongo.collection.Collection.replace_one

如果要使用批量更新:

from pymongo import ReplaceOne

update_objects = list()
for obj in objects:
    update_objects.append(ReplaceOne( {'_id': obj['_id']},  obj, upsert=True))

collection.bulk_write(update_objects)
于 2019-07-31T16:06:02.813 回答
4

对于 pymongo 3.0 及更高版本:

import pymongo
con = pymongo.MongoClient()
collection = con.db_name.collection_name

docs = [{"_id" : 1, "foo" : "HELLO"}, {"_id" : 2, "Blah" : "Bloh"}]
for d in docs:
    collection.update_many({'_id':d['_id']}, d,True)

参考:http ://api.mongodb.org/python/current/api/pymongo/collection.html

于 2016-03-08T03:57:53.923 回答