grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a j=@sdZddlmZmZmZmZmZddlmZm Z ddl m Z m Z m Z mZddl mZmZmZmZddlmZddlmZddlmZeed Zd ej_d ej_eej_e e e gej_eej_e e gej_eej_e e gej_eej_e e e e e e gej_eej _e ee gej _e ej!_ee gej!_e ej"_e gej"_e ej#_d ej#_e ej$_egej$_e ej%_egej%_e ej&_e gej&_e ej'_eee ee egej'_e ej(_eee gej(_e ej)_eeegej)_e ej*_eegej*_e ej+_e egej+_e ej,_e e gej,_e ej-_e e gej-_e ej._eegej._e ej/_eegej/_e ej0_d ej0_e ej1_e e e egej1_e ej2_e e e eegej2_Gd d d e3Z4Gd dde5Z6d S)aBWrapper module for libpcp_import - Performace Co-Pilot Log Import API # # Copyright (C) 2012-2022 Red Hat. # # This file is part of the "pcp" module, the python interfaces for the # Performance Co-Pilot toolkit. # # This program is free software; you can redistribute it and/or modify it # under the terms of the GNU General Public License as published by the # Free Software Foundation; either version 2 of the License, or (at your # option) any later version. # # This program is distributed in the hope that it will be useful, but # WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY # or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License # for more details. # # Example use of this module for creating a PCP archive: import time import pmapi from pcp import pmi # Create a new archive log = pmi.pmiLogImport("loadtest") log.pmiSetHostname("www.abc.com") log.pmiSetTimezone("EST-10") # Add a metric with an instance domain domain = 60 # Linux kernel pmid = log.pmiID(domain, 2, 0) indom = log.pmiInDom(domain, 2) units = log.pmiUnits(0, 0, 0, 0, 0, 0) log.pmiAddMetric("kernel.all.load", pmid, pmapi.PM_TYPE_FLOAT, indom, pmapi.PM_SEM_INSTANT, units) log.pmiAddInstance(indom, "1 minute", 1) log.pmiAddInstance(indom, "5 minute", 5) log.pmiAddInstance(indom, "15 minute", 15) # Create a record with a timestamp log.pmiPutValue("kernel.all.load", "1 minute", "%f" % 0.01) log.pmiPutValue("kernel.all.load", "5 minute", "%f" % 0.05) log.pmiPutValue("kernel.all.load", "15 minute", "%f" % 0.15) log.pmiWrite(time.time()) # sec since epoch, or datetime, or #log.pmiWrite(seconds, useconds) del log )pmIDpmInDompmUnitspmHighResResultpmResult) pmiErrSymDictPMI_MAXERRMSGLEN)c_intc_uint c_longlongc_char_p)castcreate_string_bufferPOINTERCDLL) find_library)datetime)modfZ pcp_importNcs0eZdZdZfddZddZddZZS)pmiErrz4 Encapsulation for PMI interface error code csBtt|j|t||_|r8t|dtr8|d|_nd|_dS)Nr)superr__init__listargs isinstanceintcode)selfr __class__-/usr/lib64/python3.9/site-packages/pcp/pmi.pyrs   zpmiErr.__init__cCsNz&t|j}tt}t|j|t}Wnty@d}}Yn0d||fS)Nz%s %s)rrrr LIBPCP_IMPORT pmiErrStr_rKeyError)rZ error_symbolZ error_stringrrr __str__s   zpmiErr.__str__cCs|jS)N)rrrrr errnosz pmiErr.errno)__name__ __module__ __qualname____doc__rr%r' __classcell__rrrr rs  rc@s eZdZdZddZddZeedddZeedddZd6dd Z d d Z d d Z ddZ ddZ eddZeddZeddZeddZddZddZddZd d!Zd"d#Zd$d%Zd7d&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zed2d3Zd4d5Z dS)8 pmiLogImportzqDefines a PCP Log Import archive context This is used to create a PCP archive from an external source cCs|jS)z Property for archive path )_pathr&rrr read_pathszpmiLogImport.read_pathcCs|jS)z! Property for log import context )_ctxr&rrr read_ctxszpmiLogImport.read_ctxNrcCsPt|ts|d}||_td|_tt |||_ |j dkrLt |j dS)Nutf-8r) rbytesencoder.rZutcfromtimestamp_epochr"pmiStartr r0r)rpathZinheritrrr rs    zpmiLogImport.__init__cCs"trt|jtd|_dS)N)r" pmiUseContextr0pmiEndr&rrr __del__s zpmiLogImport.__del__cCsRt|j}|dkrt|t|ts0|d}tt|}|dkrNt||S)z8PMI - set the source host name for a Log Import archive rr2) r"r9r0rrr3r4pmiSetHostnamer )rhostnamestatusrrr r<s   zpmiLogImport.pmiSetHostnamecCsRt|j}|dkrt|t|ts0|d}tt|}|dkrNt||S)z?PMI - set the source timezone for a Log Import archive rr2) r"r9r0rrr3r4pmiSetTimezoner )rtimezoner>rrr r?s   zpmiLogImport.pmiSetTimezonecCsHt|j}|dkrt|t|ts*d}t|}|dkrDt||S)z6PMI - set the output archive version (2 or 3) r)r"r9r0rrr pmiSetVersion)rversionr>rrr rBs   zpmiLogImport.pmiSetVersioncCst|||Sz7PMI - construct a pmID data structure (helper routine) )r"pmiID)domainclusteritemrrr rEszpmiLogImport.pmiIDcCs t||SrD)r" pmiCluster)rFrGrrr rIszpmiLogImport.pmiClustercCs t||S)z:PMI - construct a pmInDom data structure (helper routine) )r"pmiInDom)rFserialrrr rJ szpmiLogImport.pmiInDomcCst||||||S)z;PMI - construct a pmiUnits data structure (helper routine) )r"pmiUnits)Z dim_spaceZdim_timeZ dim_countZ scale_spaceZ scale_timeZ scale_countrrr rLs zpmiLogImport.pmiUnitscCs\t|j}|dkrt|t|ts0|d}tt||||||}|dkrXt||S)z:PMI - add a new metric definition to a Log Import context rr2) r"r9r0rrr3r4 pmiAddMetricr )rnameZpmidtypedindomZsemZunitsr>rrr rMs     zpmiLogImport.pmiAddMetriccCsVt|j}|dkrt|t|ts0|d}t|t||}|dkrRt||S)z@PMI - add element to an instance domain in a Log Import context rr2) r"r9r0rrr3r4pmiAddInstancer )rrPinstanceZinstidr>rrr rQ$s   zpmiLogImport.pmiAddInstancecCst|j}|dkrt|t|ts0|d}d}|durXt|tsP|d}t|}t|tsl|d}tt||t|}|dkrt||S)z-PMI - add a value for a metric-instance pair rr2N) r"r9r0rrr3r4r pmiPutValue)rrNinstvaluer>rRrrr rS0s$        zpmiLogImport.pmiPutValuecCs|t|j}|dkrt|t|ts0|d}d}|durXt|tsP|d}t|}tt||}|dkrxt||S)z1PMI - define a handle for a metric-instance pair rr2N) r"r9r0rrr3r4r pmiGetHandle)rrNrTr>rRrrr rVDs     zpmiLogImport.pmiGetHandlecCsTt|j}|dkrt|t|ts0|d}t|t|}|dkrPt||S)z:PMI - add a value for a metric-instance pair via a handle rr2) r"r9r0rrr3r4pmiPutValueHandler )rZhandlerUr>rrr rWUs   zpmiLogImport.pmiPutValueHandlecCs<t|j}|dkrt|t||}|dkr8t||S))PMI - flush data to a Log Import archive r)r"r9r0rpmiHighResWrite)rsecZnsecr>rrr rYas  zpmiLogImport.pmiHighResWritecCst|j}|dkrt||rt|stt|tr@t||j}t|trpt |}t |d}t |dd}nd}t ||}|dkrt||S)rXri@B) r"r9r0rrrfloatr5Z total_secondsrr pmiWrite2)rrZZusecr>tsrrr pmiWriteks     zpmiLogImport.pmiWritecCs8t|j}|dkrt|t}|dkr4t||S)z4PMI - write a record to a Log Import archive r)r"r9r0r pmiPutMarkrr>rrr r`~s zpmiLogImport.pmiPutMarkcCsDt|j}|dkrt|tt|tt}|dkr@t||Sz0PMI - add a data record to a Log Import archive r)r"r9r0r pmiPutResultr rrrresultr>rrr put_results zpmiLogImport.put_resultcCsDt|j}|dkrt|tt|tt}|dkr@t||Srb)r"r9r0rpmiPutHighResResultr rrrdrrr put_highres_results zpmiLogImport.put_highres_resultcCsXt|j}|dkrt|t|ts0|d}t|||t|}|dkrTt||S)z0PMI - add a text record to a Log Import archive rr2) r"r9r0rrr3r4 pmiPutTextr )rtypclsidentcontentr>rrr ris   zpmiLogImport.pmiPutTextcCsrt|j}|dkrt|t|ts0|d}t|tsD|d}t|||t|t|}|dkrnt||S)z1PMI - add a label record to a Log Import archive rr2) r"r9r0rrr3r4 pmiPutLabelr )rrjrlrTrNrmr>rrr rns     zpmiLogImport.pmiPutLabelcCs tdS)z8PMI - dump the current Log Import contexts (diagnostic) N)r"pmiDumprrrr roszpmiLogImport.pmiDumpcCs>t|j}|dkrt|t}d|_|dkr:t||S)zsz3