o ?8\n@@sdZddlmZmZddlmZddlmZddlm Z m Z dZ dZ dZ dZd Zd Zd d Zd dZddZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZeeeeefZd(ddZd ZGd!d"d"eZd#d$ZGd%d&d&eZ d'S))zBUtilities for choosing which member of a replica set to read from.)abc integer_types)max_staleness_selectors)ConfigurationError) member_with_tags_server_selector#secondary_with_tags_server_selector)primaryprimaryPreferred secondarysecondaryPreferrednearestcCsf|dur|St|tstd|ft|dkrtd|f|D]}t|tjs0td|fq!|S)z3Validate tag sets for a MongoReplicaSetClient. Nz#Tag sets %r invalid, must be a listrzETag sets %r invalid, must be None or contain at least one set of tagszqTag set %r invalid, must be an instance of dict, bson.son.SON or other type that inherits from collection.Mapping) isinstancelist TypeErrorlen ValueErrorrMapping)tag_setstagsrJ/var/www/html/env/lib/python3.10/site-packages/pymongo/read_preferences.py_validate_tag_sets(s(   rcCsd|S)Nz6maxStalenessSeconds must be a positive integer, not %sr max_stalenessrrr_invalid_max_staleness_msg@srcCs:|dkrdSt|tstt||dkrtt||S)zValidate max_staleness.r)rrrrrrrrr_validate_max_stalenessFs   r c@seZdZdZdZdddZeddZed d Zed d Z ed dZ eddZ eddZ eddZ ddZddZddZddZddZdS) _ServerModez)Base class for all read preferences. ) __mongos_mode__mode __tag_sets__max_stalenessNrcCs(t||_||_t||_t||_dSN) _MONGOS_MODES_ServerMode__mongos_mode_ServerMode__moder_ServerMode__tag_setsr _ServerMode__max_staleness)selfmoderrrrr__init__Zs  z_ServerMode.__init__cCs|jjS)z*The name of this read preference. ) __class____name__r,rrrname`sz_ServerMode.namecC|jS)z1The mongos mode of this read preference. )r(r1rrr mongos_modefz_ServerMode.mongos_modecCs<d|ji}|jdigfvr|j|d<|jdkr|j|d<|S)z'Read preference as a document. r-NrrmaxStalenessSeconds)r(r*r+)r,docrrrdocumentls    z_ServerMode.documentcCr3)z3The mode of this read preference instance. )r)r1rrrr-wr5z_ServerMode.modecCs|jrt|jSigS)a{Set ``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." MongoReplicaSetClient tries each set of tags in turn until it finds a set of tags with at least one matching member. .. seealso:: `Data-Center Awareness `_ )r*rr1rrrr}s z_ServerMode.tag_setscCr3)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.r+r1rrrrsz_ServerMode.max_stalenesscCs|jdkrdSdS)aThe 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`. rrr9r1rrrmin_wire_versions z_ServerMode.min_wire_versioncCsd|j|j|jfS)Nz!%s(tag_sets=%r, max_staleness=%r))r2r*r+r1rrr__repr__s z_ServerMode.__repr__cCs2t|tr|j|jko|j|jko|j|jkStSr&)rr!r-rrNotImplementedr,otherrrr__eq__s    z_ServerMode.__eq__cCs ||k Sr&rr>rrr__ne__ z_ServerMode.__ne__cCs|j|j|jdS)zeReturn value of object for pickling. Needed explicitly because __slots__() defined. r-rr)r)r*r+r1rrr __getstate__sz_ServerMode.__getstate__cCs6|d|_t|j|_t|d|_t|d|_dS)zRestore from pickling.r-rrN)r)r'r(rr*r r+)r,valuerrr __setstate__s  z_ServerMode.__setstate__Nr)r0 __module__ __qualname____doc__ __slots__r.propertyr2r4r8r-rrr;r<r@rArDrFrrrrr!Ts.          r!cs<eZdZdZdZfddZddZddZd d ZZ S) PrimaryaGPrimary 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. rcstt|tdSr&)superrMr._PRIMARYr1r/rrr.szPrimary.__init__cCs|jS)z*Apply this read preference to a Selection.)primary_selectionr, selectionrrr__call__zPrimary.__call__cCsdS)Nz Primary()rr1rrrr<szPrimary.__repr__cCst|tr |jtkStSr&)rr!r-rOr=r>rrrr@s  zPrimary.__eq__) r0rHrIrJrKr.rTr<r@ __classcell__rrrPrrMs rMc.eZdZdZdZd fdd ZddZZS) PrimaryPreferredaQPrimaryPreferred 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. :Parameters: - `tag_sets`: The :attr:`~tag_sets` to use if the primary is not available. - `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. rNrctt|t||dSr&)rNrXr._PRIMARY_PREFERREDr,rrrPrrr. zPrimaryPreferred.__init__cCs"|jr|jSt|jt|j|Sz(Apply this read preference to Selection.)r rQrrrselectrrRrrrrTszPrimaryPreferred.__call__rGr0rHrIrJrKr.rTrVrrrPrrXs rXcrW) Secondarya]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. :Parameters: - `tag_sets`: The :attr:`~tag_sets` for this read preference. - `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. rNrcrYr&)rNr`r. _SECONDARYr[rPrrr.zSecondary.__init__cCt|jt|j|Sr])rrrr^rrRrrrrT zSecondary.__call__rGr_rrrPrr` r`crW) SecondaryPreferreda^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. :Parameters: - `tag_sets`: The :attr:`~tag_sets` for this read preference. - `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. rNrcrYr&)rNrfr._SECONDARY_PREFERREDr[rPrrr.6r\zSecondaryPreferred.__init__cCs$t|jt|j|}|r|S|jSr])rrrr^rrQ)r,rS secondariesrrrrT;szSecondaryPreferred.__call__rGr_rrrPrrf!s rfcrW) NearestaNearest 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. :Parameters: - `tag_sets`: The :attr:`~tag_sets` for this read preference. - `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. rNrcrYr&)rNrir._NEARESTr[rPrrr.]rbzNearest.__init__cCrcr])rrrr^rrRrrrrT`rdzNearest.__call__rGr_rrrPrriHrerircCsB|tkr|digfvrtd|dkrtdtSt|||S)Nz4Read preference primary cannot be combined with tagsrzCRead preference primary cannot be combined with maxStalenessSeconds)rOrrM_ALL_READ_PREFERENCESrCrrrmake_read_preferencelsrl)PRIMARYPRIMARY_PREFERRED SECONDARYSECONDARY_PREFERREDNEARESTc@s.eZdZdZeZeZeZ e Z e Z dS)ReadPreferenceaDAn enum that defines the read preference modes supported by PyMongo. 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. N)r0rHrIrJrMrmrXrnr`rorfrprirqrrrrrrs1 rrcCs t|S)z7Get the read preference mode from mongos/uri name. )r'index)r2rrrread_pref_mode_from_names rtc@s0eZdZdZddZddZddZdd Zd S) MovingAveragez0Tracks an exponentially-weighted moving average.cC d|_dSr&averager1rrrr.rBzMovingAverage.__init__cCs8|dkrdS|jdur||_dSd|jd||_dS)Nrg?g?rw)r,samplerrr add_samples   zMovingAverage.add_samplecCr3)z6Get the calculated average, or None if no samples yet.rwr1rrrgetrUzMovingAverage.getcCrvr&rwr1rrrresetrBzMovingAverage.resetN)r0rHrIrJr.rzr{r|rrrrrus  ruN)r)!rJbson.py3compatrrpymongorpymongo.errorsrpymongo.server_selectorsrrrOrZrargrjr'rrr objectr!rMrXr`rfrirkrl_MODESrrrtrurrrrs8   k& '    9