+ 8i:WRt^RIHt^RIt^RIHt^RIHtHtH t H t H t ^RI H t ^RIHt^RIHtHt]'d ^RIHt^R IHt^t^t^t^t^tR(t] ]]3,t] ] ]]3,,tR R ltR R lt RRlt!RRlt"!RR4t#!RR]#4t$!RR]#4t%!RR]#4t&!RR]#4t'!RR]#4t(!RR4t)]$]%]&]'](3t*R)R R!llt+R*t,!R"R#4t-R$R%lt.!R&R'4t/R#)+zUtilities 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)TopologyDescriptionc V^8dQhRRRR/#)tag_setsOptional[_TagSets]return)formats"V/var/www/html/photoedit/myenv/lib/python3.14/site-packages/pymongo/read_preferences.py __annotate__r9s!38Jc.VfV#\V\\34'g\RV: R24h\ V4^8Xd\ RV: R24hVF3p\V\ P4'dK%\RV: R24h \V4#)z$Validate tag sets for a MongoClient.z Tag sets z invalid, must be a sequencez: 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 ValueErrorrr)rtagss& r_validate_tag_setsr!9s hu . .)Hrc V^8dQhRRRR/#)r max_stalenessrrstrr)rs"rrrPsTTcTcTrcRV,#)z6maxStalenessSeconds must be a positive integer, not %srr#s&r_invalid_max_staleness_msgr'Ps Cm SSrc V^8dQhRRRR/#)rr#rrintr)rs"rrrUs  3 3 rcVR8XdR#\V\4'g\\V44hV^8:d\ \V44hV#)zValidate max_staleness.)rr)rr'rr&s&r_validate_max_stalenessr,UsL mS ) )2=ABB3MBCC rc V^8dQhRRRR/#)rhedgeOptional[_Hedge]rr)rs"rrrcs  + 0@ rcVfR#\V\4'g\RV: 24h\P!R\ ^R7V#)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. stacklevel)rdictrwarningswarnDeprecationWarning)r.s&r_validate_hedger8csI } eT " ":5)DEE MM } Lrc&]tRt^stRtR"tR#RRllt]RRl4t]RRl4t ]R R l4t ]R R l4t ]R Rl4t ]RRl4t ]RRl4t]RRl4tRRltRRltRRltRRltRRltRR ltR!tR#)$ _ServerModez$Base class for all read preferences.Nc ,V^8dQhRRRRRRRRRR /#) rmoder)rrr#r.r/rNoner)rs"rr_ServerMode.__annotate__xs< . . .% . .  .  .rc \V,VnWn\V4Vn\ V4Vn\V4VnR#N) _MONGOS_MODES_ServerMode__mongos_mode_ServerMode__moder!_ServerMode__tag_setsr,_ServerMode__max_stalenessr8_ServerMode__hedge)selfr<rr#r.s&&&&&r__init___ServerMode.__init__xs;+40 ,X66}E&u- rcV^8dQhRR/#rrr$r)rs"rrr>s''c'rc .VPP#)z!The name of this read preference.) __class____name__rGs&rname_ServerMode.names~~&&&rcV^8dQhRR/#rKr)rs"rrr>s""S"rc VP#)z(The mongos mode of this read preference.)rBrOs&r mongos_mode_ServerMode.mongos_modes!!!rcV^8dQhRR/#rrzdict[str, Any]r)rs"rrr>s  . rc RVP/pVPR/.39dVPVR&VPR8wdVPVR&VPR/39dVPVR&V#)zRead preference as a document.r<Nr maxStalenessSecondsr.r+)rBrDrErF)rGdocs& rdocument_ServerMode.documentst &t'9'9: ??4", .//CK   2 %)-)=)=C% & <<bz )<scrc VP#)z*The mode of this read preference instance.)rCrOs&rr<_ServerMode.modes{{rcV^8dQhRR/#)rr_TagSetsr)rs"rrr>sBB(Brc VVP'd\VP4#/.#)aSet ``tag_sets`` to a list of dictionaries like [{'dc': 'ny'}] to read only from members whose ``dc`` tag has the value ``"ny"``. To specify a priority-order for tag sets, provide a list of tag sets: ``[{'dc': 'ny'}, {'dc': 'la'}, {}]``. A final, empty tag set, ``{}``, means "read from any member that matches the mode, ignoring tags." MongoClient tries each set of tags in turn until it finds a set of tags with at least one matching member. For example, to only send a query to an analytic node:: Nearest(tag_sets=[{"node":"analytics"}]) Or using :class:`SecondaryPreferred`:: SecondaryPreferred(tag_sets=[{"node":"analytics"}]) .. seealso:: `Data-Center Awareness `_ )rDrrOs&rr_ServerMode.tag_setss"()-tDOO$AbTArcV^8dQhRR/#r^r)rs"rrr>s$$s$rc VP#)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. rErOs&rr#_ServerMode.max_stalenesss ###rcV^8dQhRR/#)rrr/r)rs"rrr>s'rc pVPe\P!R\^R7VP#)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 r1r2)rFr5r6r7rOs&rr._ServerMode.hedges20 << # MME"  ||rcV^8dQhRR/#r^r)rs"rrr>s 6 6# 6rc ,VPR8Xd^#^#)aRThe 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+rgrOs&rmin_wire_version_ServerMode.min_wire_versions((B.q5A5rcV^8dQhRR/#rKr)rs"rrr>s  # rc zRPVPVPVPVP4#)z1{}(tag_sets={!r}, max_staleness={!r}, hedge={!r}))rrPrDrErFrOs&r__repr___ServerMode.__repr__s3BII II OO  LL   rc V^8dQhRRRR/#rotherrrboolr)rs"rrr>sCDrc 2\V\4'd}VPVP8H;'d\VPVP8H;'d;VPVP8H;'dVP VP 8H#\ #r@)rr:r<rr#r.NotImplementedrGrvs&&r__eq___ServerMode.__eq__s e[ ) ) UZZ'..MMU^^3..&&%*=*==..JJ%++-   rc V^8dQhRRRR/#rur)rs"rrr>s!!C!D!rc W8X*#r@rrzs&&r__ne___ServerMode.__ne__s   rcV^8dQhRR/#rWr)rs"rrr>s   n  rc fRVPRVPRVPRVP/#)zUReturn value of object for pickling. Needed explicitly because __slots__() defined. r<rr#r.)rCrDrErFrOs&r __getstate___ServerMode.__getstate__s4 DKK  T11 T\\   rc V^8dQhRRRR/#)rvaluezMapping[str, Any]rr=r)rs"rrr> s77"377rc VR,Vn\VP,Vn\VR,4Vn\ VR,4Vn\VR,4VnR#)zRestore from pickling.r<rr#r.N) rCrArBr!rDr,rEr8rF)rGrs&&r __setstate___ServerMode.__setstate__ sQFm *4;;7,U:->?6u_7MN&uW~6 rc V^8dQhRRRR/#r selectionr rr)rs"rrr>s) rc V#r@rrGrs&&r__call___ServerMode.__call__sr)__hedge__max_staleness__mode __mongos_mode __tag_sets)rrrrrNr+N)rN __module__ __qualname____firstlineno____doc__ __slots__rHpropertyrPrTr[r<rr#r.rnrrr{rrrr__static_attributes__rrrr:r:ss.WI .''""  BB*$$> 6 6 !  7rr:cZa]tRtRtRtR tRV3RlltRRltRRltR R lt R t V;t #) Primaryia/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. cV^8dQhRR/#rrr=r)rs"rrPrimary.__annotate__$s##$#rc .<\SV`\4R#r@)superrH_PRIMARY)rGrMs&rrHPrimary.__init__$s "rc V^8dQhRRRR/#rr)rs"rrr's++)+ +rc VP#z*Apply this read preference to a Selection.)primary_selectionrs&&rrPrimary.__call__'s***rcV^8dQhRR/#rKr)rs"rrr+s#rc R#)z Primary()rrOs&rrrPrimary.__repr__+src V^8dQhRRRR/#rur)rs"rrr.sCDrc `\V\4'dVP\8H#\#r@)rr:r<rryrzs&&rr{Primary.__eq__.s$ e[ ) )::) )rr) rNrrrrrrHrrrr{r __classcell__rMs@rrrs-I##+rrcFa]tRtRtRtRtRRV3RllltRRltRtV;t #) PrimaryPreferredi4aCPrimaryPreferred 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. c(V^8dQhRRRRRRRR/# rrrr#r)r.r/rr=r)rs"rrPrimaryPreferred.__annotate__Qs8MM$MM M  Mrc 2<\SV`\WV4R#r@)rrH_PRIMARY_PREFERREDrGrr#r.rMs&&&&rrHPrimaryPreferred.__init__Qs +XeLrc V^8dQhRRRR/#rr)rs"rrrYs) rc VP'd VP#\VP\P !VP V44#z(Apply this read preference to Selection.)primaryrr rr selectr#rs&&rrPrimaryPreferred.__call__YsE    .. .6 6==d>P>PR[\ rrr rNrrrrrrHrrrrs@rrr4s%4IMMrrcFa]tRtRtRtRtRRV3RllltRRltRtV;t #) SecondaryicaSecondary 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. c(V^8dQhRRRRRRRR/#rr)rs"rrSecondary.__annotate__{s8EE$EE E  Erc 2<\SV`\WV4R#r@)rrH _SECONDARYrs&&&&rrHSecondary.__init__{s XeDrc V^8dQhRRRR/#rr)rs"rrr  )  rc l\VP\P!VPV44#r)r rr rr#rs&&rrSecondary.__call__s,2 MM299$:L:LiX  rrrrrs@rrrcs%*IEE  rrcFa]tRtRtRtRtRRV3RllltRRltRtV;t #) SecondaryPreferrediaTSecondaryPreferred 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. c(V^8dQhRRRRRRRR/#rr)rs"rrSecondaryPreferred.__annotate__s8OO$OO O  Orc 2<\SV`\WV4R#r@)rrH_SECONDARY_PREFERREDrs&&&&rrHSecondaryPreferred.__init__s -xNrc V^8dQhRRRR/#rr)rs"rrrs / /) / /rc \VP\P!VPV44pV'dV#VP #r)r rr rr#r)rGr secondariess&& rrSecondaryPreferred.__call__s@9 MM299$:L:LiX   .. .rrrrrs@rrrs%2IOO / /rrcFa]tRtRtRtRtRRV3RllltRRltRtV;t #) Nearestia9Nearest 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. c(V^8dQhRRRRRRRR/#rr)rs"rrNearest.__annotate__s8CC$CC C  Crc 2<\SV`\WV4R#r@)rrH_NEARESTrs&&&&rrHNearest.__init__s 8EBrc V^8dQhRRRR/#rr)rs"rrrrrc l\VP\P!VPV44#r)r rr rr#rs&&rrNearest.__call__s,/ MM299$:L:LiX  rrrrrs@rrrs%*ICC  rrcZ]tRtRtRtRtRRltRRltRRltR R lt R R lt R t R#) _AggWritePrefizAgg $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+. cV^8dQhRR/#)rprefr:r)rs"rr_AggWritePref.__annotate__sBB[Brc <Wn\PVnR#r@)rReadPreferencePRIMARYeffective_pref)rGrs&&rrH_AggWritePref.__init__s +9+A+Arc V^8dQhRRRR/#)rtopology_descriptionrrr=r)rs"rrrs , ,3F ,4 ,rc VPpVP\P4'd'V'dV^ 8d\PVnR#VP VnR#) N)common_wire_versionhas_readable_serverrPRIMARY_PREFERREDrrr)rGr common_wvs&& rselection_hook_AggWritePref.selection_hooksH(<< 4 4^5U5U V VB"0"8"8D "&))D rc V^8dQhRRRR/#rr)rs"rrrs..). .rc $VPV4#r)rrs&&rr_AggWritePref.__call__s""9--rcV^8dQhRR/#rKr)rs"rrrs44#4rc $RVP: R2#)z_AggWritePref(pref=))rrOs&rrr_AggWritePref.__repr__s$TYYM33rc V^8dQhRRRR/#)rrPr$rrr)rs"rrrs2222rc .\VPV4#r@)getattrr)rGrPs&&r __getattr___AggWritePref.__getattr__st**D11r)rrN)rr) rNrrrrrrHrrrrrrrrrrrs-+IB ,.4 22rrc(V^8dQhRRRRRRRR/#)rr<r)rrr#rr:r)rs"rrr s2 @ @  @+ @`_ 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. rN)rNrrrrrrrrr SECONDARYrSECONDARY_PREFERREDrNEARESTrrrrrr#s14liG(* I,.iGrrc V^8dQhRRRR/#)rrPr$rr)r)rs"rrras%%3%3%rc,\PV4#)z2Get the read preference mode from mongos/uri name.)rAindex)rPs&rread_pref_mode_from_nameras   t $$rcV]tRtRt$RtR]R&RRltRRltR R ltR R lt R t R#) MovingAverageifz0Tracks an exponentially-weighted moving average.Optional[float]averagecV^8dQhRR/#rr)rs"rrMovingAverage.__annotate__ks$rc RVnR#r@rrOs&rrHMovingAverage.__init__k  rc V^8dQhRRRR/#)rsamplefloatrr=r)rs"rrrns===4=rc V^8d\RV 24hVPf WnR#RVP,RV,,VnR#)zduration cannot be negative Ng?g?)rr)rGrs&&r add_sampleMovingAverage.add_samplensF A:;F8DE E << !L-f r7s" #BB+- 2@      c  GCH% &.T   bbJk8,{,^$ $ N-/-/`$ k$ N%2%2P!"2I?QSZ[ @ ;;|% r