1- from pymongo import MongoClient
1+ from pymongo import MongoClient , AsyncMongoClient
22from pymongo .monitoring import CommandListener , CommandSucceededEvent , ServerListener , \
33 ConnectionPoolListener , ServerHeartbeatStartedEvent , \
44 ConnectionCreatedEvent
55
6- # start-monitoring
6+ # start-monitoring-listeners
77class MyCommandListener (CommandListener ):
88 def succeeded (self , event : CommandSucceededEvent ):
99 print (f"Command { event .command_name } succeeded" )
@@ -21,7 +21,14 @@ def connection_created(self, event: ConnectionCreatedEvent):
2121 print (f"Connection { event .connection_id } created" )
2222
2323 # Include other event method implementations here
24+ # end-monitoring-listeners
2425
26+ # start-monitoring-client
2527listeners = [MyCommandListener (), MyServerListener (), MyPoolListener ()]
2628client = MongoClient ("<connection URI>" , event_listeners = listeners )
27- # end-monitoring
29+ # end-monitoring-client
30+
31+ # start-monitoring-client-async
32+ listeners = [MyCommandListener (), MyServerListener (), MyPoolListener ()]
33+ client = AsyncMongoClient ("<connection URI>" , event_listeners = listeners )
34+ # end-monitoring-client-async
0 commit comments