&gPY S r SSKJr SSKrSSKJr SSKJrJrJ r J
r
J r SSK J
r
SSKJr SSKJrJr \( a SS KJr SS
KJr SrS rS rS
rSrSr\ \ \4 r \ \ \ \4 r S)S jr S*S jr S+S jr!S,S jr" " S S5 r# " S S\#5 r$ " S S\#5 r% " S S\#5 r& " S S \#5 r' " S S \#5 r( " S S!5 r)\$\%\&\'\(4r* S- S.S" jjr+S#r, " S$ S%5 r-S/S& jr. " S' S(5 r/g)0zUtilities for choosing which member of a replica set to read from.
.. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs.
) annotationsN)abc)
TYPE_CHECKINGAnyMappingOptionalSequence)max_staleness_selectors)ConfigurationError) member_with_tags_server_selector#secondary_with_tags_server_selector) Selection)TopologyDescription )primaryprimaryPreferred secondarysecondaryPreferrednearestc & U c U $ [ U [ [ 45 ( d [ SU < S35 e[ U 5 S:X a [ SU < S35 eU H2 n[ U[ R 5 ( a M$ [ SU< S35 e [ U 5 $ )z$Validate tag sets for a MongoClient.z Tag sets z invalid, must be a sequencer z: invalid, must be None or contain at least one set of tagszTag set zg invalid, must be an instance of dict, bson.son.SON or other type that inherits from collection.Mapping)
isinstancelisttuple TypeErrorlen
ValueErrorr r )tag_setstagss ]C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\pymongo/read_preferences.py_validate_tag_setsr# 9 s hu
. .)H c SU - $ )Nz6maxStalenessSeconds must be a positive integer, not %s
max_stalenesss r" _invalid_max_staleness_msgr) P s
Cm SSr$ c U S:X a g[ U [ 5 ( d [ [ U 5 5 eU S:: a [ [ U 5 5 eU $ )zValidate max_staleness.r )r intr r) r r' s r" _validate_max_stalenessr- U sJ mS ) )2=ABB3MBCC r$ c U c g[ U [ 5 ( d [ SU < 35 e[ R " S[
SS9 U $ )zValidate hedge.Nz hedge must be a dictionary, not The read preference 'hedge' option is deprecated in PyMongo 4.12+ because hedged reads are deprecated in MongoDB version 8.0+. Support for 'hedge' will be removed in PyMongo 5.0.r
stacklevel)r dictr warningswarnDeprecationWarning)hedges r" _validate_hedger7 c sI } eT " ":5)DEE MM }
Lr$ c \ rS rSrSrSr S SS jjr\SS j5 r\SS j5 r \SS j5 r
\SS j5 r \SS
j5 r \SS j5 r
\SS j5 r\SS
j5 rSS jrS S jrS S jrSS jrS S jrS S jrSrg) _ServerModes z$Base class for all read preferences.)
__mongos_mode__mode
__tag_sets__max_staleness__hedgeNc [ U U l Xl [ U5 U l [ U5 U l [ U5 U l g N)
_MONGOS_MODES_ServerMode__mongos_mode_ServerMode__moder# _ServerMode__tag_setsr- _ServerMode__max_stalenessr7 _ServerMode__hedge)selfmoder r( r6 s r" __init___ServerMode.__init__x s; +4 0 ,X6 6} E &u- r$ c . U R R $ )z!The name of this read preference.) __class____name__rH s r" name_ServerMode.name s ~~&&&r$ c U R $ )z(The mongos mode of this read preference.)rC rO s r" mongos_mode_ServerMode.mongos_mode s !!!r$ c SU R 0nU R S0 /4; a U R US' U R S:w a U R US' U R S0 4; a U R US' U$ )z Read preference as a document.rI Nr! r+ maxStalenessSecondsr6 )rC rE rF rG )rH docs r" document_ServerMode.document st &t'9'9 : ??4", . //CK 2 %)-)=)=C% & <<bz ) <`_
)rE r rO s r" r _ServerMode.tag_sets s ( )-tDOO$AbTAr$ c U R $ )zThe maximum estimated length of time (in seconds) a replica set
secondary can fall behind the primary in replication before it will
no longer be selected for operations, or -1 for no maximum.
rF rO s r" r( _ServerMode.max_staleness s ###r$ c h U R b [ R " S[ SS9 U R $ )a **DEPRECATED** - The read preference 'hedge' option is deprecated in PyMongo 4.12+ because hedged reads are deprecated in MongoDB version 8.0+. Support for 'hedge' will be removed in PyMongo 5.0.
The read preference ``hedge`` parameter.
A dictionary that configures how the server will perform hedged reads.
It consists of the following keys:
- ``enabled``: Enables or disables hedged reads in sharded clusters.
Hedged reads are automatically enabled in MongoDB 4.4+ when using a
``nearest`` read preference. To explicitly enable hedged reads, set
the ``enabled`` key to ``true``::
>>> Nearest(hedge={'enabled': True})
To explicitly disable hedged reads, set the ``enabled`` key to
``False``::
>>> Nearest(hedge={'enabled': False})
.. versionadded:: 3.11
r/ r r0 )rG r3 r4 r5 rO s r" r6 _ServerMode.hedge s2 0 << # MM E"
||r$ c * U R S:X a S$ S$ )aR The wire protocol version the server must support.
Some read preferences impose version requirements on all servers (e.g.
maxStalenessSeconds requires MongoDB 3.4 / maxWireVersion 5).
All servers' maxWireVersion must be at least this read preference's
`min_wire_version`, or the driver raises
:exc:`~pymongo.errors.ConfigurationError`.
r+ r r_ rO s r" min_wire_version _ServerMode.min_wire_version s ((B.q5A5r$ c z SR U R U R U R U R 5 $ )Nz1{}(tag_sets={!r}, max_staleness={!r}, hedge={!r}))formatrP rE rF rG rO s r" __repr___ServerMode.__repr__ s3 BII II OO LL
r$ c * [ U[ 5 ( ay U R UR :H =( aY U R UR :H =( a9 U R UR :H =( a U R
UR
:H $ [ $ rA )r r9 rI r r( r6 NotImplementedrH others r" __eq___ServerMode.__eq__ sq e[ ) ) UZZ' .MMU^^3.&&%*=*==. JJ%++-
r$ c X:X + $ rA r& rm s r" __ne___ServerMode.__ne__ s r$ c ` U R U R U R U R S.$ )zUReturn value of object for pickling.
Needed explicitly because __slots__() defined.
)rI r r( r6 )rD rE rF rG rO s r" __getstate___ServerMode.__getstate__ s, KK ! 1 1\\
r$ c US U l [ U R U l [ US 5 U l [ US 5 U l [ US 5 U l g)zRestore from pickling.rI r r( r6 N) rD rB rC r# rE r- rF r7 rG )rH values r" __setstate___ServerMode.__setstate__ sQ Fm *4;; 7,U:->? 6u_7M N &uW~6 r$ c U$ rA r& rH selections r" __call___ServerMode.__call__ s r$ )r? r> r< r; r= Nr+ N)
rI r, r Optional[_TagSets]r( r, r6 Optional[_Hedge]returnNoner str)r zdict[str, Any])r r, )r _TagSets)r r rn r r bool)rx zMapping[str, Any]r r r} r r r )rN
__module__ __qualname____firstlineno____doc__ __slots__rJ propertyrP rS rX rI r r( r6 re ri ro rr ru ry r~ __static_attributes__r& r$ r" r9 r9 s s
.WI
(, "& . . % . .
.
. ' ' " " B B* $ $ >
6
6
!
7r$ r9 c R ^ \ rS rSrSrSrSU 4S jjrS S jrS
S jrS S jr Sr
U =r $ ) Primaryi a/ Primary read preference.
* When directly connected to one mongod queries are allowed if the server
is standalone or a replica set primary.
* When connected to a mongos queries are sent to the primary of a shard.
* When connected to a replica set queries are sent to the primary of
the replica set.
r& c , > [ TU ] [ 5 g rA )superrJ _PRIMARY)rH rM s r" rJ Primary.__init__$ s
"r$ c UR $ z*Apply this read preference to a Selection.)primary_selectionr| s r" r~ Primary.__call__' s ***r$ c g)Nz Primary()r& rO s r" ri Primary.__repr__+ s r$ c ^ [ U[ 5 ( a UR [ :H $ [ $ rA )r r9 rI r rl rm s r" ro Primary.__eq__. s$ e[ ) )::) ) r$ r r r r r ) rN r r r r r rJ r~ ri ro r
__classcell__rM s @r" r r s( I#+ r$ r c V ^ \ rS rSrSrSr S SU 4S jjjrSS jrSrU =r $ ) PrimaryPreferredi4 aC PrimaryPreferred read preference.
* When directly connected to one mongod queries are allowed to standalone
servers, to a replica set primary, or to replica set secondaries.
* When connected to a mongos queries are sent to the primary of a shard if
available, otherwise a shard secondary.
* When connected to a replica set queries are sent to the primary if
available, otherwise a secondary.
.. note:: When a :class:`~pymongo.mongo_client.MongoClient` is first
created reads will be routed to an available secondary until the
primary of the replica set is discovered.
:param tag_sets: The :attr:`~tag_sets` to use if the primary is not
available.
:param max_staleness: (integer, in seconds) The maximum estimated
length of time a replica set secondary can fall behind the primary in
replication before it will no longer be selected for operations.
Default -1, meaning no maximum. If it is set, it must be at least
90 seconds.
:param hedge: **DEPRECATED** - The :attr:`~hedge` for this read preference.
.. versionchanged:: 3.11
Added ``hedge`` parameter.
r& c 0 > [ TU ] [ XU5 g rA )r rJ _PRIMARY_PREFERREDrH r r( r6 rM s r" rJ PrimaryPreferred.__init__Q s +XeLr$ c UR ( a UR $ [ U R [ R
" U R U5 5 $ z(Apply this read preference to Selection.)r r r
r r
selectr( r| s r" r~ PrimaryPreferred.__call__Y sB .. .6
6 = =d>P>PR[ \
r$ r r r r( r, r6 r r r r
rN r r r r r rJ r~ r r r s @r" r r 4 sZ 4 I (, "& M$M M M
M M r$ r c V ^ \ rS rSrSrSr S SU 4S jjjrSS jrSrU =r $ ) Secondaryic a Secondary read preference.
* When directly connected to one mongod queries are allowed to standalone
servers, to a replica set primary, or to replica set secondaries.
* When connected to a mongos queries are distributed among shard
secondaries. An error is raised if no secondaries are available.
* When connected to a replica set queries are distributed among
secondaries. An error is raised if no secondaries are available.
:param tag_sets: The :attr:`~tag_sets` for this read preference.
:param max_staleness: (integer, in seconds) The maximum estimated
length of time a replica set secondary can fall behind the primary in
replication before it will no longer be selected for operations.
Default -1, meaning no maximum. If it is set, it must be at least
90 seconds.
:param hedge: **DEPRECATED** - The :attr:`~hedge` for this read preference.
.. versionchanged:: 3.11
Added ``hedge`` parameter.
r& c 0 > [ TU ] [ XU5 g rA )r rJ
_SECONDARYr s r" rJ Secondary.__init__{ s XeDr$ c l [ U R [ R " U R U5 5 $ r )r
r r
r r( r| s r" r~ Secondary.__call__ s, 2 MM299$:L:LiX
r$ r r r r r s @r" r r c sZ * I (, "& E$E E E
E E
r$ r c V ^ \ rS rSrSrSr S SU 4S jjjrSS jrSrU =r $ ) SecondaryPreferredi aT SecondaryPreferred read preference.
* When directly connected to one mongod queries are allowed to standalone
servers, to a replica set primary, or to replica set secondaries.
* When connected to a mongos queries are distributed among shard
secondaries, or the shard primary if no secondary is available.
* When connected to a replica set queries are distributed among
secondaries, or the primary if no secondary is available.
.. note:: When a :class:`~pymongo.mongo_client.MongoClient` is first
created reads will be routed to the primary of the replica set until
an available secondary is discovered.
:param tag_sets: The :attr:`~tag_sets` for this read preference.
:param max_staleness: (integer, in seconds) The maximum estimated
length of time a replica set secondary can fall behind the primary in
replication before it will no longer be selected for operations.
Default -1, meaning no maximum. If it is set, it must be at least
90 seconds.
:param hedge: **DEPRECATED** - The :attr:`~hedge` for this read preference.
.. versionchanged:: 3.11
Added ``hedge`` parameter.
r& c 0 > [ TU ] [ XU5 g rA )r rJ _SECONDARY_PREFERREDr s r" rJ SecondaryPreferred.__init__ s -xNr$ c [ U R [ R " U R U5 5 nU( a U$ UR
$ r )r
r r
r r( r )rH r} secondariess r" r~ SecondaryPreferred.__call__ s@ 9 MM299$:L:LiX
.. .r$ r r r r r s @r" r r sZ 2 I (, "& O$O O O
O O / /r$ r c V ^ \ rS rSrSrSr S SU 4S jjjrSS jrSrU =r $ ) Nearesti a9 Nearest read preference.
* When directly connected to one mongod queries are allowed to standalone
servers, to a replica set primary, or to replica set secondaries.
* When connected to a mongos queries are distributed among all members of
a shard.
* When connected to a replica set queries are distributed among all
members.
:param tag_sets: The :attr:`~tag_sets` for this read preference.
:param max_staleness: (integer, in seconds) The maximum estimated
length of time a replica set secondary can fall behind the primary in
replication before it will no longer be selected for operations.
Default -1, meaning no maximum. If it is set, it must be at least
90 seconds.
:param hedge: **DEPRECATED** - The :attr:`~hedge` for this read preference.
.. versionchanged:: 3.11
Added ``hedge`` parameter.
r& c 0 > [ TU ] [ XU5 g rA )r rJ _NEARESTr s r" rJ Nearest.__init__ s 8EBr$ c l [ U R [ R " U R U5 5 $ r )r r r
r r( r| s r" r~ Nearest.__call__ s, / MM299$:L:LiX
r$ r r r r r s @r" r r sZ * I (, "& C$C C C
C C
r$ r c N \ rS rSrSrSrS S jrS S jrS
S jrSS jr SS jr
S r g
)
_AggWritePrefi zAgg $out/$merge write preference.
* If there are readable servers and there is any pre-5.0 server, use
primary read preference.
* Otherwise use `pref` read preference.
:param pref: The read preference to use on MongoDB 5.0+.
)prefeffective_prefc : Xl [ R U l g rA )r ReadPreferencePRIMARYr )rH r s r" rJ _AggWritePref.__init__ s +9+A+Ar$ c UR nUR [ R 5 ( a# U( a US: a [ R U l g U R U l g )N
)common_wire_versionhas_readable_serverr PRIMARY_PREFERREDr r r )rH topology_description common_wvs r" selection_hook _AggWritePref.selection_hook sH (<< 4 4^5U5U V VB"0"8"8D "&))D r$ c $ U R U5 $ r )r r| s r" r~ _AggWritePref.__call__ s ""9--r$ c $ SU R < S3$ )Nz_AggWritePref(pref=))r rO s r" ri _AggWritePref.__repr__ s $TYYM33r$ c . [ U R U5 $ rA )getattrr )rH rP s r" __getattr___AggWritePref.__getattr__ s t**D11r$ )r r N)r r9 )r r r r r r )rP r r r ) rN r r r r r rJ r r~ ri r r r& r$ r" r r s( +IB ,.4
2r$ r c U [ :X a/ US 0 /4; a [ S5 eUS:w a [ S5 e[ 5 $ [ U " X5 $ )Nz4Read preference primary cannot be combined with tagsr+ zCRead preference primary cannot be combined with maxStalenessSeconds)r r r _ALL_READ_PREFERENCES)rI r r( s r" make_read_preferencer sX x D2$< '$%[\ \ B $U
y &x ??r$ )r r SECONDARYSECONDARY_PREFERREDNEARESTc ^ \ rS rSrSr\" 5 r\" 5 r\ " 5 r
\ " 5 r \
" 5 rSrg)r i# a) An enum that defines some commonly used read preference modes.
Apps can also create a custom read preference, for example::
Nearest(tag_sets=[{"node":"analytics"}])
See :doc:`/examples/high_availability` for code examples.
A read preference is used in three cases:
:class:`~pymongo.mongo_client.MongoClient` connected to a single mongod:
- ``PRIMARY``: Queries are allowed if the server is standalone or a replica
set primary.
- All other modes allow queries to standalone servers, to a replica set
primary, or to replica set secondaries.
:class:`~pymongo.mongo_client.MongoClient` initialized with the
``replicaSet`` option:
- ``PRIMARY``: Read from the primary. This is the default, and provides the
strongest consistency. If no primary is available, raise
:class:`~pymongo.errors.AutoReconnect`.
- ``PRIMARY_PREFERRED``: Read from the primary if available, or if there is
none, read from a secondary.
- ``SECONDARY``: Read from a secondary. If no secondary is available,
raise :class:`~pymongo.errors.AutoReconnect`.
- ``SECONDARY_PREFERRED``: Read from a secondary if available, otherwise
from the primary.
- ``NEAREST``: Read from any member.
:class:`~pymongo.mongo_client.MongoClient` connected to a mongos, with a
sharded cluster of replica sets:
- ``PRIMARY``: Read from the primary of the shard, or raise
:class:`~pymongo.errors.OperationFailure` if there is none.
This is the default.
- ``PRIMARY_PREFERRED``: Read from the primary of the shard, or if there is
none, read from a secondary of the shard.
- ``SECONDARY``: Read from a secondary of the shard, or raise
:class:`~pymongo.errors.OperationFailure` if there is none.
- ``SECONDARY_PREFERRED``: Read from a secondary of the shard if available,
otherwise from the shard primary.
- ``NEAREST``: Read from any shard member.
r& N)rN r r r r r r r r r r r r r r r r& r$ r" r r # s1 4l iG(* I,.iGr$ r c , [ R U 5 $ )z2Get the read preference mode from mongos/uri name.)rB index)rP s r" read_pref_mode_from_namer a s t $$r$ c L \ rS rSr% SrS\S' S S jrS S jrS
S jrS S jr S r
g
)
MovingAverageif z0Tracks an exponentially-weighted moving average.Optional[float]averagec S U l g rA r rO s r" rJ MovingAverage.__init__k r$ c US: a [ SU 35 eU R c Xl g SU R - SU- - U l g )Nr z duration cannot be negative g?g?)r r )rH samples r"
add_sampleMovingAverage.add_samplen sF A: ;F8 DE E << !L -f r sM
# B B + -
2@
c GCH% &.T
b bJ k 8,{ ,^$
$
N-/ -/`$
k $
N%2 %2P !"2I?QSZ[ CE @
@+ @