Docs 主页 → 开发应用程序 → Python 驱动程序 → pymongo
将数据写入 MongoDB
Overview
在此页面上,您可以查看可复制的代码示例,这些示例展示了通过 PyMongo 将数据写入 MongoDB 的常用方法。
提示
要了解有关此页面上显示的任何方法的更多信息,请参阅每个部分中提供的链接。
要使用本页中的示例,请将代码示例复制到示例应用程序或您自己的应用程序中。 请务必将代码示例中的所有占位符(例如 <connection string URI>
)替换为 MongoDB 部署的相关值。
示例应用程序
您可以使用以下示例应用程序来测试本页上的代码示例。 要使用示例应用程序,请执行以下步骤:
确保已安装 PyMongo。
复制以下代码并将其粘贴到新的
.py
文件中。从此页面复制代码示例,并将其粘贴到文件中的指定行。
1 import pymongo 2 from pymongo import MongoClient 3 4 try: 5 uri = "<connection string URI>" 6 client = MongoClient(uri) 7 8 database = client["<database name>"] 9 collection = database["<collection name>"] 10 11 # start example code here 12 13 # end example code here 14 15 client.close() 16 17 except Exception as e: 18 raise Exception( 19 "The following error occurred: ", e)
insertOne
result = collection.insert_one({ "<field name>" : "<value>" }) print(result.acknowledged)
要了解有关insert_one()
方法的更多信息,请参阅“插入文档”指南。
插入多个
document_list = [ { "<field name>" : "<value>" }, { "<field name>" : "<value>" } ] result = collection.insert_many(document_list) print(result.acknowledged)
要了解有关insert_many()
方法的更多信息,请参阅“插入文档”指南。
updateOne
query_filter = { "<field to match>" : "<value to match>" } update_operation = { "$set" : { "<field name>" : "<value>" } } result = collection.update_one(query_filter, update_operation) print(result.modified_count)
要了解有关update_one()
方法的更多信息,请参阅更新文档指南。
更新多个
query_filter = { "<field to match>" : "<value to match>" } update_operation = { "$set" : { "<field name>" : "<value>" } } result = collection.update_many(query_filter, update_operation) print(result.modified_count)
要了解有关update_many()
方法的更多信息,请参阅更新文档指南。
replaceOne
query_filter = { "<field to match>" : "<value to match>" } replace_document = { "<new document field name>" : "<new document value>" } result = collection.replace_one(query_filter, replace_document) print(result.modified_count)
要了解有关replace_one()
方法的更多信息,请参阅替换文档指南。
deleteOne
query_filter = { "<field to match>" : "<value to match>" } result = collection.delete_one(query_filter) print(result.deleted_count)
要了解有关delete_one()
方法的更多信息,请参阅“删除文档”指南。
删除多个
query_filter = { "<field to match>" : "<value to match>" } result = collection.delete_many(query_filter) print(result.deleted_count)
要了解有关delete_many()
方法的更多信息,请参阅“删除文档”指南。
批量写入
operations = [ pymongo.InsertOne( { "<field name>" : "<value>" } ), pymongo.UpdateMany( { "<field to match>" : "<value to match>" }, { "$set" : { "<field name>" : "<value>" }}, ), pymongo.DeleteOne( { "<field to match>" : "<value to match>" } ), ] result = collection.bulk_write(operations) print(result)
要了解有关bulk_write()
方法的更多信息,请参阅批量写入指南。