ruạṛ
a ���f> � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl m Z d dl m Z d dlmZ dZdadZdadZd d � Zd d � Zd dd�Zdd� Zdd� Zdd� Zdd� Zd!dd�Z dd� Z d d � Z d d � Z dS )"� )�absolute_importN�� REGION_REALMS�REALMS)� HTTPAdapter)�default_user_agent)�Retryz User-Agent)�oc5�oc6�oc7�oc8c C s | d }|� d| � |S )z%Get the region from instance metadata�canonicalRegionNamez Region: %s)�debug)�instance_metadata�logger� region_name� r �E/sparta/input/python_modules/oci_agent_utils/oci_agent_utils/utils.py� get_region s r c C sH t | |�}|�d�}|d ur@||v r@|| }|�d�||�� nd }|S )N�https_certificateszregion {0}; cert {1}.)r �get�info�format)r r � agent_configr r � certificater r r �get_certificate_bundle s r Tc C s |r t r t S t| ||�a t S d S )N)�telemetry_endpoint�build_telemetry_endpoint)r r �telemetry_config� use_cacher r r �get_telemetry_endpoint+ s r c C s� t | |�}|�d�}|durL||v rL|�d| � || }|�d�t�� nPt| �}|d �� tv rvd�|d �|d< t|�}t j � |jf i |��|d �}|�d �|�� |S ) a� Build endpoint based on the region where the instance is in. Region is fetched from instance metadata. It gets the endpoint url template from the telemetry config file. For R1: 'https://telemetry-ingestion.r1.oracleiaas.com/20180401/metrics' Others: old config endpoint_format: 'https://telemetry-ingestion.{region}.oraclecloud.com' new config endpoint format: 'https://telemetry-ingestion.{region}.{domain}' :param instance_metadata: :param logger: :return: �region_endpointsNzRegion match found: %szRegion endpoints found: {}�realmzoci.{}�domain� endpoint_pathz%Region endpoint built from format: {}) r r r r r �get_region_info�lower� onsr_realms� get_telemetry_endpoint_format�urllib�parse�urljoin)r r r �regionr! �build_telemetry� region_info�endpoint_formatr r r r 4 s$ ��r c C s$ d}| r d| � d�v r | � d�}|S )Nz-https://telemetry-ingestion.{region}.{domain}z{domain}r/ )r )�telemetry_config_dictr/ r r r r( V s r( c C s@ | t v r t | }|tv r t| S | dkr,dS | dkr8dS td S )N�r1�oracleiaas.comz us-tacoma-1zoracleonsrcloud.com�oc1r )r, r" r r r � get_domain_ s r4 c C s� d| � d�krdddd�S | d }d|i}| � di �}|� d �}|� d �}d |d < d |d< |rr|rr||d < ||d< t� |d�}t� |�}|r�|r�||d < ||d< |S )a� Gets regional domain suffix to build service urls Get region_info from instance metadata service and merge with constants defined in oci sdk prefering sdk values Parameters ---------- instance_metadata : dict Dict containing instance metadata from metadata service. Returns ------- region_info : dict Dict with realm, region and domain keys Examples -------- For R1, {'realm': 'region1', 'region': 'r1', 'domain': 'oracleiaas.com'} For OC1, {'realm', 'oc1', 'region': 'us-ashburn-1', 'domain', 'oraclecloud.com'} For OC2, {'realm', 'oc2', 'region': 'us-langley-1', 'domain': 'oraclegovcloud.com'} For OC3, {'realm': 'oc3', 'region': 'us-gov-ashburn-1', 'domain': 'oraclegovcloud.com'} For OC4, {'realm': 'oc4', 'region': 'uk-gov-london-1', 'domain': 'oraclegovcloud.uk'} For OC5, {'realm': 'oc5', 'region': 'us-tacoma-1', 'domain': 'oracleonsrcloud.com'} �sear, �region1r1 r2 )r" r, r# r � regionInfo�realmDomainComponent�realmKeyr3 r" zoraclecloud.comr# � )r r r )r r, r. �metadata_region_info�realm_domain_component� realm_key� sdk_realm� sdk_domainr r r r% l s$ r% c C sj t � }d}| rJt| t�r8d�dd� | �� D ��}|�� }t| t�rJ| �� }t|�dkrbd||f }t|iS )Nr: c S s$ g | ] \}}d ||� dd�f �qS )z%s/%s � �-)�replace)�.0�key�valuer r r � <listcomp>� s �z"get_user_agent.<locals>.<listcomp>r z%s %s) r � isinstance�dict�join�items�strip�str�len�user_agent_header_name)�extra_user_agents� user_agents�more_user_agentsr r r �get_user_agent� s � �rR c C s$ t rt S tddddtdg�d�a t S )N� g�������?���)�total�connect�read�backoff_factor�status_forcelist)�request_no_retryr � frozensetr r r r �request_dont_retry� s �r\ c C s0 t �� } tt� d�}| �d|� | �d|� | S )N)� max_retrieszhttp://zhttps://)�requests�Sessionr r\ �mount)�session�adapterr r r �requests_no_retry_session� s rc c C s� z�t td�}|r�tj�|�}tj�|�}t�|�D ]N}|�d�r2||kr2| �d|� zt � tj� ||�� W q2 t y~ Y q20 q2W n t y� | �d� Y n0 dS )z[ Rudimentary workaround for https://github.com/pyinstaller/pyinstaller/issues/2379 �_MEIPASS�_MEIz Cleanup %sz Cleanup MEIN)�getattr�sys�os�path�dirname�basename�listdir� startswithr �shutil�rmtreerI �PermissionError� Exception� exception)r � mei_bundle�mei_dir� current_mei�filenamer r r � cleanup_mei� s rw )T)N) � __future__r rh rn rg r) r^ � oci.regionsr r �requests.adaptersr �requests.utilsr �urllib3.util.retryr �telemetry_metricsr rN rZ r' r r r r r( r4 r% rR r\ rc rw r r r r �<module> s2 " 5
cải xoăn