qisdZddlmZmZmZddlmZddlmZddl m Z m Z m Z m Z mZmZmZmZddlmZmZGddeZy ) zMetrics logging observer for Pipecat. This module provides an observer that logs metrics frames to the console, allowing developers to monitor performance metrics, token usage, and other statistics in real-time. )OptionalSetType)logger) MetricsFrame) LLMTokenUsageLLMUsageMetricsData MetricsDataProcessingMetricsDataSmartTurnMetricsDataTTFBMetricsDataTTSUsageMetricsDataTurnMetricsData) BaseObserver FramePushedceZdZdZ ddeeeeffd Zde fdZ dede fdZ ded e fd Zded ed ed e fd Zded ed ed e fdZxZS)MetricsLogObservera{Observer to log metrics activity to the console. Monitors and logs all MetricsFrame instances, including: - TTFBMetricsData (Time To First Byte) - ProcessingMetricsData (General processing time) - LLMUsageMetricsData (Token usage statistics) - TTSUsageMetricsData (Text-to-Speech character counts) - TurnMetricsData (Turn prediction metrics) This allows developers to track performance metrics, token usage, and other statistics throughout the pipeline. Examples: Log all metrics types:: observers = [MetricsLogObserver()] Log only LLM and TTS metrics:: from pipecat.metrics.metrics import LLMUsageMetricsData, TTSUsageMetricsData observers = [ MetricsLogObserver( include_metrics={LLMUsageMetricsData, TTSUsageMetricsData} ) ] include_metricsc t|di||r6t|vr.ddl}|j dt d|thz t hz}||_t|_ y)a%Initialize the metrics log observer. Args: include_metrics: Set of metrics types to include. If specified, only these metrics types will be logged. If None, all metrics are logged. **kwargs: Additional arguments passed to parent class. rNzSSmartTurnMetricsData is deprecated in include_metrics, use TurnMetricsData instead.) stacklevel) super__init__r warningswarnDeprecationWarningr_include_metricsset _frames_seen)selfrkwargsr __class__s `/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/observers/loggers/metrics_log_observer.pyrzMetricsLogObserver.__init__=si "6" 3F  MM/"   /2F1GGOK\\O /EdatacNK|j}|j}t|tsy|j|j vry|j j |j|dz }|jD]&}|j|s|j||(yw)a'Handle frame push events and log metrics frames. Logs MetricsFrame instances with detailed information about the metrics data, formatted appropriately for each metrics type. Args: data: Frame push event data containing source, frame, and timestamp. Niʚ;) frame timestamp isinstanceridr addr&_should_log_metrics_log_metrics_data)r!r&r(r)time_sec metrics_datas r$ on_push_framez MetricsLogObserver.on_push_frameXs NN %.  88t(( (  ehh'},"JJ ;L++L9  " "< :  ;sB#B%r0returncJ|jt||jvSy)zDetermine if a metrics data item should be logged based on filters. Args: metrics_data: The metrics data to check. Returns: True if the metrics should be logged, False otherwise. T)rtype)r!r0s r$r-z&MetricsLogObserver._should_log_metricsws+  , %)>)>> >r%r/c d|jd}|jrd|jdnd}t|tr.t j d|d|d|j d |d d yt|tr.t j d|d |d|j d |d d yt|tr|j||||yt|tr.t j d|d |d|j d|d d yt|tr|j||||yt j d|d|d|d|d d y)zLog a single metrics data item. Args: metrics_data: The metrics data to log. time_sec: Timestamp in seconds. []z ()📊 z TTFB: zs at z.3fsz PROCESSING TIMEz TTS USAGEz characters at z METRICS at N) processormodelr*r rdebugvaluer r _log_llm_usagerr _log_turn)r!r0r/processor_info model_infos r$r.z$MetricsLogObserver._log_metrics_datasv\334A63?3E3Er,,,-Q/2 lO 4 LL'uZL<;M;M:NeT\]`Saabc  &; < LL''7 |2lFXFXEYY^_ghk^llmn  &9 :    nj( S  &9 : LL'z*R @R@R?SSbcklobppqr  o 6 NN<X N LL'x |2l^4PXY\~]^_ r%rDrEc |j}d|jd|jd|jg}|j|j d|j|j |j d|j |j|j d|jdj|}tjd |d |d |d |d d y)aLog LLM token usage metrics. Args: metrics_data: The LLM usage metrics data. processor_info: Formatted processor name string. model_info: Formatted model name string. time_sec: Timestamp in seconds. zprompt: z completion: ztotal: Nz cache_read: zcache_creation: z reasoning: z, r:z LLM TOKEN USAGEr;r=.2fr<) rA prompt_tokenscompletion_tokens total_tokenscache_read_input_tokensappendcache_creation_input_tokensreasoning_tokensjoinrr@)r!r0rDrEr/usagedetails usage_strs r$rBz!MetricsLogObserver._log_llm_usages ,11u**+ ,5223 4e(() *   ( ( 4 NN\%*G*G)HI J  , , 8 NN-e.O.O-PQ R  ! ! - NN[)?)?(@A BIIg&  N##3J  kU@% )% %  %  % N %      r%rN)r_typingrrrlogururpipecat.frames.framesrpipecat.metrics.metricsrr r r r r rrpipecat.observers.base_observerrrrrr%r$ris;'&.   FE E r%