9h)SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSK J r SSK J r \R"\5r"SS 5rg) N) KafkaMetric)AnonMeasurable) MetricConfig) MetricName)Sensorc\rSrSrSrSSjr\S5r\S5rSSjr Sr S\ RS4S jr S rSS jrS rS rSr"SS5rSrSrg)Metricsar A registry of sensors and metrics. A metric is a named, numerical measurement. A sensor is a handle to record numerical measurements as they occur. Each Sensor has zero or more associated metrics. For example a Sensor might represent message sizes and we might associate with this sensor a metric for the average, maximum, or other statistics computed off the sequence of message sizes that are recorded by the sensor. Usage looks something like this: # set up metrics: metrics = Metrics() # the global repository of metrics and sensors sensor = metrics.sensor('message-sizes') metric_name = MetricName('message-size-avg', 'producer-metrics') sensor.add(metric_name, Avg()) metric_name = MetricName('message-size-max', 'producer-metrics') sensor.add(metric_name, Max()) # as messages are sent we record the sizes sensor.record(message_size); Nc^[R"5TlU=(d [5Tl0Tl0Tl0TlU=(d /TlTRHnUR/5 M U(a1U4Sjn[R"US9nSUl UR5 TRTRSSS5[U4Sj55 g) a Create a metrics repository with a default config, given metric reporters and the ability to expire eligible sensors Arguments: default_config (MetricConfig, optional): The default config reporters (list of AbstractMetricsReporter, optional): The metrics reporters enable_expiration (bool, optional): true if the metrics instance can garbage collect inactive sensors, false otherwise cl>[R"S5 TRRT5 M3)N)timesleepExpireSensorTaskrunselfs]C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/metrics/metrics.py expire_loop%Metrics.__init__..expire_loop>s*JJrN))--d3)targetTcountzkafka-metrics-countz"total number of registered metricsc.>[TR5$N)len_metrics)confignowrs r"Metrics.__init__..Mss4==/ArN) threadingRLock_lockr_config_sensorsr_children_sensors _reportersinitThreaddaemonstart add_metric metric_namer)rdefault_config reportersenable_expirationreporterrmetrics_schedulers` r__init__Metrics.__init__'s__& %7   !##/rH MM" (  4 !* 0 0 D '+  $  # # %    .0T  A B  rcUR$r)r&rs rrMetrics.configPs ||rcUR$)zD Get all the metrics currently maintained and indexed by metricName )rrs rmetricsMetrics.metricsTs }}rc[URR5nURU=(d 05 [ XX55$)a Create a MetricName with the given name, group, description and tags, plus default tags specified in the metric configuration. Tag in tags takes precedence if the same tag key is specified in the default metric configuration. Arguments: name (str): The name of the metric group (str): logical group name of the metrics to which this metric belongs description (str, optional): A human-readable description to include in the metric tags (dict, optionals): additional key/value attributes of the metric )dictrtagsupdater)rnamegroup descriptionr> combined_tagss rr/Metrics.metric_name[s7 T[[--. TZR(${BBrc^U(d [S5eURRUS5$)z Get the sensor with the given name if it exists Arguments: name (str): The name of the sensor Returns: Sensor: The sensor or None if no such sensor exists zname must be non-emptyN) ValueErrorr'get)rr@s r get_sensorMetrics.get_sensoros*56 6}}  t,,rcURU5nU(aU$UR URU5nU(d[UUUU=(d URU5nXPRU'U(aLUHFnUR R U5nU(d/nXpR U'URU5 MH [RSU5 UsSSS5 $!,(df  g=f)ab Get or create a sensor with the given unique name and zero or more parent sensors. All parent sensors will receive every value recorded with this sensor. Arguments: name (str): The name of the sensor config (MetricConfig, optional): A default configuration to use for this sensor for metrics that don't have their own config inactive_sensor_expiration_time_seconds (int, optional): If no value if recorded on the Sensor for this duration of time, it is eligible for removal parents (list of Sensor): The parent sensors Returns: Sensor: The sensor that is created zAdded sensor with name %sN) rHr%rrr'r(rGappendloggerdebug)rr@r'inactive_sensor_expiration_time_secondsparentssensorparentchildrens rrPMetrics.sensor}s0& M ZZ__T*F)dkk; '- d#")#'#9#9#=#=f#E'')H=E226: / #*  8$?'ZZs B3C$$ C2cNURRU5nU(aSnUR UR URRUS5nU(aeXB:Xa`URHnUR UR 5 M [RSU5 URRUS5nSSS5 SSS5 U(a%UHnURUR5 M ggg!,(df  ND=f!,(df  NM=f)z Remove a sensor (if it exists), associated metrics and its children. Arguments: name (str): The name of the sensor to be removed NzRemoved sensor with name %s) r'rGr%popr: remove_metricr/rLrMr( remove_sensorr@)rr@rP child_sensorsvalmetric child_sensors rrWMetrics.remove_sensors""4(  Mtzzmm''d33="(..**6+=+=>#1LL!>E$($:$:$>$>vt$LM *$1L&&|'8'89%2 )zs# DB DD D D D$cd[XU=(d UR5nURU5 g)a Add a metric to monitor an object that implements measurable. This metric won't be associated with any sensor. This is a way to expose existing values as metrics. Arguments: metricName (MetricName): The name of the metric measurable (AbstractMeasurable): The measurable that will be measured by this metric config (MetricConfig, optional): The configuration to use when measuring this measurable N)rrregister_metric)rr/ measurablerrZs rr.Metrics.add_metrics'[f6K L V$rcUR URRUS5nU(a$URHnUR U5 M UsSSS5 $!,(df  g=f)a/ Remove a metric if it exists and return it. Return None otherwise. If a metric is removed, `metric_removal` will be invoked for each reporter. Arguments: metric_name (MetricName): The name of the metric Returns: KafkaMetric: the removed `KafkaMetric` or None if no such metric exists N)r%rrUr)metric_removal)rr/rZr3s rrVMetrics.remove_metricsMZZ]]&&{D9F $H++F3!0 ZZs A A  A.cUR UR[URR 555 UR R U5 SSS5 g!,(df  g=f)zAdd a MetricReporterN)r%r*listr:valuesr)rKrr3s r add_reporterMetrics.add_reportersC ZZ MM$t||2245 6 OO " "8 ,ZZs AA$$ A2c.UR URUR;a[SURS35eXRUR'URHnUR U5 M SSS5 g!,(df  g=f)NzA metric named "z." already exists, cannot register another one.)r%r/r:rFr) metric_change)rrZr3s rr^Metrics.register_metricsz ZZ!!T\\1 &v'9'9&:;--06LL++ , OO&&v.,ZZs A0B Bc(\rSrSrSr\S5rSrg)Metrics.ExpireSensorTaskzm This iterates over every Sensor and triggers a remove_sensor if it has expired. Package private for testing c&[URR55nUHVup#UR UR 5(a'[ R SU5 URU5 SSS5 MX g!,(df  Mj=f)NzRemoving expired sensor %s)rer'itemsr% has_expiredrLrMrW)r:rqr@rPs rrMetrics.ExpireSensorTask.runsk))//12E % \\))++ %A4H--d3"\!&"\s =B B N)__name__ __module__ __qualname____firstlineno____doc__ staticmethodr__static_attributes__rtrrrrns  4  4rrc~URHnUR5 M URR5 g)zClose this metrics repository.N)r)closerclearrgs rr} Metrics.closes,H NN ( r)r(r&r%rr)r')NNF)Nr)rurvrwrxryr5propertyrr:r/rHsysmaxsizerPrWr.rVrhr^rr}r{rtrrr r s}.' R C( -"03  /b:*%"(- /440rr )loggingrr#r kafka_metricrr_r metric_configrr/rstatsr getLoggerrurLr rtrrrs<  %&'#   8 $GGr