【Python】MongoDB中的批量写入案例,避免单条插入失败导致整体失败
from pymongo import MongoClient
# 假设已经有了一个MongoDB客户端实例和数据库对象
client = MongoClient('mongodb://localhost:27017/')
db = client['mydatabase']
collection = db['mycollection']
# 准备要批量插入的数据
documents = [
{"name": "Alice", "age": 25, "address": "123 Maple Street"},
{"name": "Bob", "age": 30, "address": "456 Elm Street"},
# ...更多文档
]
# 使用insert_many进行批量插入
try:
result = collection.insert_many(documents)
# 打印插入的文档ID
print("Inserted multiple documents:", result.inserted_ids)
except Exception as e:
print("An error occurred while inserting documents:", e)
# 注意:在实际应用中,应该处理特定的异常,例如 pymongo.errors.BulkWriteError
这段代码演示了如何使用PyMongo库将一个文档列表批量插入MongoDB中。它使用insert_many
函数来执行批量插入,并通过try-except捕获异常来处理可能发生的错误。在实际应用中,应该更具体地处理异常,例如处理BulkWriteError
以获取更详细的错误信息。
评论已关闭