面试题：MongoDB批量操作中的异常处理策略

处理策略：
- 事务（MongoDB 4.0+）：
  - 对于支持事务的 MongoDB 版本，可以使用事务来确保批量操作的原子性。事务可以将多个操作捆绑在一起，要么所有操作都成功提交，要么所有操作都回滚。
  - 在开启事务后，进行批量插入或更新操作，若其中任何一个操作失败，事务将自动回滚，从而保证数据的一致性和完整性。
- 错误处理与重试：
  - 在不支持事务的情况下，记录每个操作的结果。当部分操作失败时，分析失败原因，针对可重试的错误（如网络短暂中断等）进行重试。
  - 对于不可重试的错误，如数据格式错误等，停止操作并记录详细的错误日志，以便后续分析和修复。
代码实现思路（以Python的PyMongo库为例，使用事务）：

from pymongo import MongoClient
from pymongo.errors import ConnectionFailure, OperationFailure

client = MongoClient('mongodb://localhost:27017/')
try:
    client.admin.command('ping')
    print("Connected to MongoDB!")
except ConnectionFailure:
    print("Could not connect to MongoDB")

db = client['your_database']
collection = db['your_collection']

try:
    with client.start_session() as session:
        session.start_transaction()
        try:
            data_to_insert = [{"name": "doc1"}, {"name": "doc2"}]
            collection.insert_many(data_to_insert, session = session)
            # 模拟更新操作
            update_filter = {"name": "doc1"}
            update_data = {"$set": {"new_field": "value1"}}
            collection.update_one(update_filter, update_data, session = session)
            session.commit_transaction()
            print("Operations completed successfully")
        except OperationFailure as e:
            session.abort_transaction()
            print(f"Transaction aborted due to error: {e}")
except Exception as e:
    print(f"An unexpected error occurred: {e}")
finally:
    client.close()

代码实现思路（以Python的PyMongo库为例，错误处理与重试）：

from pymongo import MongoClient
from pymongo.errors import ConnectionFailure, OperationFailure

client = MongoClient('mongodb://localhost:27017/')
try:
    client.admin.command('ping')
    print("Connected to MongoDB!")
except ConnectionFailure:
    print("Could not connect to MongoDB")

db = client['your_database']
collection = db['your_collection']

data_to_insert = [{"name": "doc1"}, {"name": "doc2"}]
insert_results = []
for doc in data_to_insert:
    try:
        result = collection.insert_one(doc)
        insert_results.append((doc, result.inserted_id, True))
    except OperationFailure as e:
        insert_results.append((doc, None, False))
        print(f"Insertion failed for {doc}: {e}")

# 处理更新操作
update_filter = {"name": "doc1"}
update_data = {"$set": {"new_field": "value1"}}
try:
    result = collection.update_one(update_filter, update_data)
    print(f"Update operation result: {result.raw_result}")
except OperationFailure as e:
    print(f"Update failed: {e}")

在上述代码中，使用事务时，操作要么全部成功提交，要么全部回滚；使用错误处理与重试时，会记录每个插入操作的结果，对更新操作也进行错误捕获。具体的重试逻辑可根据业务需求进一步完善，比如设置重试次数、延迟重试等。

星途面试题库

面试题：MongoDB批量操作中的异常处理策略

知识考点

面试题答案