o i7@sdZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZmZmZddlmZdd lmZmZdd lmZeZejeefZeeZ ej!Z!ej"Z"ej#Z#ej$Z$ej%Z%ej&Z&ej'Z'ej(Z(ej)Z)ej*Z*ej+Z+ej,Z,ej-Z-ej.Z.ej/Z/ej0Z0ej1Z1ej2Z2ej3Z4ej5Z6ej7Z8ej9Z:ej;Zej?Z@ejAZBejCZDejEZFejGZHejIZJejKZLejMZNejOZPejQZRejSZTejUZUejVZVejWZWejXZXejYZYejZZZej[Z[ej\Z\ej]Z]ej^Z^ej_Z_ej`Z`ejaZaejbZbejcZcejdZdejeZeejfZfejgZgejhZhed ZiGd d d ZjejiZkejehdeedefeiiZlGdddejmZnGdddenZoGdddenZp  ddejqddejrejdd fddZsdS)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 `mysql.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)parse)BoundedAttributes)$OTEL_EXPERIMENTAL_RESOURCE_DETECTORSOTEL_RESOURCE_ATTRIBUTESOTEL_SERVICE_NAME)ResourceAttributes) entry_pointsversion)AttributeValuezopentelemetry-sdkc@seZdZdZddedejefddZe  ddejedejeddfdd Z e dd d Z e defd d Z e defddZdddZdedefddZddZddefddZdS)ResourcezZA Resource is an immutable representation of the entity producing telemetry as Attributes.N attributes schema_urlcCs"t|d|_|dur d}||_dS)N)r)r _attributes _schema_url)selfrrre/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/mysql/opentelemetry/sdk/resources/__init__.py__init__s  zResource.__init__returnc Cs|si}g}t}ttdd}d|vr|d|D]}|tttd| d qt |t t ||}|jtds^d}|jtd}|rT|d|7}| t t|i|}|S)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. otel,opentelemetry_resource_detector)groupnameNunknown_service:)_DEFAULT_RESOURCErgetrsplitappendnextiterr striploadget_aggregated_resourcesmerger r SERVICE_NAMEPROCESS_EXECUTABLE_NAME)rrresource_detectorsresource$otel_experimental_resource_detectorsresource_detectordefault_service_nameprocess_executable_namerrrcreatesP     zResource.createcCstSN)_EMPTY_RESOURCErrrr get_emptyszResource.get_emptycC|jSr2)rrrrrrzResource.attributescCr5r2)rr6rrrrr7zResource.schema_urlothercCsn|j}||j|jdkr|j}n|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)rcopyupdaterloggererrorr )rr8merged_attributesrrrrr(s      zResource.mergecCs&t|tsdS|j|jko|j|jkS)NF) isinstancer rr)rr8rrr__eq__s   zResource.__eq__cCs"tt|jddd|jS)NT) sort_keys|)hashrrr9rr6rrr__hash__ szResource.__hash__cCstt|j|jd|dS)N)rr)indent)rdictrr)rrErrrto_jsons zResource.to_jsonr2)NNrr )r8r rr )rD)__name__ __module__ __qualname____doc__ AttributestypingOptionalstrr staticmethodr1r4propertyrrr(objectboolr?rCrGrrrrr s. 8  $r python opentelemetryc@s&eZdZd ddZejd ddZdS) ResourceDetectorFcCs ||_dSr2)raise_on_error)rrXrrrr#s zResourceDetector.__init__rr cCstr2)NotImplementedErrorr6rrrdetect&r7zResourceDetector.detectN)FrH)rIrJrKrabcabstractmethodrZrrrrrW"s rWc@eZdZdddZdS)OTELResourceDetectorrr c Cstt}i}|rC|dD]4}z |jddd\}}Wnty4}z td||WYd}~qd}~wwt| }||| <qtt }|rN||t <t |S)Nr=)maxsplitz0Invalid key value resource attribute pair %s: %s) rr rr! ValueErrorr;warningrunquoter%rr)r ) renv_resources_itemsenv_resource_mapitemkeyvalueexcvalue_url_decoded service_namerrrrZ-s*   zOTELResourceDetector.detectNrHrIrJrKrZrrrrr^+r^c@r])ProcessResourceDetectorrr cCsNdtttjjdkrtjjstjddntj}tttj t tj j t |iS)N.final)joinmaprPsys version_info releaselevelserialr PROCESS_RUNTIME_DESCRIPTIONr PROCESS_RUNTIME_NAMEimplementationrPROCESS_RUNTIME_VERSION)r_runtime_versionrrrrZGs   zProcessResourceDetector.detectNrHrmrrrrroErnro detectorsinitial_resourcerc s|pt}tjjddUfdd|D}t|D]>\}}||}z0z|j|d}Wn tyL} zt}|j r;| t d| |WYd} ~ nd} ~ wwW| |}q| |}wWd|S1sewY|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: rD) max_workerscsg|]}|jqSr)submitrZ).0detectorexecutorrr jsz,get_aggregated_resources..)timeoutz%Exception %s in detector %s, ignoringN) r r1 concurrentfuturesThreadPoolExecutor enumerateresult Exceptionr3rXr;rcr() rrrdetectors_merged_resourcer detector_indfuturerdetected_resourceexrrrr'[s2   r')Nr~)trLr[concurrent.futuresrloggingrurNjsonrosrurllibrmysql.opentelemetry.attributesr-mysql.opentelemetry.sdk.environment_variablesrrr$mysql.opentelemetry.semconv.resourcer ,mysql.opentelemetry.util._importlib_metadatar r mysql.opentelemetry.util.typesr LabelValueDictrPrM getLoggerrIr;CLOUD_PROVIDERCLOUD_ACCOUNT_ID CLOUD_REGIONCLOUD_AVAILABILITY_ZONECONTAINER_NAME CONTAINER_IDCONTAINER_IMAGE_NAMECONTAINER_IMAGE_TAGDEPLOYMENT_ENVIRONMENT FAAS_NAMEFAAS_ID FAAS_VERSION FAAS_INSTANCE HOST_NAME 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_TYPEOS_DESCRIPTION PROCESS_PIDr*PROCESS_EXECUTABLE_PATHPROCESS_COMMANDPROCESS_COMMAND_LINEPROCESS_COMMAND_ARGS PROCESS_OWNERrzr|ryr)SERVICE_NAMESPACESERVICE_INSTANCE_IDSERVICE_VERSIONTELEMETRY_SDK_NAMETELEMETRY_SDK_VERSIONTELEMETRY_AUTO_VERSIONTELEMETRY_SDK_LANGUAGE_OPENTELEMETRY_SDK_VERSIONr r3rABCrWr^roListrOr'rrrrs+