MongoDB read_preference()函数作用与使用方法

作用

read_preference()函数可以用来定义MongoDB读取数据的首选项，包括读取数据的方式和读取数据的节点等。在MongoDB集群模式下，使用该函数可以指定读取数据的节点，提高数据读取的效率、稳定性和可靠性。

使用方法

对于单节点环境，read_preference()函数设置通常为默认选项。

在集群环境中，MongoDB支持三种读取数据的方式：主节点读取、从节点读取和随机读取。通过read_preference()函数可以设置这些读取方式。常用的有以下几种选项：

PrimaryPreferred：优先从主节点读取数据。如果主节点不可用，则从备份节点读取数据。
Secondary：直接从备份节点读取数据。如果备份节点不可用，则抛出异常。
SecondaryPreferred：优先从备份节点读取数据。如果备份节点不可用，则从主节点读取数据。
Nearest：从最近的节点读取数据，无论是否为主节点或备份节点。

除了读取数据的节点外，read_preference()函数还可以设置数据读取时的读取模式。默认情况下，MongoDB读取数据时会进行网络传输的校验，以保证读取的数据的正确性。如果对读取性能要求比较高的时候，可以选择关闭校验，提高数据读取效率。www

接下来给出两个实例来说明read_preference()函数的使用方法。

实例一：从节点读取数据

from pymongo import MongoClient, ReadPreference

# MongoDB节点信息
client = MongoClient(['node1:27017', 'node2:27017', 'node3:27017'], replicaSet='rs1')

# 设置从节点读取数据
client.read_preference = ReadPreference.SECONDARY

# 读取数据
db = client['testdatabase']
collection = db['testcollection']
result = collection.find({})

在这个实例中，我们首先定义MongoDB节点信息，并将其视为一个副本集合（replicaSet）。然后，我们通过read_preference()函数将数据读取方式设置为从节点读取（ReadPreference.SECONDARY），然后读取数据。

实例二：最近节点读取数据

from pymongo import MongoClient, ReadPreference

# MongoDB节点信息
client = MongoClient(['node1:27017', 'node2:27017', 'node3:27017'], replicaSet='rs1')

# 设置最近节点读取数据
client.read_preference = ReadPreference.NEAREST

# 读取数据
db = client['testdatabase']
collection = db['testcollection']
result = collection.find({})

在这个实例中，我们同样定义MongoDB节点信息，并将其视为一个副本集合（replicaSet）。然后，我们通过read_preference()函数将数据读取方式设置为最近节点读取（ReadPreference.NEAREST），然后读取数据。