i)iPdZddlmZddlZddlmZmZddlmZm Z m Z m Z m Z ddl mZddlmZmZddlmZmZdd lmZmZerdd lmZdd lmZdd lmZed dZegggggZGddZGddeZ GddeZ!GddeZ"GddeZ#GddeZ$dqdZ%drd$Z&dsd'Z'dtd,Z(Gd-d.Z)Gd/d0e)Z*Gd1d2e)Z+Gd3d4e)Z,Gd5d6Z-Gd7d8e-Z.Gd9d:e-Z/Gd;de-Z1Gd?d@Z2GdAdBZ3GdCdDZ4GdEdFe4Z5GdGdHe5Z6GdIdJe5Z7GdKdLe6Z8GdMdNe5Z9GdOdPe4Z:GdQdRe6Z;GdSdTe6Z<GdUdVe5Z=GdWdXZ>GdYdZe>Z?Gd[d\e>Z@Gd]d^e>ZAGd_d`ZBGdadbeBZCGdcddeBZDGdedfeBZEGdgdhZFGdidjeFZGGdkdleFZHGdmdneFZIGdodpZJdS)uaTools to monitor driver events. .. versionadded:: 3.1 .. attention:: Starting in PyMongo 3.11, the monitoring classes outlined below are included in the PyMongo distribution under the :mod:`~pymongo.event_loggers` submodule. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. Use :func:`register` to register global listeners for specific events. Listeners must inherit from one of the abstract classes below and implement the correct functions for that class. For example, a simple command logger might be implemented like this:: import logging from pymongo import monitoring class CommandLogger(monitoring.CommandListener): def started(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} started on server " "{0.connection_id}".format(event)) def succeeded(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "succeeded in {0.duration_micros} " "microseconds".format(event)) def failed(self, event): logging.info("Command {0.command_name} with request id " "{0.request_id} on server {0.connection_id} " "failed in {0.duration_micros} " "microseconds".format(event)) monitoring.register(CommandLogger()) Server discovery and monitoring events are also available. For example:: class ServerLogger(monitoring.ServerListener): def opened(self, event): logging.info("Server {0.server_address} added to topology " "{0.topology_id}".format(event)) def description_changed(self, event): previous_server_type = event.previous_description.server_type new_server_type = event.new_description.server_type if new_server_type != previous_server_type: # server_type_name was added in PyMongo 3.4 logging.info( "Server {0.server_address} changed type from " "{0.previous_description.server_type_name} to " "{0.new_description.server_type_name}".format(event)) def closed(self, event): logging.warning("Server {0.server_address} removed from topology " "{0.topology_id}".format(event)) class HeartbeatLogger(monitoring.ServerHeartbeatListener): def started(self, event): logging.info("Heartbeat sent to server " "{0.connection_id}".format(event)) def succeeded(self, event): # The reply.document attribute was added in PyMongo 3.4. logging.info("Heartbeat to server {0.connection_id} " "succeeded with reply " "{0.reply.document}".format(event)) def failed(self, event): logging.warning("Heartbeat to server {0.connection_id} " "failed with error {0.reply}".format(event)) class TopologyLogger(monitoring.TopologyListener): def opened(self, event): logging.info("Topology with id {0.topology_id} " "opened".format(event)) def description_changed(self, event): logging.info("Topology description updated for " "topology id {0.topology_id}".format(event)) previous_topology_type = event.previous_description.topology_type new_topology_type = event.new_description.topology_type if new_topology_type != previous_topology_type: # topology_type_name was added in PyMongo 3.4 logging.info( "Topology {0.topology_id} changed type from " "{0.previous_description.topology_type_name} to " "{0.new_description.topology_type_name}".format(event)) # The has_writable_server and has_readable_server methods # were added in PyMongo 3.4. if not event.new_description.has_writable_server(): logging.warning("No writable servers available.") if not event.new_description.has_readable_server(): logging.warning("No readable servers available.") def closed(self, event): logging.info("Topology with id {0.topology_id} " "closed".format(event)) Connection monitoring and pooling events are also available. For example:: class ConnectionPoolLogger(ConnectionPoolListener): def pool_created(self, event): logging.info("[pool {0.address}] pool created".format(event)) def pool_ready(self, event): logging.info("[pool {0.address}] pool is ready".format(event)) def pool_cleared(self, event): logging.info("[pool {0.address}] pool cleared".format(event)) def pool_closed(self, event): logging.info("[pool {0.address}] pool closed".format(event)) def connection_created(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection created".format(event)) def connection_ready(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection setup succeeded".format(event)) def connection_closed(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection closed, reason: " "{0.reason}".format(event)) def connection_check_out_started(self, event): logging.info("[pool {0.address}] connection check out " "started".format(event)) def connection_check_out_failed(self, event): logging.info("[pool {0.address}] connection check out " "failed, reason: {0.reason}".format(event)) def connection_checked_out(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked out of pool".format(event)) def connection_checked_in(self, event): logging.info("[pool {0.address}][connection #{0.connection_id}] " "connection checked into pool".format(event)) Event listeners can also be registered per instance of :class:`~pymongo.mongo_client.MongoClient`:: client = MongoClient(event_listeners=[CommandLogger()]) Note that previously registered global listeners are automatically included when configuring per client event listeners. Registering a new global listener will not add that listener to existing client instances. .. note:: Events are delivered **synchronously**. Application threads block waiting for event handlers (e.g. :meth:`~CommandListener.started`) to return. Care must be taken to ensure that your event handlers are efficient enough to not adversely affect overall application performance. .. warning:: The command documents published through this API are *not* copies. If you intend to modify them in any way you must copy them in your event handler first. ) annotationsN)abc namedtuple) TYPE_CHECKINGAnyMappingOptionalSequence)ObjectId)Hello HelloCompat)_SENSITIVE_COMMANDS_handle_exception)_Address _DocumentOut) timedelta)ServerDescription)TopologyDescription _Listeners)command_listenersserver_listenersserver_heartbeat_listenerstopology_listenerscmap_listenersceZdZdZdS)_EventListenerz,Abstract base class for all event listeners.N)__name__ __module__ __qualname____doc__d/Users/user/workspace/sujinbaek/cqa-test-app/venv/lib/python3.11/site-packages/pymongo/monitoring.pyrrs6666r"rc*eZdZdZd dZd dZdd Zd S)CommandListenerzAbstract base class for command listeners. Handles `CommandStartedEvent`, `CommandSucceededEvent`, and `CommandFailedEvent`. eventCommandStartedEventreturnNonect)zAbstract method to handle a `CommandStartedEvent`. :param event: An instance of :class:`CommandStartedEvent`. NotImplementedErrorselfr&s r#startedzCommandListener.started "!r"CommandSucceededEventct)zAbstract method to handle a `CommandSucceededEvent`. :param event: An instance of :class:`CommandSucceededEvent`. r+r-s r# succeededzCommandListener.succeededr0r"CommandFailedEventct)z}Abstract method to handle a `CommandFailedEvent`. :param event: An instance of :class:`CommandFailedEvent`. r+r-s r#failedzCommandListener.failedr0r"N)r&r'r(r))r&r1r(r))r&r4r(r)rrrr r/r3r6r!r"r#r%r%sZ """"""""""""""r"r%cjeZdZdZddZddZdd Zdd Zd dZd!dZ d"dZ d#dZ d$dZ d%dZ d&dZdS)'ConnectionPoolListenera-Abstract base class for connection pool listeners. Handles all of the connection pool events defined in the Connection Monitoring and Pooling Specification: :class:`PoolCreatedEvent`, :class:`PoolClearedEvent`, :class:`PoolClosedEvent`, :class:`ConnectionCreatedEvent`, :class:`ConnectionReadyEvent`, :class:`ConnectionClosedEvent`, :class:`ConnectionCheckOutStartedEvent`, :class:`ConnectionCheckOutFailedEvent`, :class:`ConnectionCheckedOutEvent`, and :class:`ConnectionCheckedInEvent`. .. versionadded:: 3.9 r&PoolCreatedEventr(r)ct)zAbstract method to handle a :class:`PoolCreatedEvent`. Emitted when a connection Pool is created. :param event: An instance of :class:`PoolCreatedEvent`. r+r-s r# pool_createdz#ConnectionPoolListener.pool_created "!r"PoolReadyEventct)zAbstract method to handle a :class:`PoolReadyEvent`. Emitted when a connection Pool is marked ready. :param event: An instance of :class:`PoolReadyEvent`. .. versionadded:: 4.0 r+r-s r# pool_readyz!ConnectionPoolListener.pool_readys "!r"PoolClearedEventct)zAbstract method to handle a `PoolClearedEvent`. Emitted when a connection Pool is cleared. :param event: An instance of :class:`PoolClearedEvent`. r+r-s r# pool_clearedz#ConnectionPoolListener.pool_cleared"r=r"PoolClosedEventct)zAbstract method to handle a `PoolClosedEvent`. Emitted when a connection Pool is closed. :param event: An instance of :class:`PoolClosedEvent`. r+r-s r# pool_closedz"ConnectionPoolListener.pool_closed+r=r"ConnectionCreatedEventct)zAbstract method to handle a :class:`ConnectionCreatedEvent`. Emitted when a connection Pool creates a Connection object. :param event: An instance of :class:`ConnectionCreatedEvent`. r+r-s r#connection_createdz)ConnectionPoolListener.connection_created4r=r"ConnectionReadyEventct)zAbstract method to handle a :class:`ConnectionReadyEvent`. Emitted when a connection has finished its setup, and is now ready to use. :param event: An instance of :class:`ConnectionReadyEvent`. r+r-s r#connection_readyz'ConnectionPoolListener.connection_ready= "!r"ConnectionClosedEventct)zAbstract method to handle a :class:`ConnectionClosedEvent`. Emitted when a connection Pool closes a connection. :param event: An instance of :class:`ConnectionClosedEvent`. r+r-s r#connection_closedz(ConnectionPoolListener.connection_closedGr=r"ConnectionCheckOutStartedEventct)zAbstract method to handle a :class:`ConnectionCheckOutStartedEvent`. Emitted when the driver starts attempting to check out a connection. :param event: An instance of :class:`ConnectionCheckOutStartedEvent`. r+r-s r#connection_check_out_startedz3ConnectionPoolListener.connection_check_out_startedPr=r"ConnectionCheckOutFailedEventct)zAbstract method to handle a :class:`ConnectionCheckOutFailedEvent`. Emitted when the driver's attempt to check out a connection fails. :param event: An instance of :class:`ConnectionCheckOutFailedEvent`. r+r-s r#connection_check_out_failedz2ConnectionPoolListener.connection_check_out_failedYr=r"ConnectionCheckedOutEventct)zAbstract method to handle a :class:`ConnectionCheckedOutEvent`. Emitted when the driver successfully checks out a connection. :param event: An instance of :class:`ConnectionCheckedOutEvent`. r+r-s r#connection_checked_outz-ConnectionPoolListener.connection_checked_outbr=r"ConnectionCheckedInEventct)zAbstract method to handle a :class:`ConnectionCheckedInEvent`. Emitted when the driver checks in a connection back to the connection Pool. :param event: An instance of :class:`ConnectionCheckedInEvent`. r+r-s r#connection_checked_inz,ConnectionPoolListener.connection_checked_inkrMr"N)r&r:r(r))r&r>r(r))r&rAr(r))r&rDr(r))r&rGr(r))r&rJr(r))r&rNr(r))r&rQr(r))r&rTr(r))r&rWr(r))r&rZr(r))rrrr r<r@rCrFrIrLrPrSrVrYr\r!r"r#r9r9s  """" " " " """""""""""""""""""""""""""""""""""""""r"r9c*eZdZdZd dZd dZdd Zd S)ServerHeartbeatListenerzAbstract base class for server heartbeat listeners. Handles `ServerHeartbeatStartedEvent`, `ServerHeartbeatSucceededEvent`, and `ServerHeartbeatFailedEvent`. .. versionadded:: 3.3 r&ServerHeartbeatStartedEventr(r)ct)zAbstract method to handle a `ServerHeartbeatStartedEvent`. :param event: An instance of :class:`ServerHeartbeatStartedEvent`. r+r-s r#r/zServerHeartbeatListener.startedr0r"ServerHeartbeatSucceededEventct)zAbstract method to handle a `ServerHeartbeatSucceededEvent`. :param event: An instance of :class:`ServerHeartbeatSucceededEvent`. r+r-s r#r3z!ServerHeartbeatListener.succeededr0r"ServerHeartbeatFailedEventct)zAbstract method to handle a `ServerHeartbeatFailedEvent`. :param event: An instance of :class:`ServerHeartbeatFailedEvent`. r+r-s r#r6zServerHeartbeatListener.failedr0r"N)r&r_r(r))r&rar(r))r&rcr(r)r7r!r"r#r^r^vsZ""""""""""""""r"r^c*eZdZdZd dZd dZdd Zd S)TopologyListenerzAbstract base class for topology monitoring listeners. Handles `TopologyOpenedEvent`, `TopologyDescriptionChangedEvent`, and `TopologyClosedEvent`. .. versionadded:: 3.3 r&TopologyOpenedEventr(r)ct)zAbstract method to handle a `TopologyOpenedEvent`. :param event: An instance of :class:`TopologyOpenedEvent`. r+r-s r#openedzTopologyListener.openedr0r"TopologyDescriptionChangedEventct)zAbstract method to handle a `TopologyDescriptionChangedEvent`. :param event: An instance of :class:`TopologyDescriptionChangedEvent`. r+r-s r#description_changedz$TopologyListener.description_changedr0r"TopologyClosedEventct)zAbstract method to handle a `TopologyClosedEvent`. :param event: An instance of :class:`TopologyClosedEvent`. r+r-s r#closedzTopologyListener.closedr0r"N)r&rgr(r))r&rjr(r))r&rmr(r)rrrr rirlror!r"r#rfrfZ""""""""""""""r"rfc*eZdZdZd dZd dZdd Zd S)ServerListenerzAbstract base class for server listeners. Handles `ServerOpeningEvent`, `ServerDescriptionChangedEvent`, and `ServerClosedEvent`. .. versionadded:: 3.3 r&ServerOpeningEventr(r)ct)z}Abstract method to handle a `ServerOpeningEvent`. :param event: An instance of :class:`ServerOpeningEvent`. r+r-s r#rizServerListener.openedr0r"ServerDescriptionChangedEventct)zAbstract method to handle a `ServerDescriptionChangedEvent`. :param event: An instance of :class:`ServerDescriptionChangedEvent`. r+r-s r#rlz"ServerListener.description_changedr0r"ServerClosedEventct)z{Abstract method to handle a `ServerClosedEvent`. :param event: An instance of :class:`ServerClosedEvent`. r+r-s r#rozServerListener.closedr0r"N)r&rtr(r))r&rvr(r))r&rxr(r)rpr!r"r#rsrsrqr"rsdurrr(intcJt|dzS)z'Convert duration 'dur' to microseconds.g.A)r{ total_seconds)rzs r# _to_microsr~s! s  ""T) * **r"optionstr listenersSequence[_EventListeners]c t|tjs!t|dt ||D]9}t|t s"td|dt |:|S)zValidate event listenersz must be a list or tuple, not Listeners for | must be either a CommandListener, ServerHeartbeatListener, ServerListener, TopologyListener, or ConnectionPoolListener,not ) isinstancerr TypeErrortyper)rrlisteners r#_validate_event_listenersrs i . .T6RRiRRSSS(N33 (((H~~ ((   r"rr)ct|ts"td|dt|t|trt j|t|trt j |t|trt j |t|trt j |t|tr!t j|dSdS)zRegister a global event listener. :param listener: A subclasses of :class:`CommandListener`, :class:`ServerHeartbeatListener`, :class:`ServerListener`, :class:`TopologyListener`, or :class:`ConnectionPoolListener`. rrN)rrrrr% _LISTENERSrappendr^rrsrrfrr9r)rs r#registerrs0 h / /  $X $ $>>  $ $   (O,,6$++H555(344?-44X>>>(N++5#**8444(,--7%,,X666(2333!((2222233r" command_namedocMapping[str, Any]boolcV|dtjfvrd|vrdSdS)NhellospeculativeAuthenticateTF)lowerr LEGACY_CMD)rrs r#_is_speculative_authenticaters6+*@ AAA % , ,t 5r"ceZdZdZdZ dddZeddZeddZeddZ ed dZ ed!dZ eddZ ed!dZ dS)" _CommandEventzBase class for command events.) __cmd_name __rqst_id __conn_id__op_id __service_id__db__server_conn_idNrr request_idr{ connection_idr operation_id Optional[int] service_idOptional[ObjectId] database_nameserver_connection_idr(r)ch||_||_||_||_||_||_||_dSN)_CommandEvent__cmd_name_CommandEvent__rqst_id_CommandEvent__conn_id_CommandEvent__op_id_CommandEvent__service_id_CommandEvent__db_CommandEvent__server_conn_id)r.rrrrrrrs r#__init__z_CommandEvent.__init__s='#&# &! 4r"c|jS)zThe command name.)rr.s r#rz_CommandEvent.command_name- r"c|jS)z"The request id for this operation.)rrs r#rz_CommandEvent.request_id2 ~r"c|jS)z@The address (host, port) of the server this command was sent to.)rrs r#rz_CommandEvent.connection_id7rr"c|jS)z^The service_id this command was sent to, or ``None``. .. versionadded:: 3.12 )rrs r#rz_CommandEvent.service_id<s   r"c|jS)z(An id for this series of events or None.)rrs r#rz_CommandEvent.operation_idD |r"c|jS)z^The database_name this command was sent to, or ``""``. .. versionadded:: 4.6 )rrs r#rz_CommandEvent.database_nameIs yr"c|jS)zThe server-side connection id for the connection this command was sent on, or ``None``. .. versionadded:: 4.7 )rrs r#rz"_CommandEvent.server_connection_idQs $$r"NrN)rrrr{rrrrrrrrrrr(r)r(rr(r{r(rr(r)r(r)rrrr __slots__rpropertyrrrrrrrr!r"r#rrs%((I *..255555$XXX!!!X!XX%%%X%%%r"rcjeZdZdZdZ ddfd ZeddZedfd ZddZ xZ S)r'aEvent published when a command starts. :param command: The command document. :param database_name: The name of the database this command was run against. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. )__cmdNcommandrrrrr{rrrrrrrr(r)c 2|st|dtt|}t||||||||} | t vst| |r i|_dS||_dS)Nz is not a valid commandrrr) ValueErrornextitersuperrrrr_CommandStartedEvent__cmd) r.rrrrrrrrcmd_name __class__s r#rzCommandStartedEvent.__init__hs DBBBCC CDMM**      !'!5     %%'' * * *.J8U\.].] *')DJJJ DJJJr"c|jS)zThe command document.)rrs r#rzCommandStartedEvent.commands zr"c*tjS)z6The name of the database this command was run against.)rrr.rs r#rz!CommandStartedEvent.database_namesww$$r"c d|jj|j|j|j|j|j|jS)Nz[<{} {} db: {!r}, command: {!r}, operation_id: {}, service_id: {}, server_connection_id: {}>) formatrrrrrrrrrs r#__repr__zCommandStartedEvent.__repr__sD i & N #         O  %   r"NN)rrrrrr{rrrrrrrrr(r)r(rr) rrrr rrrrrr __classcell__rs@r#r'r'Zs  I*..2!!!!!!!:X%%%%%X%         r"r'cheZdZdZdZ ddfd ZeddZeddZddZ xZ S) r1aOEvent published when a command succeeds. :param duration: The command duration as a datetime.timedelta. :param reply: The server reply document. :param command_name: The command name. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. :param database_name: The database this command was sent to, or ``""``. )__duration_micros__replyNrdurationdatetime.timedeltareplyrrrrr{rrrrrrrrr(r)c t||||||| t||_|} | t vst | |r i|_dS||_dSNr)rrr~'_CommandSucceededEvent__duration_microsrrr_CommandSucceededEvent__reply) r.rrrrrrrrrrrs r#rzCommandSucceededEvent.__init__s     !'!5    ",H!5!5%%'' * * *.J8UZ.[.[ *)+DLLL DLLLr"c|jSz/The duration of this operation in microseconds.)rrs r#duration_microsz%CommandSucceededEvent.duration_micros %%r"c|jSz/The server failure document for this operation.)rrs r#rzCommandSucceededEvent.replyrr"c d|jj|j|j|j|j|j|j|j S)Nzp<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, service_id: {}, server_connection_id: {}>) rrrrrrrrrrrs r#rzCommandSucceededEvent.__repr__sJ ~ & N #          O  %  r"r)rrrrrrrr{rrrrrrrrrrr(r)rrr) rrrr rrrrrrrrs@r#r1r1s  1I*..2!!!!!!!8&&&X&X         r"r1cheZdZdZdZ ddfd ZeddZeddZddZ xZ S) r4aNEvent published when a command fails. :param duration: The command duration as a datetime.timedelta. :param failure: The server reply document. :param command_name: The command name. :param request_id: The request id for this operation. :param connection_id: The address (host, port) of the server this command was sent to. :param operation_id: An optional identifier for a series of related events. :param service_id: The service_id this command was sent to, or ``None``. :param database_name: The database this command was sent to, or ``""``. )r __failureNrrrfailurerrrrr{rrrrrrrrr(r)c t||||||| t||_||_dSr)rrr~$_CommandFailedEvent__duration_micros_CommandFailedEvent__failure) r.rrrrrrrrrrs r#rzCommandFailedEvent.__init__sX     !'!5    ",H!5!5 r"c|jSr)rrs r#rz"CommandFailedEvent.duration_micros rr"c|jSr)rrs r#rzCommandFailedEvent.failurerr"c d|jj|j|j|j|j|j|j|j |j S)Nz<{} {} db: {!r}, command: {!r}, operation_id: {}, duration_micros: {}, failure: {!r}, service_id: {}, server_connection_id: {}>) rrrrrrrrrrrrs r#rzCommandFailedEvent.__repr__sR G & N #          L O  %  r"r)rrrrrrrr{rrrrrrrrrrr(r)rrr) rrrr rrrrrrrrs@r#r4r4s  3I*..2!!!!!!!0&&&X&X        r"r4c>eZdZdZdZd dZed dZdd Zd S) _PoolEventzBase class for pool events. __addressaddressrr(r)c||_dSr_PoolEvent__addressr.rs r#rz_PoolEvent.__init__*  r"c|jS)zbThe address (host, port) pair of the server the pool is attempting to connect to. rrs r#rz_PoolEvent.address- ~r"rc0|jjd|jdSN())rrrrs r#rz_PoolEvent.__repr__4 .)??DN????r"Nrrr(r)rr rrrr rrrrrr!r"r#rr%sm%%I!!!!X @@@@@@r"rcHeZdZdZdZd fd Zedd Zdd ZxZ S)r:zPublished when a Connection Pool is created. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 3.9 ) __optionsrroptionsdict[str, Any]r(r)cXt|||_dSr)rr_PoolCreatedEvent__options)r.rr rs r#rzPoolCreatedEvent.__init__Cs& !!! r"c|jS)zCAny non-default pool options that were set on this Connection Pool.)rrs r#r zPoolCreatedEvent.optionsGrr"rc@|jjd|jd|jdSNrz, r)rrrrrs r#rzPoolCreatedEvent.__repr__Ls*.)QQDLQQdnQQQQr"rrr r r(r))r(r r) rrrr rrrr rrrs@r#r:r:8sI!!!!!!XRRRRRRRRr"r:ceZdZdZdZdS)r>zPublished when a Connection Pool is marked ready. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. .. versionadded:: 4.0 r!Nrrrr rr!r"r#r>r>PIIIr"r>cfeZdZdZdZ ddfd ZeddZeddZddZ xZ S)rAawPublished when a Connection Pool is cleared. :param address: The address (host, port) pair of the server this Pool is attempting to connect to. :param service_id: The service_id this command was sent to, or ``None``. :param interrupt_connections: True if all active connections were interrupted by the Pool during clearing. .. versionadded:: 3.9 )r__interrupt_connectionsNFrrrrinterrupt_connectionsrr(r)cft|||_||_dSr)rr_PoolClearedEvent__service_id(_PoolClearedEvent__interrupt_connections)r.rrrrs r#rzPoolClearedEvent.__init__is3 !!!&'<$$$r"c|jS)zConnections with this service_id are cleared. When service_id is ``None``, all connections in the pool are cleared. .. versionadded:: 3.12 )rrs r#rzPoolClearedEvent.service_idss   r"c|jS)zdIf True, active connections are interrupted during clearing. .. versionadded:: 4.7 )rrs r#rz&PoolClearedEvent.interrupt_connections}s ++r"rcP|jjd|jd|jd|jdSr)rrrrrrs r#rzPoolClearedEvent.__repr__s7.)vvDLvvd>OvvUYUqvvvvr")NFrrrrrrr(r)rr(rr) rrrr rrrrrrrrs@r#rArA\seZdZdZdZd dZed dZdd Zd S)_ConnectionEventz)Private base class for connection events.rrrr(r)c||_dSr_ConnectionEvent__addressrs r#rz_ConnectionEvent.__init__rr"c|jS)ziThe address (host, port) pair of the server this connection is attempting to connect to. r6rs r#rz_ConnectionEvent.addressrr"rc0|jjd|jdSr)rrr7rs r#rz_ConnectionEvent.__repr__rr"Nrrrr r!r"r#r4r4sm33I!!!!X @@@@@@r"r4cHeZdZdZdZd fd Zedd Zdd ZxZ S)_ConnectionIdEventz4Private base class for connection events with an id.)__connection_idrrrr{r(r)cXt|||_dSr)rr!_ConnectionIdEvent__connection_id)r.rrrs r#rz_ConnectionIdEvent.__init__s) !!!,r"c|jS)zThe ID of the connection.)r>rs r#rz _ConnectionIdEvent.connection_ids ##r"rc@|jjd|jd|jdSr)rrrr>rs r#rz_ConnectionIdEvent.__repr__s+.)WWDLWWd>RWWWWr"rrrr{r(r)rr) rrrr rrrrrrrs@r#r;r;s>>$I------$$$X$XXXXXXXXr"r;cHeZdZdZdZdfd Zedd ZddZxZ S)_ConnectionDurationEventz9Private base class for connection events with a duration.) __durationrrrr{rOptional[float]r(r)cZt||||_dSr)rr"_ConnectionDurationEvent__duration)r.rrrrs r#rz!_ConnectionDurationEvent.__init__s( -000"r"c|jS)zMThe duration of the connection event. .. versionadded:: 4.7 )rGrs r#rz!_ConnectionDurationEvent.durations r"rcP|jjd|jd|jd|jdSr)rrrrrGrs r#rz!_ConnectionDurationEvent.__repr__s7.)jjDLjjd>PjjVZVejjjjr")rrrr{rrEr(r))r(rEr) rrrr rrrrrrrs@r#rCrCsCCI######Xkkkkkkkkr"rCceZdZdZdZdS)rGaPublished when a Connection Pool creates a Connection object. NOTE: This connection is not ready for use until the :class:`ConnectionReadyEvent` is published. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r!Nrr!r"r#rGrGs  IIIr"rGceZdZdZdZdS)rJa&Published when a Connection has finished its setup, and is ready to use. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r!Nrr!r"r#rJrJIIIr"rJcHeZdZdZdZd fd Zedd Zdd ZxZ S)rNaKPublished when a Connection is closed. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. :param reason: A reason explaining why this connection was closed. .. versionadded:: 3.9 __reasonrrrr{reasonrcZt||||_dSr)rr_ConnectionClosedEvent__reason)r.rrrPrs r#rzConnectionClosedEvent.__init__!s( -000 r"r(c|jS)zA reason explaining why this connection was closed. The reason must be one of the strings from the :class:`ConnectionClosedReason` enum. )rRrs r#rPzConnectionClosedEvent.reason% }r"cdd|jj|j|j|jS)Nz{}({!r}, {!r}, {!r}))rrrrrrRrs r#rzConnectionClosedEvent.__repr__.s2%,, N # L   M    r")rrrr{rPrr rrrr rrrrPrrrs@r#rNrNsIX        r"rNceZdZdZdZdS)rQzPublished when the driver starts attempting to check out a connection. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. .. versionadded:: 3.9 r!Nrr!r"r#rQrQ7rr"rQcHeZdZdZdZdfd Zedd Zdd ZxZ S)rTa!Published when the driver's attempt to check out a connection fails. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param reason: A reason explaining why connection check out failed. .. versionadded:: 3.9 rNrrrPrrrEr(r)c^t|d|||_dS)Nr)rrr)rr&_ConnectionCheckOutFailedEvent__reason)r.rrPrrs r#rz&ConnectionCheckOutFailedEvent.__init__Os- HMMM r"c|jS)zA reason explaining why connection check out failed. The reason must be one of the strings from the :class:`ConnectionCheckOutFailedReason` enum. )rZrs r#rPz$ConnectionCheckOutFailedEvent.reasonSrTr"cP|jjd|jd|jd|jdSr)rrrrZrrs r#rz&ConnectionCheckOutFailedEvent.__repr__\s6.)ccDLccdmccQUQ^ccccr")rrrPrrrEr(r)rrVrs@r#rTrTCsIXddddddddr"rTceZdZdZdZdS)rWaPublished when the driver successfully checks out a connection. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r!Nrr!r"r#rWrW`rLr"rWceZdZdZdZdS)rZaPublished when the driver checks in a Connection into the Pool. :param address: The address (host, port) pair of the server this Connection is attempting to connect to. :param connection_id: The integer ID of the Connection in this Pool. .. versionadded:: 3.9 r!Nrr!r"r#rZrZmrLr"rZcVeZdZdZdZdd Zedd Zedd Zdd Z dS) _ServerEventzBase class for server events.)__server_address __topology_idserver_addressr topology_idr r(r)c"||_||_dSr)_ServerEvent__server_address_ServerEvent__topology_id)r.rcrds r#rz_ServerEvent.__init__s .(r"c|jS)z+The address (host, port) pair of the server)rfrs r#rcz_ServerEvent.server_addresss $$r"c|jSz>A unique identifier for the topology this server is a part of.)rgrs r#rdz_ServerEvent.topology_id !!r"rcBd|jjd|jd|jdS)N<  topology_id: >)rrrcrdrs r#rz_ServerEvent.__repr__s/c4>*ccT-@ccPTP`ccccr"Nrcrrdr r(r)rr(r r) rrrr rrrrcrdrr!r"r#r`r`zs''5I))))%%%X%"""X"ddddddr"r`c`eZdZdZdZdfd Zedd Zedd ZddZ xZ S)rvzJPublished when server description changes. .. versionadded:: 3.3 __previous_description__new_descriptionprevious_descriptionrnew_descriptionargsrr(r)cPtj|||_||_dSr)rr4_ServerDescriptionChangedEvent__previous_description/_ServerDescriptionChangedEvent__new_descriptionr.rwrxryrs r#rz&ServerDescriptionChangedEvent.__init__/ $&:#!0r"c|jS)zUThe previous :class:`~pymongo.server_description.ServerDescription`. )r{rs r#rwz2ServerDescriptionChangedEvent.previous_description **r"c|jS)zPThe new :class:`~pymongo.server_description.ServerDescription`. )r|rs r#rxz-ServerDescriptionChangedEvent.new_description %%r"rcdd|jj|j|j|jS)Nz <{} {} changed from: {}, to: {}>)rrrrcrwrxrs r#rz&ServerDescriptionChangedEvent.__repr__s4188 N #    %     r")rwrrxrryrr(r))r(rr rrrr rrrrwrxrrrs@r#rvrv @I111111+++X+ &&&X&         r"rvceZdZdZdZdS)rtzEPublished when server is initialized. .. versionadded:: 3.3 r!Nrr!r"r#rtrt IIIr"rtceZdZdZdZdS)rxz@Published when server is closed. .. versionadded:: 3.3 r!Nrr!r"r#rxrxrr"rxc>eZdZdZdZd dZed dZdd Zd S) TopologyEventz+Base class for topology description events.)rbrdr r(r)c||_dSr_TopologyEvent__topology_id)r.rds r#rzTopologyEvent.__init__s(r"c|jSrjrrs r#rdzTopologyEvent.topology_idrkr"rc2d|jjd|jdS)Nrmrorp)rrrdrs r#rzTopologyEvent.__repr__s#M4>*MM$:JMMMMr"Nrdr r(r)rrr) rrrr rrrrdrr!r"r#rrsm55"I))))"""X"NNNNNNr"rc`eZdZdZdZdfd Zedd Zedd ZddZ xZ S)rjzPPublished when the topology description changes. .. versionadded:: 3.3 rtrwrrxryrr(r)cPtj|||_||_dSr)rr6_TopologyDescriptionChangedEvent__previous_description1_TopologyDescriptionChangedEvent__new_descriptionr}s r#rz(TopologyDescriptionChangedEvent.__init__r~r"c|jS)zYThe previous :class:`~pymongo.topology_description.TopologyDescription`. )rrs r#rwz4TopologyDescriptionChangedEvent.previous_descriptionrr"c|jS)zTThe new :class:`~pymongo.topology_description.TopologyDescription`. )rrs r#rxz/TopologyDescriptionChangedEvent.new_descriptionrr"rcdd|jj|j|j|jS)Nz-<{} topology_id: {} changed from: {}, to: {}>)rrrrdrwrxrs r#rz(TopologyDescriptionChangedEvent.__repr__s4>EE N #    %     r")rwrrxrryrr(r))r(rrrrs@r#rjrjrr"rjceZdZdZdZdS)rgzKPublished when the topology is initialized. .. versionadded:: 3.3 r!Nrr!r"r#rgrgrr"rgceZdZdZdZdS)rmzFPublished when the topology is closed. .. versionadded:: 3.3 r!Nrr!r"r#rmrmrr"rmcXeZdZdZdZddd Zedd Zedd ZddZ dS)_ServerHeartbeatEventz'Base class for server heartbeat events.)r< __awaitedFrrawaitedrr(r)c"||_||_dSr)$_ServerHeartbeatEvent__connection_id_ServerHeartbeatEvent__awaited)r.rrs r#rz_ServerHeartbeatEvent.__init__s, r"c|jS)zSThe address (host, port) of the server this heartbeat was sent to. )rrs r#rz#_ServerHeartbeatEvent.connection_id!s ##r"c|jS)zgWhether the heartbeat was issued as an awaitable hello command. .. versionadded:: 4.6 )rrs r#rz_ServerHeartbeatEvent.awaited(s ~r"rcBd|jjd|jd|jdS)Nrmrnz awaited: rp)rrrrrs r#rz_ServerHeartbeatEvent.__repr__0s-Z4>*ZZT-?ZZ4<ZZZZr"NFrrrrr(r)rr!r) rrrr rrrrrrr!r"r#rrs110I!!!!!$$$X$ X[[[[[[r"rceZdZdZdZdS)r_zFPublished when a heartbeat is started. .. versionadded:: 3.3 r!Nrr!r"r#r_r_4rr"r_ceZdZdZdZ ddfd ZeddZeddZedfd Z ddZ xZ S)razIFired when the server heartbeat succeeds. .. versionadded:: 3.3 rDrFrfloatrHello[dict[str, Any]]rrrrr(r)cht||||_||_dSr)rr(_ServerHeartbeatSucceededEvent__duration%_ServerHeartbeatSucceededEvent__replyr.rrrrrs r#rz&ServerHeartbeatSucceededEvent.__init__Es1 000" r"c|jSz/The duration of this heartbeat in microseconds.)rrs r#rz&ServerHeartbeatSucceededEvent.durationPrr"c|jS)z-An instance of :class:`~pymongo.hello.Hello`.)rrs r#rz#ServerHeartbeatSucceededEvent.replyUrr"c*tjSzWhether the heartbeat was awaited. If true, then :meth:`duration` reflects the sum of the round trip time to the server and the time that the server waited before sending a response. .. versionadded:: 3.11 rrrs r#rz%ServerHeartbeatSucceededEvent.awaitedZwwr"rcpd|jj|j|j|j|jS)Nz,<{} {} duration: {}, awaited: {}, reply: {}>rrrrrrrrs r#rz&ServerHeartbeatSucceededEvent.__repr__fs7=DD N #   M L J    r"r) rrrrrrrrr(r)r(r)r(rr!r rrrr rrrrrrrrrs@r#rara=s *I       XX     X         r"raceZdZdZdZ ddfd ZeddZeddZedfd Z ddZ xZ S)rczxFired when the server heartbeat fails, either with an "ok: 0" or a socket exception. .. versionadded:: 3.3 rFrrr Exceptionrrrrr(r)cht||||_||_dSr)rr%_ServerHeartbeatFailedEvent__duration"_ServerHeartbeatFailedEvent__replyrs r#rz#ServerHeartbeatFailedEvent.__init__ys1 000" r"c|jSr)rrs r#rz#ServerHeartbeatFailedEvent.durationrr"c|jS)zA subclass of :exc:`Exception`.)rrs r#rz ServerHeartbeatFailedEvent.replyrr"c*tjSrrrs r#rz"ServerHeartbeatFailedEvent.awaitedrr"rcpd|jj|j|j|j|jS)Nz.<{} {} duration: {}, awaited: {}, reply: {!r}>rrs r#rz#ServerHeartbeatFailedEvent.__repr__s7?FF N #   M L J    r"r) rrrrrrrrr(r)r)r(rr!rrrs@r#rcrcps *I[`XX     X         r"rccneZdZdZdLdZedMdZedMdZedMd ZedMd Z edMd Z dNd Z dOdPdZ dQdRd%Z dSdTd'ZdUd)ZdVd,ZdWd.ZdXd2ZdXd3ZdYd7ZdZd8ZdZd9Zd[d;Zd\d?Zd]d@Z d^d_dBZd]dCZd`dDZdadEZdbdGZd]dHZdcdIZ dadJZ!d`dKZ"dS)d_EventListenerszConfigure event listeners for a client instance. Any event listeners registered globally are included by default. :param listeners: A list of event listeners. r"Optional[Sequence[_EventListener]]ctjdd|_tjdd|_tj}|dd|_tjdd|_tj dd|_ ||D]}t|tr|j |t|tr|j |t|tr|j |t|t r|j |t|t"r|j |t%|j|_t%|j|_t%|j|_t%|j|_t%|j |_dSr)rr"_EventListeners__command_listenersr!_EventListeners__server_listenersr+_EventListeners__server_heartbeat_listenersr#_EventListeners__topology_listenersr_EventListeners__cmap_listenersrr%rrsr^rfr9r%_EventListeners__enabled_for_commands#_EventListeners__enabled_for_server-_EventListeners__enabled_for_server_heartbeat%_EventListeners__enabled_for_topology!_EventListeners__enabled_for_cmap)r.rlsts r#rz_EventListeners.__init__s#-#?#B ","=aaa"@3,/F)$.$A!!!$D! * 9!!! <   6 6c?339,33C888c>228+223777c#:;;B5<;??1 $ $J $!!%(((( $ $ $!##### $ $ $rct||}|jD]6} ||#t$rt Y3wxYwdS)zPublish a ServerClosedEvent to all server listeners. :param server_address: The address (host, port) pair of the server. :param topology_id: A unique identifier for the topology this server is a part of. N)rxrrorrrs r#publish_server_closedz%_EventListeners.publish_server_closedsx".+>>1 $ $J $!!%(((( $ $ $!##### $ $ $rrwrrxct||||}|jD]6} ||#t$rt Y3wxYwdS)a~Publish a ServerDescriptionChangedEvent to all server listeners. :param previous_description: The previous server description. :param server_address: The address (host, port) pair of the server. :param new_description: The new server description. :param topology_id: A unique identifier for the topology this server is a part of. N)rvrrlrr)r.rwrxrcrdr&rs r#"publish_server_description_changedz2_EventListeners.publish_server_description_changeds. />;  1 $ $J $..u5555 $ $ $!##### $ $ $rct|}|jD]6} ||#t$rt Y3wxYwdS)zPublish a TopologyOpenedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rgrrirrr.rdr&rs r#publish_topology_openedz'_EventListeners.publish_topology_openedv $K003 $ $J $!!%(((( $ $ $!##### $ $ $0A  A ct|}|jD]6} ||#t$rt Y3wxYwdS)zPublish a TopologyClosedEvent to all topology listeners. :param topology_id: A unique identifier for the topology this server is a part of. N)rmrrorrrs r#publish_topology_closedz'_EventListeners.publish_topology_closedrrrct|||}|jD]6} ||#t$rt Y3wxYwdS)a:Publish a TopologyDescriptionChangedEvent to all topology listeners. :param previous_description: The previous topology description. :param new_description: The new topology description. :param topology_id: A unique identifier for the topology this server is a part of. N)rjrrlrr)r.rwrxrdr&rs r#$publish_topology_description_changedz4_EventListeners.publish_topology_description_changeds|00DoWbcc3 $ $J $..u5555 $ $ $!##### $ $ $2A  A rr r ct||}|jD]6} ||#t$rt Y3wxYwdS)z:Publish a :class:`PoolCreatedEvent` to all pool listeners.N)r:rr<rr)r.rr r&rs r#publish_pool_createdz$_EventListeners.publish_pool_createdsv '22/ $ $J $''.... $ $ $!##### $ $ $rct|}|jD]6} ||#t$rt Y3wxYwdS)z8Publish a :class:`PoolReadyEvent` to all pool listeners.N)r>rr@rrr.rr&rs r#publish_pool_readyz"_EventListeners.publish_pool_readystw''/ $ $J $%%e,,,, $ $ $!##### $ $ $rrct|||}|jD]6} ||#t$rt Y3wxYwdS)z:Publish a :class:`PoolClearedEvent` to all pool listeners.N)rArrCrr)r.rrrr&rs r#publish_pool_clearedz$_EventListeners.publish_pool_cleareds{!*6KLL/ $ $J $''.... $ $ $!##### $ $ $rct|}|jD]6} ||#t$rt Y3wxYwdS)z9Publish a :class:`PoolClosedEvent` to all pool listeners.N)rDrrFrrrs r#publish_pool_closedz#_EventListeners.publish_pool_closedst((/ $ $J $&&u---- $ $ $!##### $ $ $rct||}|jD]6} ||#t$rt Y3wxYwdS)zWPublish a :class:`ConnectionCreatedEvent` to all connection listeners. N)rGrrIrrr.rrr&rs r#publish_connection_createdz*_EventListeners.publish_connection_created&sx'w >>/ $ $J $--e4444 $ $ $!##### $ $ $rct|||}|jD]6} ||#t$rt Y3wxYwdS)zDPublish a :class:`ConnectionReadyEvent` to all connection listeners.N)rJrrLrrr.rrrr&rs r#publish_connection_readyz(_EventListeners.publish_connection_ready1sz%WmXFF/ $ $J $++E2222 $ $ $!##### $ $ $rrPct|||}|jD]6} ||#t$rt Y3wxYwdS)zVPublish a :class:`ConnectionClosedEvent` to all connection listeners. N)rNrrPrr)r.rrrPr&rs r#publish_connection_closedz)_EventListeners.publish_connection_closed<sz&g}fEE/ $ $J $,,U3333 $ $ $!##### $ $ $rct|}|jD]6} ||#t$rt Y3wxYwdS)z_Publish a :class:`ConnectionCheckOutStartedEvent` to all connection listeners. N)rQrrSrrrs r#$publish_connection_check_out_startedz4_EventListeners.publish_connection_check_out_startedGsv/w77/ $ $J $77>>>> $ $ $!##### $ $ $rct|||}|jD]6} ||#t$rt Y3wxYwdS)z^Publish a :class:`ConnectionCheckOutFailedEvent` to all connection listeners. N)rTrrVrr)r.rrPrr&rs r##publish_connection_check_out_failedz3_EventListeners.publish_connection_check_out_failedRsz .gvxHH/ $ $J $66u==== $ $ $!##### $ $ $rct|||}|jD]6} ||#t$rt Y3wxYwdS)zZPublish a :class:`ConnectionCheckedOutEvent` to all connection listeners. N)rWrrYrrrs r#publish_connection_checked_outz._EventListeners.publish_connection_checked_out_sz *'=(KK/ $ $J $11%8888 $ $ $!##### $ $ $rct||}|jD]6} ||#t$rt Y3wxYwdS)zYPublish a :class:`ConnectionCheckedInEvent` to all connection listeners. N)rZrr\rrr s r#publish_connection_checked_inz-_EventListeners.publish_connection_checked_inlsx)-@@/ $ $J $007777 $ $ $!##### $ $ $r)rrr!)r(rr)rrrrrr{rrrrrrrrr(r))NNFr)rrrrrrrr{rrrrrrrrrrrrr(r))NNr)rrrrrrrr{rrrrrrrrrrr(r)r) rrrrrrrrr(r)) rrrrrrrrr(r)rq) rwrrxrrcrrdr r(r)r)rwrrxrrdr r(r)rrrr rA)rrrr{rrr(r))rrrr{rPrr(r))rrrPrrrr(r))#rrrr rrrrrrrrrrrrrrrrrrrrrrr r rrrrrrrr!r"r#rrs>>>>2+++X+)))X)333X3+++X+'''X'    " $)-$$$$$$$$$$\ $)-"'/$/$/$/$/$r $)-*$*$*$*$*$X $ $ $ $$$$$&$$$$& $ $ $ $ $ $ $ $$$$$0 $ $ $ $ $ $ $ $$$$$($$$$$$$$', $ $ $ $ $$$$$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $r"r)rzrr(r{)rrrrr(r)rrr(r))rrrrr(r)Kr __future__rdatetime collectionsrrtypingrrrr r bson.objectidr pymongo.hellor r pymongo.helpers_sharedrrpymongo.typingsrrrpymongo.server_descriptionrpymongo.topology_descriptionrrrrr%r9r^rfrsr~rrrrr'r1r4rr:r>rArDr$r.r4r;rCrGrJrNrQrTrWrZr`rvrtrxrrjrgrmrr_rarcrr!r"r#r&sll\#"""""''''''''BBBBBBBBBBBBBB"""""",,,,,,,,IIIIIIII22222222A""""""<<<<<<@@@@@@Z   ZBB + + 77777777"""""n""":u"u"u"u"u"^u"u"u"p"""""n""">"""""~"""<"""""^"""<++++ $3333:I%I%I%I%I%I%I%I%X@ @ @ @ @ -@ @ @ FB B B B B MB B B J@ @ @ @ @ @ @ @ F@@@@@@@@&RRRRRzRRR0     Z   *w*w*w*w*wz*w*w*wZ     j   FFFFFFFF*&@@@@@@@@&XXXXX)XXX$kkkkk1kkk*     /        3         .    F     %5   ddddd$<ddd:      8        1   dddddddd.& & & & & L& & & R NNNNNNNN"& & & & & m& & & R--[[[[[[[[8"70 0 0 0 0 $90 0 0 f- - - - - !6- - - `U$U$U$U$U$U$U$U$U$U$r"