/
lib
/
python3.9
/
site-packages
/
oci
/
__pycache__
/
Upload File
HOME
a ���fU� � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlmZmZmZ d dlmZ ddlmZmZmZmZ d dlmZ d dlm Z d dl Z d d l m Z dd l m!Z!m"Z"m#Z#m$Z$ dd l%m&Z& dd l'm(Z(m)Z) dd l*m+Z+ ddl,m-Z- ddl.m/Z/m0Z0 d dlm1Z1m2Z2 ddl3m4Z4 ddl5m6Z6m7Z7m8Z8 e7d�Z9dZ:dZ;ej<�=e:�Z>d�?e4�Z@e �Ad�ZBe �Ad�ZCdZDdZEej<�=dd�ZFeGeFejH��r�eF�I� d k�r�d ZEd d � ZJdCd!d"�ZKd#d$� ZLd%d&� ZMd'd(� ZNd)ZOd*ZPd+ZQd,ZRd-ZSd.ZTdd/d0d1d2d3�ZUd4d5� ZVd6d7� ZWd8d9� ZXG d:d;� d;e �ZYG d<d=� d=ejZj[�Z\G d>d?� d?ej]�Z^eE�r~e^ej_j`d@< G dAdB� dBea�ZbdS )D� )�absolute_importN)�date�datetime�timezone)� default_timer� )�requests�six�urllib3� sseclient)�parse)�tz)� HTTPResponse)� constants� exceptions�regions�retry)�signers)�get_config_value_or_default�validate_config)�Request)�Response)�CircuitBreakerStrategy�NoCircuitBreakerStrategy)�CircuitBreaker�CircuitBreakerMonitor)� __version__)� NONE_SENTINEL�Sentinel�extract_service_endpointZMissingZOCI_SDK_APPEND_USER_AGENT�4OCI_REALM_SPECIFIC_SERVICE_ENDPOINT_TEMPLATE_ENABLEDzOracle-PythonSDK/{}zdict\(str, (.+?)\)$zlist\[(.+?)\]$zOhttps://docs.oracle.com/en-us/iaas/Content/API/Concepts/sdk_troubleshooting.htmTZ OCI_PYSDK_USING_EXPECT_HEADER�falseFc G s i }| D ]}|� |� q|S �N)�update)Z dictionariesZmergedZ dictionary� r$ �3/usr/lib/python3.9/site-packages/oci/base_client.py�merge_type_mappings8 s r& � c C s@ d� tt�� t�� t�� | p d�}|�� }tr<|d� t�7 }|S )Nz{} (python {}; {}-{}) {}r' z {})�format� USER_INFO�platformZpython_version�machine�system�strip�APPEND_USER_AGENT)ZextraZagentr$ r$ r% �build_user_agent? s �r/ c C s dt t�� � d S )N� z: )�strr Zutcnowr$ r$ r$ r% �utc_nowM s r2 c C s" | rdt jjj_n dt jjj_d S )Nr r )r �movesZ http_clientZHTTPConnection� debuglevel)Z is_enabledr$ r$ r% �is_http_log_enabledQ s r5 c C s: t �| �D ]*\}}t|t j�s(t|t�r t|�| |< q | S r" )r � iteritems� isinstance� integer_types�floatr1 )�headersZ header_nameZ header_valuer$ r$ r% � _sanitize_headers_for_requestsX s r; �stream�bytesztext/event-stream�application/jsong $@g N@�,� r0 �|)�multiZcsvZtsvZssvZpipesc C s d }|dkr| � � }qd S )N� )�readline)�fp�currentr$ r$ r% �_read_all_headersz s rG c C sD g }| D ],}t |tj�r*|�|�d�� q|�|� qd�|�}|S )Nzutf-8rC )r7 r � text_type�append�encode�join)Z input_bufferZ bytes_buffer�chunk�msgr$ r$ r% � _to_bytes� s rN c C s2 | � d d�}t|�dko0|d �d�o0|d dkS )N� � r � HTTP/r s 100)�split�len� startswith)�line�partsr$ r$ r% �_is_100_continue� s �rW c @ s e Zd Zdd� Zdd� ZdS )�OCIHTTPResponsec O s( |� d�| _tj| g|�R i |�� d S )N� status_tuple)�pop� _status_tupler �__init__��self�args�kwargsr$ r$ r% r\ � s zOCIHTTPResponse.__init__c C s( | j d ur| j }d | _ |S t�| �S d S r" )r[ r � _read_status)r^ rY r$ r$ r% ra � s z OCIHTTPResponse._read_statusN)�__name__� __module__� __qualname__r\ ra r$ r$ r$ r% rX � s rX c sR e Zd ZdZ� fdd�Z� fdd�Zddd�Zd d � Zd d � Z� fd d�Z � Z S )� OCIConnectionz+ HTTPConnection with 100 Continue support. c sF t t| �j|i |�� | j| _d| _d| _t�d� t t | ���| _ d S )NF�{}.{}) �superre r\ �response_class�_original_response_cls�_response_received�_using_expect_header�logging� getLoggerr( rb �id�loggerr] �� __class__r$ r% r\ � s zOCIConnection.__init__c s~ d| _ |�dd�dkr0| jdkr(td� d| _n | jdkrBtd� d| _| j| _tt| �j ||||g|�R i |��}d| _ |S ) NF�expectr' z 100-continuer zUsing Expect header...TzNot using Expect header...) rj �getr4 �printrk ri rh rg re � _send_requestZ_expect_header_set)r^ �method�url�bodyr: r_ r` Zrvalrp r$ r% ru � s$ ���zOCIConnection._send_requestNc O s� | j �d� t| j �}| j d d �= | js>t|t�r>||7 }d }| �|� | jr~| jdkr`td� t j � | j d�r~| � |� d S |d ur�| jdkr�td� | �|� d S )N)� ry r z.Waiting 3 seconds for 100-continue response...rP zBTimeout waiting for 100-continue response, sending message body...)�_buffer�extendrN rk r7 r= �sendr4 rt r �utilZ wait_for_read�sock�_handle_expect_response)r^ � message_bodyr_ r` rM r$ r$ r% � _send_output� s$ zOCIConnection._send_outputc C s� | j �dd�}z�|�� }|�d d�}| jdkr6t|� t|�rd| jdkrPtd� t|� | �|� nlt |�dkr�|d � d�r�| jdkr�td� |d � d�t |d �|d � d�f}t jt|d �}|| _d | _W |�� n |�� 0 d S ) N�rbr rO z7Received 100-continue response, sending message body...rP rQ z4Received non-100-continue response, abort request...�asciir )rY T)r~ ZmakefilerD rR r4 rt rW rG �_send_message_bodyrS rT �decode�int� functools�partialrX rh rj �close)r^ r� rE rU rV rY rh r$ r$ r% r � s. ��z%OCIConnection._handle_expect_responsec C s |d ur| � |� d S r" )r| )r^ r� r$ r$ r% r� � s z OCIConnection._send_message_bodyc s | j r d S tt| ��|�S r" )rj rg re r| )r^ r1 rp r$ r% r| � s zOCIConnection.send)N) rb rc rd �__doc__r\ ru r� r r� r| � __classcell__r$ r$ rp r% re � s re c @ s e Zd ZeZdS )�OCIConnectionPoolN)rb rc rd re Z ConnectionClsr$ r$ r$ r% r� � s r� �httpsc @ s� e Zd Zeeejeee e d�Z dZ dd� Z dd� Zedd� �Zejd d� �Zd d � Zd d � Zedd� �Zejdd� �Zedd� �Zejdd� �Zdd� Zdddddddddg f dd�Zdd� Zd d � Zd d � Zd d!� ZdOd"d#�Z d$d%� Z dPd'd(�Z e d)d*� �Z d+d,� Z!dQd-d.�Z"d/d0� Z#d1d2� Z$d3d4� Z%d5d6� Z&dRd7d8�Z'dSd9d:�Z(dTd;d<�Z)dUd=d>�Z*d?d@� Z+dAdB� Z,dCdD� Z-dEdF� Z.dGdH� Z/e dIdJ� �Z0dKdL� Z1dMdN� Z2dS )V� BaseClient)r� r9 r1 �boolr r �objectFc K s� t ||d� || _|| _|�dd�| _d | _|�d�| _|�d�| _|�d�| _|�d�| _ |�d�| _ |�d �| _ | jr�|�d �r�|�d �| _ n`d }d |v r�|d r�|�d �}nt |d �r�|j}| �|| j| j�}tj||||�d �| j d �| _ n"|�d ��s t�d��|�d �| _ || _|| _t| j|�| _t�� | _d|v �rN|�d�nt t f| _ t t |d��| _!t"�#d�$t%t&| ���| _'| j'�(t"�)� � t |d��r�d| j'_*| j'�+t"j,� t-d� nd| j'_*t-d� |�d�| _.|�d�| _/d | _0| j/d u �st1| j/t2��r| j'�3d� nzt1| j/t4��s(t5d��| j/j6d u �rBt7t8�9� �n| j/j6| _0t:�| j0�}|d u �r�t;| j/j<| j/j=| j/j>| j0d�}|| j?�| _?| j'�3d�$| j�� d S )N)�signer�regional_clientT� base_path�service_endpoint_template�#service_endpoint_template_per_realm�endpoint_service_name�allow_control_chars�5client_level_realm_specific_endpoint_template_enabledZservice_endpoint�region�endpoint�r� r� r� r� z>An endpoint must be provided for a non-regional service client�timeoutZadditional_user_agentrf Z log_requestsF�skip_deserialization�circuit_breaker_strategyz$No circuit breaker strategy enabled!z!Invalid Circuit Breaker Strategy!)�failure_threshold�recovery_timeout�expected_exception�namez Endpoint: {})@r r� �configrs r� � _endpoint� _base_pathr� r� r� �_allow_control_chars�6_client_level_realm_specific_endpoint_template_enabledr� �hasattrr� � handle_service_endpoint_templater � endpoint_forr Z/MissingEndpointForNonRegionalServiceClientError�service�complex_type_mappingsr& �primitive_type_map� type_mappingsr ZSession�session�DEFAULT_CONNECTION_TIMEOUT�DEFAULT_READ_TIMEOUTr� r/ r � user_agentrl rm r( rb rn ro Z addHandlerZ NullHandlerZdisabledZsetLevel�DEBUGr5 r� r� �circuit_breaker_namer7 r �debugr � TypeErrorr� r1 �uuid�uuid4r r r� r� r� �request) r^ r� r� r� Z type_mappingr` � region_to_useZendpoint_template�circuit_breakerr$ r$ r% r\ s| � $ � zBaseClient.__init__c C s4 | � � }|r0|tjv r0tj| }||v r0|| S |S r" )� should_allow_template_per_realmr Z REGION_REALMS)r^ Z region_idr� r� Z should_enable_realm_templateZrealmr$ r$ r% r� g s z+BaseClient.handle_service_endpoint_templatec C s | j S r" )r� �r^ r$ r$ r% r� r s zBaseClient.endpointc C sR | j dkr|| _n<| j rH|�| j �sH|�d�| j ��sHd�|| j �| _n|| _d S )N�/z{}/z{}{})r� r� �endswithr( )r^ r� r$ r$ r% r� v s $c C s t | j�S r" )r r� r� r$ r$ r% � get_endpoint� s zBaseClient.get_endpointc C s> | j r2| �|| j| j�}tj| j||| jd�| _nt d��d S )N)r� r� r� zeSetting the region is not allowed for non-regional service clients. You must instead set the endpoint) r� r� r� r� r r� r� r� r� r� )r^ r� r� r$ r$ r% � set_region� s zBaseClient.set_regionc C s | j S r" �r� r� r$ r$ r% r� � s z BaseClient.allow_control_charsc C s || _ d S r" r� )r^ r� r$ r$ r% r� � s c C s | j S r" )r� r� r$ r$ r% r� � s z@BaseClient.client_level_realm_specific_endpoint_template_enabledc C sx || _ d }d| jv r,| jd r,| j�d�}nt| jd�r@| jj}| �|| j| j�}t j | j ||| j�d�| j d�| _ d S )Nr� r� r� )r� r� rs r� r� r� r� r� r� r r� r� r� r� )r^ r� r� r� r$ r$ r% r� � s �c C s` t | jtj�sTt | jtj�sTt | jtj�sTt | jtj�sTt | jtj�sTt | jtj�rXdS dS d S �NTF) r7 r� r Z%InstancePrincipalsSecurityTokenSignerZ"ResourcePrincipalsFederationSignerZ EphemeralResourcePrincipalSignerZ#EphemeralResourcePrincipalV21SignerZNestedResourcePrincipalsZ*OkeWorkloadIdentityResourcePrincipalSignerr� r$ r$ r% �2is_instance_principal_or_resource_principal_signer� s � � � � �z=BaseClient.is_instance_principal_or_resource_principal_signerNTc C s |rFt r|�� dvr<dd� |D �} d| v r<|�| �d�d� | �|�}|pLi }t|�}t|tj< | j |tj < |�tj t �t u r�| � � |tj < tj�d�}|r�||d< |r�| �|�}|�� D ]6\}}tjjj�t| �|���}|�d| d |�}q�|�r| �|�}|du�r0|�d �d k�r0| �|�}t�|�}| � ||| �}|| }t |||||||d �}| � � �r�d }|dk �r z| � || | | �W S t j!�y� } z8|d7 }|j"dk�r�|dk �r�| j#�$� n� W Y d}~n d}~0 0 �qjn:t%� }| � || | | �}t%� }| j&�'d�(t|| ��� |S dS )a5 Makes the HTTP request and return the deserialized data. :param resource_path: Path to the resource (e.g. /instance) :param method: HTTP method :param path_params: (optional) Path parameters in the url. :param query_params: (optional) Query parameters in the url. :param header_params: (optional) Request header params. :param body: (optional) Request body. :param response_type: (optional) Response data type. :param enforce_content_headers: (optional) Whether content headers should be added for PUT and POST requests when not present. Defaults to True. :param allow_control_chars: (optional) Boolean that allows whether or not the response object can contain control chars :param operation_name: (optional) String that represents the operational name of the API call. :param api_reference_link: (optional) String that represents the link to the API reference page for this operation. :return: A Response object, or throw in the case of an error. )ZputZpostZpatchc S s i | ]}|� � |�qS r$ )�lower��.0�kr$ r$ r% � <dictcomp>� ry z'BaseClient.call_api.<locals>.<dictcomp>rr NZOCI_DB_OPC_HOST_SERIALzopc-host-serial�{�}� content-typer> )rv rw � query_params� header_paramsrx � response_type�enforce_content_headersr rO r i� z time elapsed for request: {}))�enable_expect_headerr� rZ rs �sanitize_for_serializationr; r) r ZHEADER_CLIENT_INFOr� ZHEADER_USER_AGENT�HEADER_REQUEST_ID�missing�build_request_id�os�environ�itemsr r3 Zurllibr �quoter1 � to_path_value�replace�process_query_params�json�dumps�!handle_service_params_in_endpointr r� r� r � ServiceError�statusr� Zrefresh_security_token�timerro r� r( )r^ � resource_pathrv � path_paramsr� r� rx r� r� r� �operation_name�api_reference_link�required_argumentsZ/map_lowercase_header_params_keys_to_actual_keysZopc_host_serialr� �vZ replacementr� rw r� Z call_attempts�e�start�response�endr$ r$ r% �call_api� sj � � zBaseClient.call_apic C s� i }t td d�|�dd��d���d���}|D ]�}d}d|v rZd}|�d�} |d| � }||v r�||v sr||v r�||v r�|| n|| } |r�| d7 } | ||d < q�| ||< q0|r�d||d < q0d||< q0|S ) Nr' �.r� r� Fz+DotTr )�set�filterrK r� rR �find) r^ �service_params_urlr� r� r� �service_params_mapZservice_params� service_paramZshould_append_dotZdot_idx�valuer$ r$ r% � map_service_params_to_values s$ ( z'BaseClient.map_service_params_to_valuesc C sr | j }td�}|| dkrn|�d�}|||d � }| �||||�}|�� D ] \} } d| d } |�| | �}qL|S )Nzhttps://r� r� r )r� rS �rfindr� r� r� ) r^ r� r� r� r� Z start_idxZend_idxr� r� r� r� r$ r$ r% r� 6 s z,BaseClient.handle_service_params_in_endpointc C sJ |t u r t S |tvr,td�|tt�� ����|dkr8|S t| �|�S d S )Nz6Invalid collection format type {}. Valid types are: {}rB )r� � VALID_COLLECTION_FORMAT_TYPES� ValueErrorr( �list�keysrK )r^ Z param_valueZcollection_format_typer$ r$ r% � generate_collection_format_paramD s z+BaseClient.generate_collection_format_paramc C s� | � |�}i }|�� D ]~\}}t|t�r:|r0dnd||< qt|t�s^t|t�s^| �|�||< qt|t�rr|||< q|�� D ]\}}||d�||�< qzq|S )N�truer! rf )r� r� r7 r� �dictr� r� r( )r^ r� Zprocessed_query_paramsr� r� Z inner_keyZ inner_valr$ r$ r% r� P s z BaseClient.process_query_paramsc C s" | j �t� dt|j�|jf � d }| jrVt�| j�j }|t j krV| j � d� |�� | j}|jsh|j}d}|jtkrzd}t|j�dd�v r�d}z�t� }| jj|j|j||j|j|j|| jd�} t� } |jtj r�| j � t� d� |jtj t| | �� � | �r*t | d ��r*| j � t� d t| j � � W n� t j j!�y� } zL| j"�sPd | _"| j"d |j d |j d� t#� f | _"t �!| ��W Y d } ~ nrd } ~ 0 t j j$�y� } zL| j"�s�d | _"| j"d |j d |j d� t#� f | _"t �$| ��W Y d } ~ n d } ~ 0 0 |j} | j � t� dt| j%� � d| j% k�r<dk�sVn | j&} |jd |j }t'}t(�)t*j+��,� }| �-| |�\}}}| j%dk�r�|dk�r�| j �.d� | �� | j/}| �0� t1�1| j�}| j�0� || _t2| j3t4��r8| j3�5| j%|��r8t�| j�j }||k�r| j �.d� ||�� | �6|| ||||| ||||� n | �7|| ||||| ||||� |�r�| j8�dd��9� tk�r�| j �.d� t:�;| �}n>| �r�| tk�r�| j8�dd��9� t<k�r�| �=| j/| |�}n| }n.| t>k�r�| j/}n | �r�| �=| j/| |�}nd }t?| j%| j8||�}| j � t� d � |S )NzRequest: %s %sz Circuit Breaker State is {}!FTZaccept�empty)�auth�paramsr: �datar< r� z time elapsed for request {}: {}�elapsedztime elapsed in response: )r' zRequest Endpoint: r0 zd See {} for help troubleshooting this error, or contact support and provide this full error message.zResponse status: %s�� i+ i� ZRequestEntityTooLargez?Recieved a 413/RequestEntityTooLarge from {}, resetting sessionz+Circuit Breaker state changed from {} to {}r� z.Received SSE response, returning an SSE clientzResponse returned)@ro �infor2 r1 rv rw r� r rs �state�circuitbreakerZ STATE_CLOSEDr� r( r� r� Zwithout_content_headersr� �STREAM_RESPONSE_TYPE�SSE_RESPONSE_HEADER_VALUEr� r� r� r� r� rx r� r r� r� r r r ZConnectTimeoutr_ �TROUBLESHOOT_URLZRequestException� status_coder� r) r Znowr �utc� isoformat�)get_deserialized_service_code_and_messageZwarning�contentr� �copyr7 r� r Zis_transient_error� raise_transient_service_error�raise_service_errorr: r� r Z SSEClient�%APPLICATION_JSON_CONTENT_HEADER_VALUE�deserialize_response_data�BYTES_RESPONSE_TYPEr )r^ r� r� r� r� Z initial_circuit_breaker_stater� r< r� r� r� r� r� �target_service�request_endpoint�client_version� timestamp� service_code�message�deserialized_data�_Z new_sessionZnew_circuit_breaker_stateZrespr$ r$ r% r� � s� " � * ( ( ( zBaseClient.requestc C s t t�� ��dd��� S )N�-r' )r1 r� r� r� �upperr� r$ r$ r% r� � s zBaseClient.build_request_id� c C s( d|vr$d� dd� t|�D ��|d< d S )Nzopc-retry-tokenr' c s s$ | ] }t �� �tjtj �V qd S r" )�randomZ SystemRandom�choice�string� ascii_letters�digits)r� r r$ r$ r% � <genexpr>� ry z;BaseClient.add_opc_retry_token_if_needed.<locals>.<genexpr>)rK �range)r^ r� Zretry_token_lengthr$ r$ r% � add_opc_retry_token_if_needed� s z(BaseClient.add_opc_retry_token_if_neededc C s d| vrd| d< d S )Nzopc-client-retriesr� r$ )r� r$ r$ r% � add_opc_client_retries_header� s z(BaseClient.add_opc_client_retries_headerc C s" t |�tkrd�|�S t|�S dS )z� Takes value and turn it into a string suitable for inclusion in the path, by url-encoding. :param obj: object or string value. :return string: quoted value. r? N)�typer� rK r1 �r^ �objr$ r$ r% r� � s zBaseClient.to_path_valuec s� t jt jtttd�f}t jttt jftt jfd�}� r����s� �d�rdt�t �sd�� ��� � n�� �d�r�t�t �s�t�t �s��� ��� � nX� �j v r�t�t �s�t��j � �s�� ��� � n$� |v r�t�|� �s�� ��� � t�|�r��S �tu �rdS t�t ��s t�t ��r4� ��fdd��D �S t�t��rl�j�sTtj������tj��� �dd�S t�t��r���� S t�t ��r��}d}� �r��� ���fd d �|D �}nZt�d ��s�td �t ��t��j �����fd d ��j � � D �}�fdd �t � �j �D �}i }t � |�D ]X\} } d} | } |�rN|| d } || d } ��r`d��| �n| } ��!| | | �|| < �q |S dS )a� Builds a JSON POST object. If obj is str, int, float, bool, None, return directly. If obj is datetime.datetime, datetime.date convert to string in iso8601 format. If obj is list, sanitize each element in the list. If obj is dict, return the dict. If obj is swagger model, return the properties dict. :param obj: The data to serialize. :return: The serialized form of data. N)r1 r� r� r9 �dict(�list[c s4 g | ],}�� |� r ��� �nd �r*�d nd ��qS )Nz[*])r� �(extract_list_item_type_from_swagger_type)r� Zsub_obj)� declared_type� field_namer^ r$ r% � <listcomp>5 s ��z9BaseClient.sanitize_for_serialization.<locals>.<listcomp>z+00:00�Zc s i | ]}|� |f�qS r$ r$ r� )�dict_value_typer$ r% r� I ry z9BaseClient.sanitize_for_serialization.<locals>.<dictcomp>� swagger_typesz7Not able to serialize data: {} of type: {} in field: {}c s0 i | ](\}}t � |�d ur� j| t � |��qS r" )�getattr� attribute_map)r� �attrr �r, r$ r% r� O s �c s i | ]\}}� j | ||f�qS r$ )r7 )r� r8 � swagger_typer9 r$ r% r� S ry r r rf )"r � string_typesr8 r9 r� r* �is_none_or_none_sentinelrT r7 r� �"raise_type_error_serializing_modelr� �tupler� r r �tzinfo�pytzr ZlocalizeZ astimezoner r� r �)extract_dict_value_type_from_swagger_typer� r� r( r1 rb r5 r� r6 r� ) r^ r, r0 r1 �typesZ0declared_swagger_type_to_acceptable_python_typesZobj_dictZ keys_to_types_and_field_nameZsanitized_dict�key�valZvalue_declared_typeZinner_field_namer$ )r0 r4 r1 r, r^ r% r� sh � � � z%BaseClient.sanitize_for_serializationc C s |d u p|t u S r" )r r+ r$ r$ r% r< b s z#BaseClient.is_none_or_none_sentinelc C s" t d�|t|�|t|�j���d S )NzGField {} with value {} was expected to be of type {} but was of type {})r� r( r1 r* rb )r^ r1 r, r0 r$ r$ r% r= e s z-BaseClient.raise_type_error_serializing_modelc C s t �|�}d }|r |�d�}|S �Nr )�DICT_VALUE_TYPE_REGEX�search�group�r^ r: �m�resultr$ r$ r% rA h s z4BaseClient.extract_dict_value_type_from_swagger_typec C s t �|�}d }|r |�d�}|S rE )�LIST_ITEM_TYPE_REGEXrG rH rI r$ r$ r% r/ q s z3BaseClient.extract_list_item_type_from_swagger_typec C s* t j|j||j||||||| | | d� �d S �N)Zoriginal_requestr� r� r r r r r )r r� r r: � r^ r� r� r r r� r� r r r r r r$ r$ r% r z s �z BaseClient.raise_service_errorc C s* t j|j||j||||||| | | d� �d S rM )r ZTransientServiceErrorr r: rN r$ r$ r% r � s �z(BaseClient.raise_transient_service_errorc C sF | � |jd|�}d }d }t|t�r8|�d�}|�d�}n|}|||fS )Nr� �coder )r r r7 r� rs )r^ r� r� r r r r$ r$ r% r � s z4BaseClient.get_deserialized_service_code_and_messagec C s� |� d�}z8| �|�}tj|| d�}|dks<t|�tjkr@|}W n tyT Y n0 | jr`|S t � }| � ||�}t � }| j � t � d�t|| �� � |S dS )ai Deserializes response into an object. :param response_data: object to be deserialized. :param response_type: class literal for deserialized object, or string of class name. :param allow_control_chars: boolean to allow control character in a response. Defaults to None :return: deserialized object. �utf8)�strictr1 z-python SDK time elapsed for deserializing: {}N)r� �should_allow_control_charsr� �loadsr* r rH r� r� r� �_BaseClient__deserializero r� r2 r( r1 ) r^ Z response_datar� r� rR Z json_responser� �resr� r$ r$ r% r � s z$BaseClient.deserialize_response_datac s |du r dS |� d�r<t�d|��d��� �fdd�|D �S |� d�rpt�d|��d ��� �fd d �|�� D �S |� jv r�� j| }n � �||�S t|d �r�|�|�}� j| }|t t t j t fv rΈ �||�S |tkr�|S |tkr� �|�S |tk�r � �|�S � �||�S dS ) z� Deserialize a dict, list, or str into an object. :param data: dict, list or str :param cls: string of class name :return: object. Nr. z list\[(.*)\]r c s g | ]}� � |���qS r$ �rT )r� Zsub_data�r^ Zsub_klsr$ r% r2 � s �z,BaseClient.__deserialize.<locals>.<listcomp>r- zdict\(([^,]*), (.*)\)rO c s i | ]\}}|� � |���qS r$ rV )r� r� r� rW r$ r% r� � s �z,BaseClient.__deserialize.<locals>.<dictcomp>� get_subtype)rT �re�matchrH r� r� �"_BaseClient__deserialize_primitiver� rX r� r9 r �ur� r� r � _BaseClient__deserialize_dater �!_BaseClient__deserialize_datetime� _BaseClient__deserialize_model)r^ r �clsr$ rW r% Z __deserialize� s6 � � zBaseClient.__deserializec C sB z ||�}W n0 t y( t�|�}Y n ty< |}Y n0 |S )z� Deserializes string to primitive type. :param data: str. :param cls: class literal. :return: int, float, str, bool. )�UnicodeEncodeErrorr r\ r� )r^ r r` r� r$ r$ r% Z__deserialize_primitive� s z"BaseClient.__deserialize_primitivec C sH zt |��� W S ty$ | Y S tyB td�|���Y n0 dS )zb Deserializes string to date. :param string: str. :return: date. z(Failed to parse `{0}` into a date objectN)r r � ImportErrorr� � Exceptionr( )r^ r# r$ r$ r% Z__deserialize_date s z BaseClient.__deserialize_datec C s� z"t �|d�}|jt�� d�}|W S ty| zt|�W Y S tyX | Y Y S tyv td� |���Y n0 Y n ty� | Y S 0 dS )z� Deserializes string to datetime. The string should be in iso8601 datetime format. :param string: str. :return: datetime. z%Y-%m-%dT%H:%M:%S.%fZ)r? z,Failed to parse `{0}` into a datetime objectN) r �strptimer� r Ztzutcr� r rb rc r( )r^ r# Z naivedatetimeZ awaredatetimer$ r$ r% Z__deserialize_datetime s z!BaseClient.__deserialize_datetimec C sL |� }|j �� D ]6\}}|j| }||v r|| }t||| �||�� q|S )z� Deserializes list or dict to model. :param data: dict, list. :param cls: class literal. :return: model object. )r5 r� r7 �setattrrT )r^ r r` �instancer8 Z attr_type�propertyr� r$ r$ r% Z__deserialize_model7 s z BaseClient.__deserialize_modelc C s( d}| r| }n|r|}n t jr$t j}|S )a Gets the preferred Retry Strategy for the client :param operation_retry_strategy: (optional) Operation level Retry Strategy :param client_retry_strategy: (optional) Client level Retry Strategy :return: Preferred Retry Strategy. N)r ZGLOBAL_RETRY_STRATEGY)Zoperation_retry_strategyZclient_retry_strategyZretry_strategyr$ r$ r% � get_preferred_retry_strategyI s z'BaseClient.get_preferred_retry_strategyc C s8 |}| j }tj}|d ur |S |d ur(|S |du r4dS dS r� )r� r� �ALLOW_CONTROL_CHARACTERS)r^ r� Zrequest_configuration�client_configurationZglobal_configurationr$ r$ r% rR Z s z%BaseClient.should_allow_control_charsc C s6 | j }tj�t�}|dur |S |dur2|�� dkS dS )z� Returns a boolean of whether or not we should use realm specific endpoint templates The highest precedence goes in decending order. The order: Client / Environment / Default (False) Nr� F)r� r� r� rs r r� )r^ rj Zenv_configurationr$ r$ r% r� m s z*BaseClient.should_allow_template_per_realm)NNN)r )NN)NNNNNNN)NNNNNNN)N)N)3rb rc rd r� r9 r r\ r� r r r� r� ri r\ r� rg r� �setterr� r� r� r� r� r� r� r� r� r� r� r� r( � staticmethodr) r� r� r< r= rA r/ r r r r rT r[ r] r^ r_ rh rR r� r$ r$ r$ r% r� s� � Z � e > b X *, r� )r' )cZ __future__r r� rl r* r r@ r! r� rY r# r� r Z _strptimer r r Ztimeitr r� Z_vendorr r r r Zdateutil.parserr Zdateutilr r� Zsix.moves.http_clientr r' r r r r r r r� r r r� r r� r r� r r r r �versionr r} r r r r� Z APPEND_USER_AGENT_ENV_VAR_NAMEr r� rs r. r( r) �compilerF rL r r� Zexpect_header_env_varr7 r; r� r& r/ r2 r5 r; r r r r r� r� r� rG rN rW rX Z connectionZVerifiedHTTPSConnectionre ZHTTPSConnectionPoolr� Z poolmanagerZpool_classes_by_schemer� r� r$ r$ r$ r% �<module> s� � T