pymongo.errors：自定义错误

pymongo.errors是一个用于处理MongoDB数据库连接和操作时可能出现的错误的模块。该模块中包含了一些内置的异常类，可以根据特定的错误类型进行错误处理。

下面是一些常见的MongoDB错误以及如何使用pymongo.errors自定义错误进行处理的例子：

1. ConnectionError：连接错误

当无法连接到MongoDB数据库时，会抛出ConnectionError异常。我们可以使用try-except块来捕获该异常，并在出现错误时进行处理。

from pymongo import MongoClient
from pymongo.errors import ConnectionError

try:
    client = MongoClient('mongodb://localhost:27017/')
    db = client['mydatabase']
except ConnectionError as e:
    print("Failed to connect to MongoDB:", e)

2. ConnectionTimeoutError：连接超时错误

当连接MongoDB数据库时发生超时错误时，会抛出ConnectionTimeoutError异常。类似地，我们也可以使用try-except块来捕获该异常并处理它。

from pymongo import MongoClient
from pymongo.errors import ConnectionTimeoutError

try:
    client = MongoClient('mongodb://localhost:27017/', serverSelectionTimeoutMS=2000)
    db = client['mydatabase']
except ConnectionTimeoutError as e:
    print("Connection timed out:", e)

3. DuplicateKeyError：重复键错误

当插入一条记录时，如果该记录的键已经存在于数据库中，则会抛出DuplicateKeyError异常。我们可以使用try-except块来捕获该异常，并进行相应的数据处理。

from pymongo import MongoClient
from pymongo.errors import DuplicateKeyError

try:
    client = MongoClient('mongodb://localhost:27017/')
    db = client['mydatabase']
    collection = db['mycollection']
    
    # Insert a document with a duplicate key
    my_document = {"_id": 1, "name": "John Doe"}
    collection.insert_one(my_document)
except DuplicateKeyError as e:
    print("Duplicate key:", e)

4. ServerSelectionTimeoutError：服务器选择超时错误

当在连接MongoDB服务器时，如果选择服务器花费的时间超过设定的超时时间，则会抛出ServerSelectionTimeoutError异常。同样，我们可以使用try-except块来捕获该异常并处理。

from pymongo import MongoClient
from pymongo.errors import ServerSelectionTimeoutError

try:
    client = MongoClient('mongodb://localhost:27017/', serverSelectionTimeoutMS=2000)
    db = client['mydatabase']
    collection = db['mycollection']
    
    # Perform an operation that takes longer than the serverSelectionTimeoutMS
    collection.find_one()
except ServerSelectionTimeoutError as e:
    print("Server selection timed out:", e)

5. WriteError：写入错误

当尝试写入数据库时，如果发生错误，则会抛出WriteError异常。我们可以使用try-except块来捕获该异常并进行相应的错误处理。

from pymongo import MongoClient
from pymongo.errors import WriteError

try:
    client = MongoClient('mongodb://localhost:27017/')
    db = client['mydatabase']
    collection = db['mycollection']
    
    # Attempt to perform an invalid write operation
    collection.insert_one({"_id": "a", "name": "Alice"})
    collection.update_one({"_id": "a"}, {"$set": {"age": 25}})
except WriteError as e:
    print("Failed to write to database:", e)

以上是一些常见的MongoDB错误以及如何使用pymongo.errors自定义错误进行处理的例子。通过捕获并处理这些错误，我们可以更好地控制和管理MongoDB数据库的连接和操作过程。