File: //var/opt/nydus/ops/mysql/opentelemetry/sdk/resources/__pycache__/__init__.cpython-39.pyc
a
�,�h�7 � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddl m
Z
ddl m Z ddl
mZ ddlmZmZmZ ddlmZ dd lmZmZ dd
lmZ eZeje ef Z e� e �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.ej/Z/ej0Z0ej1Z1ej2Z2ej3Z4ej5Z6ej7Z8ej9Z:ej;Z<ej=Z>ej?Z@ejAZBejCZDejEZFejGZHejIZJejKZLejMZNejOZPejQZRejSZTejUZUejVZVejWZWejXZXejYZYejZZZej[Z[ej\Z\ej]Z]ej^Z^ej_Z_ej`Z`ejaZaejbZbejcZcejdZdejeZeejfZfejgZgejhZhed �ZiG d d
� d
�Zjeji �Zkejehdeedefeii�ZlG dd� dejm�ZnG dd� den�ZoG dd� den�Zpdejqd ejrej d
d�dd�ZsdS )a�
This package implements `OpenTelemetry Resources
<https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/resource/sdk.md#resource-sdk>`_:
*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"
<https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/resource/semantic_conventions/README.md>`_
that have prescribed semantic meanings, for example ``service.name`` in the
above example.
� N)�dumps)�environ)�parse)�BoundedAttributes)�$OTEL_EXPERIMENTAL_RESOURCE_DETECTORS�OTEL_RESOURCE_ATTRIBUTES�OTEL_SERVICE_NAME)�ResourceAttributes)� entry_points�version)�AttributeValuezopentelemetry-sdkc @ s� e Zd ZdZdeeje d�dd�Ze deje eje d d�dd��Z
e d d �d
d ��Z e ed �d d
��Z
e ed �dd��Zd d d�dd�Zeed�dd�Zdd� Zd ed �dd�ZdS ) �ResourcezZA Resource is an immutable representation of the entity producing telemetry as Attributes.N��
attributes�
schema_urlc C s" t |d�| _|d u rd}|| _d S )N)r � )r � _attributes� _schema_url)�selfr r � r �]/opt/nydus/tmp/pip-target-wkfpz8uv/lib64/python/mysql/opentelemetry/sdk/resources/__init__.py�__init__� s zResource.__init__)r r �returnc C s� | si } g }t }t�td��d�}d|vr4|�d� |D ](}|�tttd|� � d����
� � � q8t |t �� t
| |��}|j�td�s�d}|j�td�}|r�|d| 7 }|� t
t|i|��}|S )z�Creates 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.
Zotel�,Z opentelemetry_resource_detector)�group�nameNZunknown_service�:)�_DEFAULT_RESOURCEr �getr �split�append�next�iterr
�strip�load�get_aggregated_resources�merger
r � SERVICE_NAME�PROCESS_EXECUTABLE_NAME)r r Zresource_detectors�resourceZ$otel_experimental_resource_detectorsZresource_detectorZdefault_service_nameZprocess_executable_namer r r �create� sL ��
���� ��� �zResource.create�r c C s t S �N)�_EMPTY_RESOURCEr r r r � get_empty� s zResource.get_emptyc C s | j S r, )r �r r r r r � s zResource.attributesc C s | j S r, )r r/ r r r r � s zResource.schema_url)�otherr c C sn | j �� }|�|j � | jdkr(|j}n<|jdkr:| j}n*| j|jkrN|j}nt�d| j|j� | S t||�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.
r zEFailed to merge resources: The two schemas %s and %s are incompatible)r �copy�updater �logger�errorr
)r r0 Zmerged_attributesr r r r r& � s
�zResource.mergec C s& t |t�sdS | j|jko$| j|jkS )NF)�
isinstancer
r r )r r0 r r r �__eq__ s
�zResource.__eq__c C s" t t| j�� dd�� d| j� ��S )NT)� sort_keys�|)�hashr r r1 r r/ r r r �__hash__ s �zResource.__hash__� c C s t t| j�| jd�|d�S )Nr )�indent)r �dictr r )r r< r r r �to_json s ��zResource.to_json)N)NN)r; )�__name__�
__module__� __qualname__�__doc__�
Attributes�typing�Optional�strr � staticmethodr* r. �propertyr r r& �object�boolr6 r: r> r r r r r
� s( ��8$r
�pythonZ
opentelemetryc @ s* e Zd Zd dd�Zejdd�dd��ZdS )
�ResourceDetectorFc C s
|| _ d S r, )�raise_on_error)r rM r r r r # s zResourceDetector.__init__r
r+ c C s
t � �d S r, )�NotImplementedErrorr/ r r r �detect& s zResourceDetector.detectN)F)r? r@ rA r �abc�abstractmethodrO r r r r rL " s
rL c @ s e Zd Zdd�dd�ZdS )�OTELResourceDetectorr
r+ c C s� t �t�}i }|r�|�d�D ]t}z|jddd�\}}W n> tyt } z&t�d||� W Y d }~q W Y d }~n
d }~0 0 t�|� � �}|||� � < q t �t
�}|r�||t < t |�S )Nr �=� )�maxsplitz0Invalid key value resource attribute pair %s: %s)
r r r r �
ValueErrorr3 �warningr �unquoter# r r' r
) r Zenv_resources_itemsZenv_resource_map�item�key�value�excZvalue_url_decodedZ service_namer r r rO - s&
�"
zOTELResourceDetector.detectN�r? r@ rA rO r r r r rR + s rR c @ s e Zd Zdd�dd�ZdS )�ProcessResourceDetectorr
r+ c C sN d� tttjjdkr*tjjs*tjd d� ntj��}tttj t
tj j t
|i�S )N�.�final� )�join�maprF �sys� version_info� releaselevel�serialr
�PROCESS_RUNTIME_DESCRIPTIONr �PROCESS_RUNTIME_NAME�implementationr �PROCESS_RUNTIME_VERSION)r Z_runtime_versionr r r rO G s
����
��z ProcessResourceDetector.detectNr] r r r r r^ E s r^ � )� detectors�initial_resourcer c
s� |p
t �� }tjjdd���� � fdd�| D �}t|�D ]~\}}| | }z`z|j|d�}W n@ ty� } z(t}|j rv| �t
� d| |� W Y d} ~ n
d} ~ 0 0 W |� |�}q6|� |�}0 q6W d � n1 s�0 Y |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:
r; )� max_workersc s g | ]}� � |j��qS r )�submitrO )�.0�detector��executorr r �
<listcomp>j � z,get_aggregated_resources.<locals>.<listcomp>)�timeoutz%Exception %s in detector %s, ignoringN)
r
r* �
concurrent�futures�ThreadPoolExecutor� enumerate�result� Exceptionr- rM r3 rW r& )
rm rn rw Zdetectors_merged_resourcery Z detector_ind�futurerr Zdetected_resource�exr rs r r% [ s$ &�
�&r% )Nrl )trB rP �concurrent.futuresrx �loggingrd rD �jsonr �osr �urllibr Z mysql.opentelemetry.attributesr Z-mysql.opentelemetry.sdk.environment_variablesr r r Z$mysql.opentelemetry.semconv.resourcer Z,mysql.opentelemetry.util._importlib_metadatar
r Z mysql.opentelemetry.util.typesr Z
LabelValue�DictrF rC � getLoggerr? r3 ZCLOUD_PROVIDERZCLOUD_ACCOUNT_IDZ CLOUD_REGIONZCLOUD_AVAILABILITY_ZONEZCONTAINER_NAMEZ CONTAINER_IDZCONTAINER_IMAGE_NAMEZCONTAINER_IMAGE_TAGZDEPLOYMENT_ENVIRONMENTZ FAAS_NAMEZFAAS_IDZ FAAS_VERSIONZ
FAAS_INSTANCEZ HOST_NAMEZ HOST_TYPEZHOST_IMAGE_NAMEZ
HOST_IMAGE_IDZHOST_IMAGE_VERSIONZK8S_CLUSTER_NAMEZKUBERNETES_CLUSTER_NAMEZK8S_NAMESPACE_NAMEZKUBERNETES_NAMESPACE_NAMEZ K8S_POD_UIDZKUBERNETES_POD_UIDZ K8S_POD_NAMEZKUBERNETES_POD_NAMEZK8S_CONTAINER_NAMEZKUBERNETES_CONTAINER_NAMEZK8S_REPLICASET_UIDZKUBERNETES_REPLICA_SET_UIDZK8S_REPLICASET_NAMEZKUBERNETES_REPLICA_SET_NAMEZK8S_DEPLOYMENT_UIDZKUBERNETES_DEPLOYMENT_UIDZK8S_DEPLOYMENT_NAMEZKUBERNETES_DEPLOYMENT_NAMEZK8S_STATEFULSET_UIDZKUBERNETES_STATEFUL_SET_UIDZK8S_STATEFULSET_NAMEZ KUBERNETES_STATEFUL_SET_NAMEZK8S_DAEMONSET_UIDZKUBERNETES_DAEMON_SET_UIDZK8S_DAEMONSET_NAMEZKUBERNETES_DAEMON_SET_NAMEZ K8S_JOB_UIDZKUBERNETES_JOB_UIDZ K8S_JOB_NAMEZKUBERNETES_JOB_NAMEZK8S_CRONJOB_UIDZKUBERNETES_CRON_JOB_UIDZK8S_CRONJOB_NAMEZKUBERNETES_CRON_JOB_NAMEZOS_TYPEZOS_DESCRIPTIONZ PROCESS_PIDr( ZPROCESS_EXECUTABLE_PATHZPROCESS_COMMANDZPROCESS_COMMAND_LINEZPROCESS_COMMAND_ARGSZ
PROCESS_OWNERri rk rh r' ZSERVICE_NAMESPACEZSERVICE_INSTANCE_IDZSERVICE_VERSIONZTELEMETRY_SDK_NAMEZTELEMETRY_SDK_VERSIONZTELEMETRY_AUTO_VERSIONZTELEMETRY_SDK_LANGUAGEZ_OPENTELEMETRY_SDK_VERSIONr
r- r �ABCrL rR r^ �ListrE r% r r r r �<module> s� +
�� ��