python - Pymongo 如何设置 read_preference

Question

我们如何使 PyMongo 从最近的位置开始读取？该字段 db.read_preference 现在是只读的。

from pymongo import ReplicaSetConnection
from pymongo import ReadPreference

db = ReplicaSetConnection('localhost:27017', replicaSet='rs1')['my_db']
db.read_preference = ReadPreference.NEAREST
db.tag_sets = [{'secondaries': 1}]

Answer 1

您需要将它添加到连接字符串中，如下所示:

db = ReplicaSetConnection('localhost:27017?readPreference=nearest', replicaSet='rs1')['my_db']

或者

db = MongoClient("myhost:27017", read_preference=ReadPreference.NEAREST, replicaSet='rs1')['my_db']

无论出于何种原因，您使用的给定语法失败，它似乎是旧 Pymongo 版本支持的语法。