hVG@dZddlmZmZddlmZddlmZddlm Z m Z dZ dZ dZ dZd Zd Zd Zd Zd ZdZGddeZGddeZGddeZGddeZGddeZGddeZeeeeefZd#dZdZGddeZdZ Gd d!eZ!y")$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 secondarysecondaryPreferrednearestc||St|tstd|dt|dk(rt d|d|D]+}t|t j rtd|d|S)z3Validate tag sets for a MongoReplicaSetClient. z Tag sets z invalid, must be a listrz: 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) isinstancelist TypeErrorlen ValueErrorrMapping)tag_setstagss [/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/read_preferences.py_validate_tag_setsr(s h %6>AB B 8} #$ $0$ ,)-/0 00 Oc d|zS)Nz6maxStalenessSeconds must be a positive integer, not %s max_stalenesss r_invalid_max_staleness_msgr"@s D  rc|dk(ryt|tstt||dkrt t||S)zValidate max_staleness.r)rrrr"rr s r_validate_max_stalenessr%FsG m] 32=ABB3MBCC rcH|yt|tstd||S)zValidate hedge.Nz hedge must be a dictionary, not )rdictr)hedges r_validate_hedger)Ts' } eT "GHH LrceZdZdZdZddZedZedZedZ edZ ed Z ed Z ed Z ed Zd ZdZdZdZdZy) _ServerModez)Base class for all read preferences. ) __mongos_mode__mode __tag_sets__max_staleness__hedgeNct||_||_t||_t ||_t||_yN) _MONGOS_MODES_ServerMode__mongos_mode_ServerMode__moder_ServerMode__tag_setsr%_ServerMode__max_stalenessr)_ServerMode__hedge)selfmoderr!r(s r__init__z_ServerMode.__init__fs;*40 ,X66}E&u- rc.|jjS)z*The name of this read preference. ) __class____name__r9s rnamez_ServerMode.namems~~&&&rc|jS)z1The mongos mode of this read preference. )r4r?s r mongos_modez_ServerMode.mongos_modess!!!rcd|ji}|jdigfvr|j|d<|jdk7r|j|d<|jdifvr|j|d<|S)z'Read preference as a document. r:Nrr$maxStalenessSecondsr()r4r6r7r8)r9docs rdocumentz_ServerMode.documentystt))* ??4", .//CK   2 %)-)=)=C% & <<bz )<`_ )r6rr?s rrz_ServerMode.tag_setss )-tDOO$AbTArc|jS)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.r7r?s rr!z_ServerMode.max_stalenesss ###rc|jS)aThe 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 )r8r?s rr(z_ServerMode.hedges,||rc(|jdk(rdSdS)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`. r$rrJr?s rmin_wire_versionz_ServerMode.min_wire_versions((B.q5A5rcn|jd|jd|jd|jdS)Nz (tag_sets=z, max_staleness=z, hedge=))r@r6r7r8r?s r__repr__z_ServerMode.__repr__s) IIt(<(?6u_7MN&uW~6 rNr$N)r> __module__ __qualname____doc__ __slots__r;propertyr@rBrFr:rr!r(rNrQrVrXrZr]rrrr+r+_sI.'' ""     B B$$ . 6 6L!'7rr+c8eZdZdZdZfdZdZdZdZxZ 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. rc4tt| tyr2)superrer;_PRIMARY)r9r=s rr;zPrimary.__init__s gt%h/rc|jS)z*Apply this read preference to a Selection.)primary_selectionr9 selections r__call__zPrimary.__call__s***rcy)Nz Primary()rr?s rrQzPrimary.__repr__srcTt|tr|jtk(StSr2)rr+r:rhrSrTs rrVzPrimary.__eq__s! e[ )::) )r) r>r_r`rarbr;rmrQrV __classcell__r=s@rreres#I0+rrec.eZdZdZdZdfd ZdZxZS)PrimaryPreferredaPrimaryPreferred 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. - `hedge`: The :attr:`~hedge` to use if the primary is not available. .. versionchanged:: 3.11 Added ``hedge`` parameter. rc:tt| t|||yr2)rgrsr;_PRIMARY_PREFERREDr9rr!r(r=s rr;zPrimaryPreferred.__init__s . - @rc|jr |jSt|jt j |j |Sz(Apply this read preference to Selection.)r rjrrrselectr!rks rrmzPrimaryPreferred.__call__#sD   .. .6 '..&& 34 4rr^r>r_r`rarbr;rmrprqs@rrsrss.I@4rrsc.eZdZdZdZdfd ZdZxZS) SecondaryaSecondary 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. - `hedge`: The :attr:`~hedge` for this read preference. .. versionchanged:: 3.11 Added ``hedge`` parameter. rc:tt| t|||yr2)rgr|r; _SECONDARYrvs rr;zSecondary.__init__Gs i' - 8rcjt|jtj|j|Srx)rrrryr!rks rrmzSecondary.__call__Ks/2 MM # * *""I /0 0rr^rzrqs@rr|r|.s,I80rr|c.eZdZdZdZdfd ZdZxZS)SecondaryPreferredaSecondaryPreferred 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. - `hedge`: The :attr:`~hedge` for this read preference. .. versionchanged:: 3.11 Added ``hedge`` parameter. rc:tt| t|||yr2)rgrr;_SECONDARY_PREFERREDrvs rr;zSecondaryPreferred.__init__ls  $0 (M5 Brct|jtj|j|}|r|S|j Srx)rrrryr!rj)r9rl secondariess rrmzSecondaryPreferred.__call__psC9 MM # * *""I /0  .. .rr^rzrqs@rrrSs,IB /rrc.eZdZdZdZdfd ZdZxZS)NearestavNearest 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. - `hedge`: The :attr:`~hedge` for this read preference. .. versionchanged:: 3.11 Added ``hedge`` parameter. rc:tt| t|||yr2)rgrr;_NEARESTrvs rr;zNearest.__init__s gt% h u 6rcjt|jtj|j|Srx)rrrryr!rks rrmzNearest.__call__s// MM # * *""I /0 0rr^rzrqs@rrr}s,I60rrc|tk(r,|digfvr td|dk7r tdtSt|||S)Nz4Read preference primary cannot be combined with tagsr$zCRead preference primary cannot be combined with maxStalenessSeconds)rhrre_ALL_READ_PREFERENCES)r:rr!s rmake_read_preferencersd x D2$< '$&DE E B $&IJ Jy  &x ??r)PRIMARYPRIMARY_PREFERRED SECONDARYSECONDARY_PREFERREDNEARESTcVeZdZdZeZeZeZ e Z e Z y)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)r>r_r`rarerrsrr|rrrrrrrrrrs10biG(* I,.iGrrc,tj|S)z7Get the read preference mode from mongos/uri name. )r3index)r@s rread_pref_mode_from_namers   t $$rc(eZdZdZdZdZdZdZy) MovingAveragez0Tracks an exponentially-weighted moving average.cd|_yr2averager?s rr;zMovingAverage.__init__  rcl|dkry|j||_yd|jzd|zz|_y)Nrg?g?r)r9samples r add_samplezMovingAverage.add_samples: A:  << !DL-f r_r`rar;rrrrrrrrs: =rrN)r$)"rabson.py3compatrrpymongorpymongo.errorsrpymongo.server_selectorsrrrhrur~rrr3rr"r%r)objectr+rersr|rrrr_MODESrrrrrrrsI-+-K     0 G7&G7Tk8&4{&4R"0 "0J'/'/T"0k"0J!"2"$6A @ 6V6r% Fr