
    Ui                         d dl  d dlmZmZmZmZ  edddd      Z edd	dd      Z ed
ddd      Z edddd      Z	 edddddg      Z
 edddddgd      Z G d de      Z eddd      d        Zy)    )*)CmfMetricCounterCmfMetricGaugeCmfMetricSummaryCmfMetricRealtimeCollectorpool_open_connectionsu@   Количество запущенных подключенийredisT)namehelpmodule_nameadd_worker_tagpool_in_use_connectionsuD   Количество используемых подключенийpool_max_connectionsu!   Лимит подключенийopen_connectionsuU   Количество подключений (установок соединения)command_executedu8   Количество выполненных командtype)r
   r   r   r   custom_tagscommand_execute_waituV   Количество времени ожидания выполнения командmicroseconds)r
   r   r   r   r   unitc                   ,    e Zd ZdZdZdZdZed        Zy)CmfRedisStatCollectorun   
    Сохраняем данные о количестве и свойствах подключения
       c                     t         j                  rt         j                  j                  sy t        j	                  t         j                  j                  j
                  j                         t        j	                  t         j                  j                  j
                  j                         t        j	                  t        t         j                  j                  j
                  j                               y )N)APPREDIS_DBr	   r   writeconnection_poolmax_connectionsr   _created_connectionsr   len_in_use_connections     ./cmf/metrics/redis_metrics.pyrunzCmfRedisStatCollector.run=   s    ||3<<#5#5""3<<#5#5#E#E#U#UV##CLL$6$6$F$F$[$[\%%c#,,*<*<*L*L*`*`&abr$   N)	__name__
__module____qualname____doc__interval_minstart_delay_hard_minutesstart_delay_soft_minutesstaticmethodr&   r#   r$   r%   r   r   5   s.     L  c cr$   r   z@hourly)	only_once
system_jobschedulec                  &    t         j                  syy)uV   
    Аналитические метрики, запрошенные из Redis
    N)configMETRICS_REDIS_DBr#   r$   r%   redis_metricsr5   F   s    
 "" #r$   N)cmf.includecmf.util.metricsr   r   r   r   r   r   r   r   r   r   r   cmf_deferred_jobr5   r#   r$   r%   <module>r9      s     k k '	 	K	  )	"	O	  &		,	  $		`	  $		C  (		a	 c6 c" DTIF Gr$   