gUK UdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddlm Z ddl mZddl mZmZmZmZddlmZddlmZdd lmZmZmZdd lmZdd lmZmZdd l m!Z!dZ"eee#d < ddl"Z$e$Z"e!Z&e jNe(e&fZ)ejTe+Z,ejZZ-ej\Z.ej^Z/ej`Z0ejbZ1ejdZ2ejfZ3ejhZ4ejjZ5ejlZ6ejnZ7ejpZ8ejrZ9ejtZ:ejvZ;ejxZej~Z?ejZAejZCejZEejZGejZIejZKejZMejZOejZQejZSejZUejZWejZYejZ[ejZ]ejZ_ejZaejZbejZcejZdejZeejZfejZgejZhejZiejZjejZkejZlejZmejZnejZoejZpejZqejZrejZsejZtejZuejZvejZwedZxe(e#d<GddZyeyiZzeyewdetdeuexiZ{GddejZ}Gdde}Z~Gdde}ZGdde}ZGdde}Z d#de jdde j"eyd ed!dfd"Zy#e%$rY}wxYw)$a This package implements `OpenTelemetry Resources `_: *A Resource is an immutable representation of the entity producing telemetry. For example, a process producing telemetry that is running in a container on Kubernetes has a Pod name, it is in a namespace and possibly is part of a Deployment which also has a name. All three of these attributes can be included in the Resource.* Resource objects are created with `Resource.create`, which accepts attributes (key-values). Resources should NOT be created via constructor, and working with `Resource` objects should only be done via the Resource API methods. Resource attributes can also be passed at process invocation in the :envvar:`OTEL_RESOURCE_ATTRIBUTES` environment variable. You should register your resource with the `opentelemetry.sdk.trace.TracerProvider` by passing them into their constructors. The `Resource` passed to a provider is available to the exporter, which can send on this information as it sees fit. .. code-block:: python trace.set_tracer_provider( TracerProvider( resource=Resource.create({ "service.name": "shoppingcart", "service.instance.id": "instance-12", }), ), ) print(trace.get_tracer_provider().resource.attributes) {'telemetry.sdk.language': 'python', 'telemetry.sdk.name': 'opentelemetry', 'telemetry.sdk.version': '0.13.dev0', 'service.name': 'shoppingcart', 'service.instance.id': 'instance-12'} Note that the OpenTelemetry project documents certain `"standard attributes" `_ that have prescribed semantic meanings, for example ``service.name`` in the above example. N)dumps)environ) ModuleType)ListMutableMappingOptionalcast)parse)BoundedAttributes)$OTEL_EXPERIMENTAL_RESOURCE_DETECTORSOTEL_RESOURCE_ATTRIBUTESOTEL_SERVICE_NAME)ResourceAttributes) entry_pointsversion)AttributeValuepsutilzopentelemetry-sdk_OPENTELEMETRY_SDK_VERSIONc eZdZUdZeed<eed< ddedejefdZ e ddejedejeddfd Z e dd Z edefd Zedefd ZddZd edefdZdefdZddedefdZy)ResourcezZA Resource is an immutable representation of the entity producing telemetry as Attributes. _attributes _schema_urlN attributes schema_urlc<t||_|d}||_y)N)r)r rr)selfrrs Y/var/www/openai/venv/lib/python3.12/site-packages/opentelemetry/sdk/resources/__init__.py__init__zResource.__init__s$- C  J%returnc |si}dhjtjtdj dDchc]}|r|j c}}g}|D]Q}|j tttd|j jSt|tjt||}|jjt dsbd}t#t$t&|jjt(d}|r|d|zz }|jtt |i|}|Scc}w) zCreates a new `Resource` from attributes. Args: attributes: Optional zero or more key-value pairs. schema_url: Optional URL pointing to the schema Returns: The newly-created Resource. otelr,opentelemetry_resource_detector)groupnameNunknown_service:)unionrgetr splitstripappendnextiterrloadget_aggregated_resources_DEFAULT_RESOURCEmergerr SERVICE_NAMEr rstrPROCESS_EXECUTABLE_NAME) rr#otel_experimental_resource_detector$otel_experimental_resource_detectorsresource_detectorsresource_detectorresourcedefault_service_nameprocess_executable_names rcreatezResource.createsvJ06x~~a@P@P?Q R  r indentc`t|j}t||jd|S)N)rr)rX)dictrrr)rrXrs rto_jsonzResource.to_json"s::>   ; ("..    r rA)NNr!r)rIrr!r))__name__ __module__ __qualname____doc__r __annotations__r6 Attributestypingrr staticmethodr?rDpropertyrrr4objectboolrRintrWr[rCr rrrsd""JN&$&28//#2F&26+/8OOJ/8OOC(8 88t J   C  !7F F t  #  c  #  r rpython opentelemetrycDeZdZddeddfdZej ddZy)ResourceDetectorraise_on_errorr!Nc||_yrA)rn)rrns rrzResourceDetector.__init__:s ,r ctrA)NotImplementedErrorrFs rdetectzResourceDetector.detect=s !##r )Fr\)r^r_r`rhrabcabstractmethodrrrCr rrmrm9s/-t-- $$r rmceZdZddZy)OTELResourceDetectorctjt}i}|rc|jdD]O} |jdd\}}tj|j}|||j<Qtjt}|r ||t<t|S#t$r!}t j d||Yd}~d}~wwxYw)Nr$=)maxsplitz0Invalid key value resource attribute pair %s: %s) rr+r r, ValueErrorrMwarningr unquoter-rr5r) renv_resources_itemsenv_resource_mapitemkeyvalueexcvalue_url_decoded service_names rrrzOTELResourceDetector.detectDs%kk*BC +11#6!%C!!<tA|S)N.finalr getppid)!joinmapr6sys version_info releaselevelserialosgetpid executablepathdirnameargvPROCESS_RUNTIME_DESCRIPTIONrPROCESS_RUNTIME_NAMEimplementationr'PROCESS_RUNTIME_VERSION PROCESS_PIDr7PROCESS_EXECUTABLE_PATHPROCESS_COMMANDPROCESS_COMMAND_LINEPROCESS_COMMAND_ARGShasattrrPROCESS_PARENT_PIDrProcessusername PROCESS_OWNERr) r_runtime_version _process_pid_process_executable_name_process_executable_path_process_command_process_command_line_process_command_args resource_infoprocessrs rrrzProcessResourceDetector.detect^sP88 ''44?,,33$$Ra())    yy{ #&>> #%77??3K#L 88A; # 2 # ' #"4"4"9"9 #%5  #%= #%= - "7 "7   2y !02 M, -  -3^^-=G'')H+3M- ( &&r Nr\rrCr rrr\s&'r rceZdZdZddZy)OsResourceDetectorzxDetect os resources based on `Operating System conventions `_.ctjj}tj}|dk(rtj}n|dk(rd}tj}t t |t|iS)aReturns a resource with with ``os.type`` and ``os.version``. Python's platform library ~~~~~~~~~~~~~~~~~~~~~~~~~ To grab this information, Python's ``platform`` does not return what a user might expect it to. Below is a breakdown of its return values in different operating systems. .. code-block:: python :caption: Linux >>> platform.system() 'Linux' >>> platform.release() '6.5.0-35-generic' >>> platform.version() '#35~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Tue May 7 09:00:52 UTC 2' .. code-block:: python :caption: MacOS >>> platform.system() 'Darwin' >>> platform.release() '23.0.0' >>> platform.version() 'Darwin Kernel Version 23.0.0: Fri Sep 15 14:42:57 PDT 2023; root:xnu-10002.1.13~1/RELEASE_ARM64_T8112' .. code-block:: python :caption: Windows >>> platform.system() 'Windows' >>> platform.release() '2022Server' >>> platform.version() '10.0.20348' .. code-block:: python :caption: FreeBSD >>> platform.system() 'FreeBSD' >>> platform.release() '14.1-RELEASE' >>> platform.version() 'FreeBSD 14.1-RELEASE releng/14.1-n267679-10e31f0946d8 GENERIC' .. code-block:: python :caption: Solaris >>> platform.system() 'SunOS' >>> platform.release() '5.11' >>> platform.version() '11.4.0.15.0' windowssunossolaris)platformsystemlowerreleaserrOS_TYPE OS_VERSION)ros_type os_versions rrrzOsResourceDetector.detectsw|//#))+%%'  i !))+J  G!))+JJ   r Nr\r^r_r`rarrrCr rrrsCN r rceZdZdZddZy)_HostResourceDetectorzT The HostResourceDetector detects the hostname and architecture attributes. cxtttjtt j iSrA)r HOST_NAMEsocket gethostname HOST_ARCHrmachinerFs rrrz_HostResourceDetector.detects06--/8++-   r Nr\rrCr rrrs  r r detectorsinitial_resourcetimeoutr!c|xstj}tjj d5}|Dcgc]}|j |j }}t|D]4\}}||}t} |j|} |j| }6 ddd|Scc}w#tjj$r/} |jr| tjd||Yd} ~ jd} ~ wt$r/} |jr| tjd| |Yd} ~ d} ~ wwxYw#|j| }wxYw#1swY|SxYw)a'Retrieves resources from detectors in the order that they were passed :param detectors: List of resources in order of priority :param initial_resource: Static resource. This has highest priority :param timeout: Number of seconds to wait for each detector to return :return: r]) max_workers)rz1Detector %s took longer than %s seconds, skippingNz%Exception %s in detector %s, ignoring)rr? concurrentfuturesThreadPoolExecutorsubmitrr enumeraterBresult TimeoutErrorrnrMr| Exceptionr4) rrrdetectors_merged_resourceexecutordetectorr detector_indfuturedetected_resourceexs rr2r2sQ!1 EHOO4E    . .1 . =DMNI8??8??3IN$-g$6 L& .H*9  $*MM'M$B!"-F,K,K%-)+%7 >6 %$5O %%22 **HG  **H;R -F,K,K%-)/ >6 %$sdE"B/ E?B4E/E4D6%C;6D9; D6%D1,D91D66D99E  EE)N)rarsconcurrent.futuresrloggingrrrrrdjsonrrtypesrrrrr urllibr opentelemetry.attributesr 'opentelemetry.sdk.environment_variablesr r ropentelemetry.semconv.resourcer&opentelemetry.util._importlib_metadatarropentelemetry.util.typesrrrb psutil_module ImportError LabelValueMappingr6rc getLoggerr^rMCLOUD_PROVIDERCLOUD_ACCOUNT_ID CLOUD_REGIONCLOUD_AVAILABILITY_ZONECONTAINER_NAME CONTAINER_IDCONTAINER_IMAGE_NAMECONTAINER_IMAGE_TAGDEPLOYMENT_ENVIRONMENT FAAS_NAMEFAAS_ID FAAS_VERSION FAAS_INSTANCErr HOST_TYPEHOST_IMAGE_NAME HOST_IMAGE_IDHOST_IMAGE_VERSIONK8S_CLUSTER_NAMEKUBERNETES_CLUSTER_NAMEK8S_NAMESPACE_NAMEKUBERNETES_NAMESPACE_NAME K8S_POD_UIDKUBERNETES_POD_UID K8S_POD_NAMEKUBERNETES_POD_NAMEK8S_CONTAINER_NAMEKUBERNETES_CONTAINER_NAMEK8S_REPLICASET_UIDKUBERNETES_REPLICA_SET_UIDK8S_REPLICASET_NAMEKUBERNETES_REPLICA_SET_NAMEK8S_DEPLOYMENT_UIDKUBERNETES_DEPLOYMENT_UIDK8S_DEPLOYMENT_NAMEKUBERNETES_DEPLOYMENT_NAMEK8S_STATEFULSET_UIDKUBERNETES_STATEFUL_SET_UIDK8S_STATEFULSET_NAMEKUBERNETES_STATEFUL_SET_NAMEK8S_DAEMONSET_UIDKUBERNETES_DAEMON_SET_UIDK8S_DAEMONSET_NAMEKUBERNETES_DAEMON_SET_NAME K8S_JOB_UIDKUBERNETES_JOB_UID K8S_JOB_NAMEKUBERNETES_JOB_NAMEK8S_CRONJOB_UIDKUBERNETES_CRON_JOB_UIDK8S_CRONJOB_NAMEKUBERNETES_CRON_JOB_NAMEOS_DESCRIPTIONrrrrr7rrrrrrrrr5SERVICE_NAMESPACESERVICE_INSTANCE_IDSERVICE_VERSIONTELEMETRY_SDK_NAMETELEMETRY_SDK_VERSIONTELEMETRY_AUTO_VERSIONTELEMETRY_SDK_LANGUAGErrrBr3ABCrmrvrrrrir2rCr rr)s#)V   776 >H3## " F ^^CO ,   8 $#22%66!.. ,DD#22!.. )>>(<<+BB  ( (  $ $!.. "00  ( (  ( (  ( ( $44"00 '::,==.AA'33(55.AA/BB0DD.AA/CC0DD1FF.@@/BB'33(55,<<->>#22  $ $  * *  ,, '::,DD,DD$44)>>)>>"00 )>>,DD0LL!.. &88(<<$44'::*@@+BB+BB")*=">C>O O d2,O9$sww$*+*4('.('VQ )Q h  ,  37)%{{-.)%ooh/)%)% )%c   s7O22O;:O;