ruạṛ
a ���fC � @ sP d dl mZmZ d dlZdej_ejjejjejj hZ ddiZ G dd� d�Z dS )� )� Semaphore�TimerN� �no�proxyc @ sX e Zd ZdZddd�Zddd�Zdd � Zd d � Zed d � �Z edd� �Z edd� �Z dS )�InstanceMetadataN� �< c C s" || _ t|�| _|| _| �� d S )N)�_refresh_durationr �_rate_limit_semaphore�_logger�_rate_limited_retrieve)�self�logger�limit�every� r �Q/sparta/input/python_modules/oci_agent_utils/oci_agent_utils/instance_metadata.py�__init__ s zInstanceMetadata.__init__c C sT | � � | jd ur<| j�||�}| j�d|� d|� �� |S | j�d|� d�� d S �NzKey: z , value: zKey z not found in instance metadata)r �_instance_metadata�getr �debug)r �key�default�valuer r r r % s zInstanceMetadata.getc C sP | � � | jd ur8| j| }| j�d|� d|� �� |S | j�d|� d�� d S r )r r r r )r r r r r r � __getitem__. s z InstanceMetadata.__getitem__c C sp | j jdd�sdS z4t�| j�| _W t| j| j j�}|� d� |� � n$t| j| j j�}|� d� |� � 0 dS )z6Retrieve instance metadata bounded by refresh durationF)�blockingNT) r �acquirer � _retriever r r r �release� setDaemon�start)r �timerr r r r 7 s � z'InstanceMetadata._rate_limited_retrievec C s dS )Nz'http://169.254.169.254/opc/v2/instance/r r r r r �endpointC s zInstanceMetadata.endpointc C s dS )Nz'http://169.254.169.254/opc/v1/instance/r r r r r � v1_endpointG s z InstanceMetadata.v1_endpointc C s� d }z�d}d|d�}t jt�� t|dd���}|jt jjkrD|�� }nZ|jt v r�t jt� � dditdd��&}|jt jjkr�|�� }W d � n1 s�0 Y W d � n1 s�0 Y W | � d|� �� |S | � d|� �� | Y S 0 d S ) Nz Bearer Oraclezapplication/json)�accept� Authorization� )�url�proxies�headers�timeoutr& )r) r+ r* r, z Retrieved instance metadata: ) �requestsr r r$ �NO_PROXY� status_code�codes�ok�json�fallback_status_codesr% r )r �result� bearer_token� v2_headers� v2_response� v1_responser r r r K s6 � � �F�zInstanceMetadata._retrieve)Nr r )N) �__name__� __module__� __qualname__r r r r r � staticmethodr$ r% r r r r r r s r ) � threadingr r r- �adapters�DEFAULT_RETRIESr0 � unauthorized� forbidden� not_foundr3 r. r r r r r �<module> s � �
cải xoăn