ZjqQ UdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZddlmZddl mZddlmZdd lmZdd lmZmZmZdd lmZdd lmZdd lm Z dZ!edze"d< ddl!Z#e#Z!n #e$$rYnwxYwe Z%e j&e'e%fZ(ej)e*Z+ej,Z,ej-Z-ej.Z.ej/Z/ej0Z0ej1Z1ej2Z2ej3Z3ej4Z4ej5Z5ej6Z6ej7Z7ej8Z8ej9Z9ej:Z:ej;Z;ej<ZZ>ej?Z@ejAZBejCZDejEZFejGZHejIZJejKZLejMZNejOZPejQZRejSZTejUZVejWZXejYZZej[Z\ej]Z^ej_Z`ejaZaejbZbejcZcejdZdejeZeejfZfejgZgejhZhejiZiejjZjejkZkejlZlejmZmejnZnejoZoejpZpejqZqejrZrejsZsejtZtejuZuejvZvGddZwewiZxewevdesdeteiZyGddejzZ{Gdde{Z|Gdde{Z}Gdde{Z~Gdde{ZdedfdZ d$d e dd!ewdzd"eddfd#ZdS)%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 except by `ResourceDetector` instances which can't use `Resource.create` to avoid infinite loops. 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)Sequence)dumps)environ) ModuleType)cast)parse)BoundedAttributes)$OTEL_EXPERIMENTAL_RESOURCE_DETECTORSOTEL_RESOURCE_ATTRIBUTESOTEL_SERVICE_NAME) __version__)ResourceAttributes)AttributeValuepsutilceZdZUdZeed<eed<ddededzfdZe ddedzdedzddfd Z e dd Z e defd Z e defd ZddZd edefdZdefdZddedzdefdZdS)ResourcezZA Resource is an immutable representation of the entity producing telemetry as Attributes. _attributes _schema_urlN attributes schema_urlcFt||_|d}||_dS)N)r)r rr)selfrrs a/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/sdk/resources/__init__.py__init__zResource.__init__s., CCC  J%returnc|si}tttt ||}|jtdsld}ttdz|jtd}|r|d|zz }|t t|i|}|S)a9Creates a new `Resource` from attributes. `ResourceDetector` instances should not call this method. Args: attributes: Optional zero or more key-value pairs. schema_url: Optional URL pointing to the schema Returns: The newly-created Resource. Nunknown_service:) get_aggregated_resources_build_resource_detectors_DEFAULT_RESOURCEmergerrget SERVICE_NAMErstrPROCESS_EXECUTABLE_NAME)rrresourcedefault_service_nameprocess_executable_names rcreatezResource.creates" J+ % ' '):  %Z00 1 1 "&&|T:: #4 &*d #''(?FF'' #' F$.E(EE$~~,(<=zJJHrctSN)_EMPTY_RESOURCErr get_emptyzResource.get_emptysrc|jSr.)rrs rrzResource.attributes rc|jSr.)rr3s rrzResource.schema_urlr4rothercnt|j}||j|jdkr|j}nS|jdkr|j}n@|j|jkr|j}n(t d|j|j|St||S)a^Merges this resource and an updating resource into a new `Resource`. If a key exists on both the old and updating resource, the value of the updating resource will override the old resource value. The updating resource's `schema_url` will be used only if the old `schema_url` is empty. Attempting to merge two resources with different, non-empty values for `schema_url` will result in an error and return the old resource. Args: other: The other resource to be merged. Returns: The newly-created Resource. rzEFailed to merge resources: The two schemas %s and %s are incompatible)dictrcopyupdaterloggererrorr)rr6merged_attributesrs rr$zResource.merges"!116688  !1222 ?b )JJ   # #JJ _ 0 0 0)JJ LLW     K):666rcpt|tsdS|j|jko|j|jkS)NF) isinstancerrr)rr6s r__eq__zResource.__eq__s?%** 5   1 1 6 E$55 rctt|jdd|jS)NT) sort_keys|)hashrrr9rr3s r__hash__zResource.__hash__sDT%**,,=== R R@P R R   rindentcXtt|j|jd|S)N)rr)rG)rr8rr)rrGs rto_jsonzResource.to_jsons;"4?33".       rr.)NNrr)r6rrr)rF)__name__ __module__ __qualname____doc__r __annotations__r' Attributesr staticmethodr,r1propertyrrr$objectboolr@intrErIr0rrrrsdd""""&&:&3:&&&& (,!%""%"$J" """\"H\ J   X  C   X !7!7!7!7F F t     #      cDj       rrpython opentelemetrycBeZdZddeddfdZejd dZdS) ResourceDetectorFraise_on_errorrNc||_dSr.)rZ)rrZs rrzResourceDetector.__init__s,rrct)zdDon't call `Resource.create` here to avoid an infinite loop, instead instantiate `Resource` directly)NotImplementedErrorr3s rdetectzResourceDetector.detects"###r)FrJ)rKrLrMrTrabcabstractmethodr^r0rrrYrYs_--t----- $$$$$$rrYceZdZddZdS)OTELResourceDetectorrrctjt}i}|r|dD]} |dd\}}n3#t$r&}t d||Yd}~Id}~wwxYwtj| }||| <tjt}|r ||t<t|S)N,=)maxsplitz0Invalid key value resource attribute pair %s: %s) rr%r split ValueErrorr;warningrunquotestripr r&r) renv_resources_itemsenv_resource_mapitemkeyvalueexcvalue_url_decoded service_names rr^zOTELResourceDetector.detect%s%k*BCC68  B+11#66 B B!%C!! #%7??3K#L#L S]++ /<D=++" # 7 7 - ' #"4"9 #%5  #%= #%= - "7 "7   2y ! ! =02 M, -  nn&&G''))H+3M- ( &&&rNrJrur0rrrwrw=s(-'-'-'-'-'-'rrwceZdZdZddZdS)OsResourceDetectorzxDetect os resources based on `Operating System conventions `_.rrctj}tj}|dkrtj}n|dkrd}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 rr^zOsResourceDetector.detectrs|/##))++%''  i  !)++JJ   G!)++JJ    rNrJrKrLrMrNr^r0rrrros:CCN N N N N N rrceZdZdZddZdS)_HostResourceDetectorzT The HostResourceDetector detects the hostname and architecture attributes. rrctttjtt jiSr.)r HOST_NAMEsocket gethostname HOST_ARCHrmachiner3s rr^z_HostResourceDetector.detects56-//8+--    rNrJrr0rrrrs2      rrrc ttdtjt ddDdgz}|dgkrtgSddlm }d|vrwtd|d j D}t|t|z }| d}|d ||z||d zd z}g}|D]} |tt!|d | X#t$$rt&d|YwxYw|S)aReturns the ordered list of resource detectors to use for Resource.create. Fast path: if no extra detectors are configured, returns only OTELResourceDetector without scanning entry_points. "otel" (OTELResourceDetector) defaults to last position so that OTEL_RESOURCE_ATTRIBUTES and OTEL_SERVICE_NAME take highest merge priority, but an explicit position in OTEL_EXPERIMENTAL_RESOURCE_DETECTORS is respected. c^g|]*}||+Sr0)rl.0rs r z-_build_resource_detectors..s@   ::<<      rrrdotelr) entry_points*c3&K|] }|dk|V dS)rNr0rs r z,_build_resource_detectors..s8  v~~ ~~~   ropentelemetry_resource_detector)groupNrf)rrz/Failed to load resource detector '%s', skipping)rr8fromkeysrr%r rhrb&opentelemetry.util._importlib_metadatarsetnamessortedindexappendnextiterload Exceptionr; exception)detector_namesr registered expansionidx detectorsrs rr"r"s!%   #K8"%**    h   ! !N&!!$&&'' n  $ 7      :N(;(;;<< ""3'' 4C4 9 ,~cAgii/H H )+I    $ "C!%$&&          A       s?AE%E<;E<rinitial_resourcetimeoutc |pt}tjd5 fd|D}t |D]\}}||}t } ||}n}#tjj$r/} |j r| t d||Yd} ~ n?d} ~ wt$r/} |j r| t d| |Yd} ~ nd} ~ wwxYw| |}#| |}wxYw dddn #1swxYwY|S)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: rF) max_workerscDg|]}|jSr0)submitr^)rdetectorexecutors rrz,get_aggregated_resources..#s'NNN8??8?33NNNr)rz1Detector %s took longer than %s seconds, skippingNz%Exception %s in detector %s, ignoring)rr, concurrentfuturesThreadPoolExecutor enumerater/result TimeoutErrorrZr;rjrr$) rrrdetectors_merged_resourcer detector_indfuturerdetected_resourceexrs @rr!r!s !1 EHOO4E4E   . .1 . = =NNNNINNN$-g$6$6   L& .H*9  $*MM'M$B$B!!%2   *HG    *H;R -F,K,K%--)),E,K,K%--)+ 6 %$s_2E0BDD%CD D%C<7D<DDED11EEE)Nr)rNr_concurrent.futuresrloggingrrrrtypingcollections.abcrjsonrrtypesrrurllibropentelemetry.attributesr 'opentelemetry.sdk.environment_variablesr r r opentelemetry.sdk.versionr _OPENTELEMETRY_SDK_VERSIONopentelemetry.semconv.resourceropentelemetry.util.typesrrrO psutil_module ImportError LabelValueMappingr'rP getLoggerrKr;CLOUD_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_DESCRIPTIONrrrrr(rrrrrrrrr&SERVICE_NAMESPACESERVICE_INSTANCE_IDSERVICE_VERSIONTELEMETRY_SDK_NAMETELEMETRY_SDK_VERSIONTELEMETRY_AUTO_VERSIONTELEMETRY_SDK_LANGUAGErr/r#ABCrYrbrwrrrr"rUr!r0rrr;s***^   $$$$$$666666 >=====333333  T  """" FF   D  ^CO ,  8 $ $#2%6!. ,D#2!. )>(<+B  (  $!. "0  (  (  ( $4"0 ':,=.A'3(5.A/B0D.A/C0D1F.@/B'3(5,<->#2  $  *  , ':,D,D$4)>)>"0 )>,D0L!. &8(<$4':*@+B+Bt t t t t t t t n(2,,HO9$$$$$sw$$$*****+***4/'/'/'/'/'./'/'/'dQ Q Q Q Q )Q Q Q h      ,    @4(:#;@@@@J)-)%)%*+)%o)%)% )%)%)%)%)%)%s5A<<BB