xtj^ UdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZmZmZdd lmZdd l m!Z!dd l"m#Z#dZ$edze%d< ddl$Z&e&Z$n #e'$rYnwxYwe#Z(e e)e(fZ*ej+e,Z-e!j.Z.e!j/Z/e!j0Z0e!j1Z1e!j2Z2e!j3Z3e!j4Z4e!j5Z5e!j6Z6e!j7Z7e!j8Z8e!j9Z9e!j:Z:e!j;Z;e!j<ZZ>e!j?Z?e!j@Z@e!jAZBe!jCZDe!jEZFe!jGZHe!jIZJe!jKZLe!jMZNe!jOZPe!jQZRe!jSZTe!jUZVe!jWZXe!jYZZe!j[Z\e!j]Z^e!j_Z`e!jaZbe!jcZce!jdZde!jeZee!jfZfe!jgZge!jhZhe!jiZie!jjZje!jkZke!jlZle!jmZme!jnZne!joZoe!jpZpe!jqZqe!jrZre!jsZse!jtZte!juZue!jvZve!jwZwe!jxZxGddZyeyiZzeyexdeudeveiZ{da|e)dze%d<da}e~dze%d<e jZGddejZGddeZGddeZGddeZGddeZGdd eZd!edfd"Zd!eyfd#Z d)d%e dd&eydzd'e~d!dfd(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)MappingSequence)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 b/var/www/html/CA-Chatbot/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/)rr4s rrzResource.schema_urlr5rothercJt|j}||j|jdkr|j}nS|jdkr|j}n@|j|jkr|j}n(td|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)dictrupdaterloggererrorr)rr7merged_attributesrs rr%zResource.merges"!11  !1222 ?b )JJ   # #JJ _ 0 0 0)JJ LLW     K):666rcpt|tsdS|j|jko|j|jkS)NF) isinstancerrr)rr7s r__eq__zResource.__eq__s?%** 5   1 1 6 E$55 rctt|jdd|jS)NT) sort_keys|)hashrrcopyrr4s r__hash__zResource.__hash__sDT%**,,=== R R@P R R   rindentcXtt|j|jd|S)N)rr)rH)rr9rr)rrHs rto_jsonzResource.to_jsons;"4?33".       rr/)NNrr)r7rrr)rG)__name__ __module__ __qualname____doc__r __annotations__r( Attributesr staticmethodr-r2propertyrrr%objectboolr@intrFrJr1rrrrsdd""""&&:&3:&&&& (,!%""%"$J" """\"H\ J   X  C   X !7!7!7!7F F t     #      cDj       rrpython opentelemetry_service_instance_id_service_instance_id_pidcNeZdZd deddfdZejd dZdefdZdS) ResourceDetectorFraise_on_errorrNc||_dSr/r])rr]s rrzResourceDetector.__init__ s,rrct)zdDon't call `Resource.create` here to avoid an infinite loop, instead instantiate `Resource` directly)NotImplementedErrorr4s rdetectzResourceDetector.detect#s"###rcdS)aReturn whether this detector depends on the current process identity. Process dependent detectors may return resource attributes that become stale after a process identity change, such as :func:`os.fork`. Detectors returning ``True`` should be re-run after such changes so the resulting :class:`Resource` describes the current process. Returns: ``True`` if this detector should be re-run after process identity changes otherwise ``False``. Fr1r4s ris_process_dependentz%ResourceDetector.is_process_dependent)s urFrK) rLrMrNrUrabcabstractmethodrbrdr1rrr\r\sz--t----- $$$$ d      rr\ceZdZddZdS)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;warningr unquotestripr r'r) renv_resources_itemsenv_resource_mapitemkeyvalueexcvalue_url_decoded service_names rrbzOTELResourceDetector.detect:s%k*BCC68  B+11#66 B B!%C!! #%7??3K#L#L 03}D3=++" ' #"4"9 #%5  #%= #%= -4   % @ //M25((=2I2IM. /2?M. / 2y ! ! =02 M, -  nn&&G''))H+3M- ( &&&rrerK) rLrMrNrOrUrrdrb __classcell__)rs@rr}r}Rs %:&+ ::::# :  ::::::d,',',',',',',','rr}ceZdZdZddZdS)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 rrbzOsResourceDetector.detects|/##))++%''  i  !)++JJ   G!)++JJ    rNrKrLrMrNrOrbr1rrrrs:CCN N N N N N rrceZdZdZddZdS)_HostResourceDetectorzT The HostResourceDetector detects the hostname and architecture attributes. rrctttjtt jiSr/)r HOST_NAMEsocket gethostname HOST_ARCHrmachiner4s rrbz_HostResourceDetector.detects56-//8+--    rNrKrr1rrrrs2      rrc&eZdZdZdefdZddZdS)!ServiceInstanceIdResourceDetectorahDetects service.instance.id as a random UUID v4. Per the OpenTelemetry specification, SDKs SHOULD generate a random v1/v4 UUID for service.instance.id to uniquely identify each service instance. The ID is shared across all detector instances within the same process and regenerated automatically when the process PID changes (e.g. after a fork). Note: because this detector is process dependent, providers refresh it automatically after a fork and merge the newly detected value on top of the existing resource. This means that if a user explicitly sets `service.instance.id` (e.g. via OTEL_RESOURCE_ATTRIBUTES or Resource.create(attributes=...)), that value will be overwritten with a newly generated UUID the next time the process forks. This differs from Resource.create(), which does preserve user supplied overrides. rcdSrr1r4s rrdz6ServiceInstanceIdResourceDetector.is_process_dependent rrrct5tj}t t|kr"t t ja|at}dddn #1swxYwYtt|iSr/) _service_instance_id_lockrrrYrZr(uuiduuid4rSERVICE_INSTANCE_ID)r current_pid instance_ids rrbz(ServiceInstanceIdResourceDetector.detects' / /)++K$,+{::'*4:<<'8'8$+6(.K / / / / / / / / / / / / / / /,k:;;;sAA##A'*A'NrK)rLrMrNrOrUrdrbr1rrrrsM d < < < < < z-_build_resource_detectors..+s@   ::<<      rrrkservice_instanceotelr) entry_points*c3&K|] }|dk|V dS)rNr1rs r z,_build_resource_detectors..@s8  v~~ ~~~   ropentelemetry_resource_detector)groupNrm)rrz/Failed to load resource detector '%s', skipping)rr9fromkeysrr&r rorri&opentelemetry.util._importlib_metadatarsetnamessortedindexappendnextiterload Exceptionr; exception)detector_namesr registered expansionidx detectorsrs rr#r#s,!%   #K8"%**    "6* +  ! !N,f5551335I5K5KLL n  $ 7      :N(;(;;<< ""3'' 4C4 9 ,~cAgii/H H )+I    $ "C!%$&&          A       sAE##%F  F c|tdtDtS)Nc:g|]}||Sr1)rd)rdetectors rrz3_get_process_dependent_resource..ds:   ,,..    r)r"r#rr2r1rr_get_process_dependent_resourcerbsG #  577      rrinitial_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: rG) max_workerscDg|]}|jSr1)submitrb)rrexecutors rrz,get_aggregated_resources..|s'NNN8??8?33NNNr)rz1Detector %s took longer than %s seconds, skippingNz%Exception %s in detector %s, ignoring)rr- concurrentfuturesThreadPoolExecutor enumerater0result TimeoutErrorr]r;rqrr%) rrrdetectors_merged_resourcer detector_indfuturerdetected_resourceexrs @rr"r"ms !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)rOrfconcurrent.futuresrloggingrrrr threadingrcollections.abcrrjsonrrtypesrtypingrurllibr opentelemetry.attributesr 'opentelemetry.sdk.environment_variablesr r r opentelemetry.sdk.versionr_OPENTELEMETRY_SDK_VERSIONopentelemetry.semconv.resourceropentelemetry.util.typesrrrP psutil_module ImportError LabelValuer(rQ getLoggerrLr;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_NAMESPACErSERVICE_VERSIONTELEMETRY_SDK_NAMETELEMETRY_SDK_VERSIONTELEMETRY_AUTO_VERSIONTELEMETRY_SDK_LANGUAGErr0r$rYrZrVLockrABCr\rir}rrrrr#rr"r1rrrVs%***^    --------666666 >=====333333  T  """" FF   D  S*_ %  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$(cDj''''+#*+++*IN,,sw2*****+***4C'C'C'C'C'.C'C'C'LQ Q Q Q Q )Q Q Q h      ,     < < < < <(8 < <