Dashboard
PHP:
8.3.33
OS:
Linux
User:
linksood
/
/
usr
/
libexec
/
oracle-cloud-agent
/
plugins
/
osms
/
oci
📤 Upload
📝 New File
📁 New Folder
Close
Editing: base_client.pyc
a M��fW� � @ sz d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl mZm Z mZ d dlmZ ddlmZmZmZ d dlmZ d dlmZ d dlZd 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-m.Z. d dlm/Z/m0Z0 ddl1m2Z2 ddl3m4Z4m5Z5m6Z6 e5d�Z7dZ8ej9�:e8�Z;d�<e2�Z=e �>d�Z?e �>d�Z@dZAdZBej9�:dd�ZCeDeCejE��r�eC�F� dk�r�d ZBd d � ZGd@d d!�ZHd"d#� ZId$d%� ZJd&d'� ZKd(ZLd)ZMd*ZNd+ZOdd,d-d.d/d0�ZPd1d2� ZQd3d4� ZRd5d6� ZSG d7d8� d8e �ZTG d9d:� d:ejUjV�ZWG d;d<� d<ejX�ZYeB�rfeYejZj[d=< G d>d?� d?e\�Z]dS )A� )�absolute_importN)�date�datetime�timezone)� default_timer� )�requests�six�urllib3)�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_endpoint�Missing�OCI_SDK_APPEND_USER_AGENTzOracle-PythonSDK/{}zdict\(str, (.+?)\)$zlist\[(.+?)\]$zOhttps://docs.oracle.com/en-us/iaas/Content/API/Concepts/sdk_troubleshooting.htmT� OCI_PYSDK_USING_EXPECT_HEADER�falseFc G s i }| D ]}|� |� q|S �N)�update)� dictionaries�merged� dictionary� r( �s/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/oci/base_client.py�merge_type_mappings6 s r* � c C s@ d� tt�� t�� t�� | p d�}|�� }tr<|d� t�7 }|S )Nz{} (python {}; {}-{}) {}r+ z {})�format� USER_INFO�platform�python_version�machine�system�strip�APPEND_USER_AGENT)�extra�agentr( r( r) �build_user_agent= s �r6 c C s dt t�� � d S )N� z: )�strr �utcnowr( r( r( r) �utc_nowK s r: c C s" | rdt jjj_n dt jjj_d S )Nr r )r �moves� http_client�HTTPConnection� debuglevel)� is_enabledr( r( r) �is_http_log_enabledO s r@ c C s: t �| �D ]*\}}t|t j�s(t|t�r t|�| |< q | S r# )r � iteritems� isinstance� integer_types�floatr8 )�headers� header_name� header_valuer( r( r) � _sanitize_headers_for_requestsV s rH �stream�bytesg $@g N@�,� r7 �|)�multi�csv�tsv�ssv�pipesc C s d }|dkr| � � }qd S )N� )�readline)�fp�currentr( r( r) �_read_all_headersv s rW c C sD g }| D ],}t |tj�r*|�|�d�� q|�|� qd�|�}|S )Nzutf-8rS )rB r � text_type�append�encode�join)� input_buffer� bytes_buffer�chunk�msgr( r( r) � _to_bytes| s r` 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 �ri 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) rn � s zOCIHTTPResponse.__init__c C s( | j d ur| j }d | _ |S t�| �S d S r# )rm r � _read_status)rp rk r( r( r) rs � s z OCIHTTPResponse._read_statusN)�__name__� __module__� __qualname__rn rs r( r( r( r) rj � s rj 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�{}.{}) �superrw rn �response_class�_original_response_cls�_response_received�_using_expect_header�logging� getLoggerr, rt �id�loggerro �� __class__r( r) rn � 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...) r| �getr> �printr} r{ rz ry rw � _send_request�_expect_header_set)rp �method�url�bodyrE rq rr �rvalr� r( r) r� � 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)� r� r z.Waiting 3 seconds for 100-continue response...rb zBTimeout waiting for 100-continue response, sending message body...)�_buffer�extendr` r} rB rJ �sendr> r� r �util� wait_for_read�sock�_handle_expect_response)rp � message_bodyrq rr r_ 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 ra z7Received 100-continue response, sending message body...rb rc z4Received non-100-continue response, abort request...�asciir )rk T)r� �makefilerT rd r> r� ri rW �_send_message_bodyre rf �decode�int� functools�partialrj rz r| �close)rp r� rU rg rh rk rz r( r( r) r� � s. ��z%OCIConnection._handle_expect_responsec C s |d ur| � |� d S r# )r� )rp r� r( r( r) r� � s z OCIConnection._send_message_bodyc s | j r d S tt| ��|�S r# )r| ry rw r� )rp r8 r� r( r) r� � s zOCIConnection.send)N) rt ru rv �__doc__rn r� r� r� r� r� � __classcell__r( r( r� r) rw � s rw c @ s e Zd ZeZdS )�OCIConnectionPoolN)rt ru rv rw � ConnectionClsr( r( r( r) r� � s r� �httpsc @ sR e Zd Zeeejeee e d�Z dZ dd� Z edd� �Zejdd� �Zdd � Zd d � Zed d � �Zejdd � �Zdd� ZdDdd�Zdd� Zdd� ZdEdd�Zdd � ZdFd d �Zed d!� �Z d"d#� Z dGd$d%�Z d&d'� Z d(d)� Z d*d+� Z!d,d-� Z"dHd.d/�Z#dId0d1�Z$dJd2d3�Z%dKd4d5�Z&d6d7� Z'd8d9� Z(d:d;� Z)d<d=� Z*d>d?� Z+ed@dA� �Z,dBdC� Z-dS )L� BaseClient)r� rD r8 �boolr r �objectFc K st t ||d� || _|�dd�| _d | _|�d�| _|�d�| _|�d�| _|�d�| _| jr�|�d�rt|�d�| _ q�d }d |v r�|d r�|�d �}nt |d �r�|j }t j || j||�d �| jd �| _ n |�d�s�t�d ��|�d�| _ || _|| _t| j|�| _t�� | _d |v �r |�d �nttf| _tt |d��| _ t � d� t!t"| ���| _#| j#�$t �%� � t |d��r�d| j#_&| j#�'t j(� t)d� nd| j#_&t)d� |�d�| _*|�d�| _+d | _,| j+d u �s�t-| j+t.��r�| j#�/d� nzt-| j+t0��s�t1d��| j+j2d u �rt3t4�5� �n| j+j2| _,t6�| j,�}|d u �rPt7| j+j8| j+j9| j+j:| j,d�}|| j;�| _;| j#�/d� | j�� d S )N)�signer�regional_clientT� base_path�service_endpoint_template�endpoint_service_name�allow_control_chars�service_endpoint�region�endpoint)r� r� r� r� z>An endpoint must be provided for a non-regional service client�timeout�additional_user_agentrx � 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� r� r� � _endpoint� _base_pathr� r� �_allow_control_charsr� �hasattrr� r � endpoint_forr �/MissingEndpointForNonRegionalServiceClientError�service�complex_type_mappingsr* �primitive_type_map� type_mappingsr �Session�session�DEFAULT_CONNECTION_TIMEOUT�DEFAULT_READ_TIMEOUTr� r6 r � user_agentr~ r r, rt r� r� � addHandler� NullHandler�disabled�setLevel�DEBUGr@ r� r� �circuit_breaker_namerB r �debugr � TypeErrorr� r8 �uuid�uuid4r r r� r� r� �request)rp r� �configr� � type_mappingrr � region_to_use�circuit_breakerr( r( r) rn st � $ � zBaseClient.__init__c C s | j S r# )r� �rp 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, )rp r� r( r( r) r� a s $c C s t | j�S r# )r r� r� r( r( r) � get_endpointm s zBaseClient.get_endpointc C s. | j r"tj| j| j|| jd�| _ntd��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� )rp r� r( r( r) � set_regionp s zBaseClient.set_regionc C s | j S r# �r� r� r( r( r) r� v s z BaseClient.allow_control_charsc C s || _ d S r# r� )rp r� r( r( r) r� z s c C sD t | jtj�s8t | jtj�s8t | jtj�s8t | jtj�r<dS dS d S �NTF)rB r� r �%InstancePrincipalsSecurityTokenSigner�"ResourcePrincipalsFederationSigner� EphemeralResourcePrincipalSigner�#EphemeralResourcePrincipalV21Signerr� 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�|�}| j | }t |||||||d �}| � � �r�d }|dk �rz| � || | | �W S t j!�y� } z8|d7 }|j"dk�r�|dk �r�| j#�$� n� W Y d}~n d}~0 0 �q^n: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. )�put�post�patchc S s i | ]}|� � |�qS r( )�lower��.0�kr( r( r) � <dictcomp>� r� z'BaseClient.call_api.<locals>.<dictcomp>r� N�OCI_DB_OPC_HOST_SERIALzopc-host-serial�{�}z content-typezapplication/json)r� r� � query_params� header_paramsr� � response_type�enforce_content_headersr ra r i� z time elapsed for request: {}))�enable_expect_headerr� rl r� �sanitize_for_serializationrH r- r �HEADER_CLIENT_INFOr� �HEADER_USER_AGENT�HEADER_REQUEST_ID�missing�build_request_id�os�environ�itemsr r; �urllibr �quoter8 � to_path_value�replace�process_query_params�json�dumpsr� r r� r� r � ServiceError�statusr� �refresh_security_token�timerr� r� r, )rp � resource_pathr� � path_paramsr� r� r� r� r� r� �operation_name�api_reference_link�/map_lowercase_header_params_keys_to_actual_keys�opc_host_serialr� �v� replacementr� r� � call_attempts�e�start�response�endr( r( r) �call_api� sh � � zBaseClient.call_apic C sJ |t u r t S |tvr,td�|tt�� ����|dkr8|S t| �|�S d S )Nz6Invalid collection format type {}. Valid types are: {}rN )r� � VALID_COLLECTION_FORMAT_TYPES� ValueErrorr, �list�keysr[ )rp � param_value�collection_format_typer( r( r) � generate_collection_format_param� 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" rx )r� r� rB r� �dictr r� r, )rp r� �processed_query_paramsr� r � inner_key� inner_valr( r( r) r � 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}z�t� }| jj|j|j||j|j|j|| jd�} t� } |jtj r�| j � t� d� |jtj t| | �� � | �rt | d��r| j � t� d t| j � � W n� t j j �y� } zL| j!�s:d | _!| 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� d t| j$� � d| j$ k�r&dk�s8n | j%} |jd |j }t&}t'�(t)j*��+� }| �,| |�\}}}| j$dk�r�|dk�r�| j �-d� | �� | j.}| �/� | j�/� t �� | _t0| j1t2��r| j1�3| j$|��rt�| j�j }||k�r�| j �-d� ||�� | �4|| ||||| ||||� n | �5|| ||||| ||||� |�rD| }n.| t6k�rV| j.}n | �rn| �7| j.| |�}nd }t8| j$| j9||�}| j � t� d � |S )NzRequest: %s %sz Circuit Breaker State is {}!FT)�auth�paramsrE �datarI r� z time elapsed for request {}: {}�elapsedztime elapsed in response: )r+ zRequest Endpoint: r7 zd See {} for help troubleshooting this error, or contact support and provide this full error message.zResponse status: %s�� i+ i� �RequestEntityTooLargez?Recieved a 413/RequestEntityTooLarge from {}, resetting sessionz+Circuit Breaker state changed from {} to {}zResponse returned):r� �infor: r8 r� r� r� r r� �state�circuitbreaker� STATE_CLOSEDr� r, r� r� �without_content_headersr� �STREAM_RESPONSE_TYPEr r� r� r� r� r� r� r r� r� r% r r �ConnectTimeoutrq �TROUBLESHOOT_URL�RequestException� status_coder� r- r �nowr �utc� isoformat�)get_deserialized_service_code_and_message�warning�contentr� rB r� r �is_transient_error� raise_transient_service_error�raise_service_error�BYTES_RESPONSE_TYPE�deserialize_response_datar rE )rp r� r� r r � initial_circuit_breaker_stater� rI r r r r r� �target_service�request_endpoint�client_version� timestamp� service_code�message�deserialized_data�_�new_circuit_breaker_state�respr( r( r) r� 3 s� " � * ( ( zBaseClient.requestc C s t t�� ��dd��� S )N�-r+ )r8 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# )�random� SystemRandom�choice�string� ascii_letters�digits)r� rE r( r( r) � <genexpr>� r� z;BaseClient.add_opc_retry_token_if_needed.<locals>.<genexpr>)r[ �range)rp r� �retry_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. rK N)�typer r[ r8 �rp �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)r8 r� r� rD �dict(�list[c s4 g | ],}�� |� r ��� �nd �r*�d nd ��qS )Nz[*])r� �(extract_list_item_type_from_swagger_type)r� �sub_obj)� declared_type� field_namerp r( r) � <listcomp>� s ��z9BaseClient.sanitize_for_serialization.<locals>.<listcomp>z+00:00�Zc s i | ]}|� |f�qS r( r( r� )�dict_value_typer( r) r� � r� 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� �attrrE �rX r( r) r� � s �c s i | ]\}}� j | ||f�qS r( )rd )r� re � swagger_typerf r( r) r� � r� r r rx )"r � string_typesrC rD r� rV �is_none_or_none_sentinelrf rB r �"raise_type_error_serializing_modelr �tupler� r r �tzinfo�pytzr3 �localize� astimezoner4 r r �)extract_dict_value_type_from_swagger_typer� r� r, r8 rt rb r� rA r� ) rp rX r] r^ �types�0declared_swagger_type_to_acceptable_python_types�obj_dict� keys_to_types_and_field_name�sanitized_dict�key�val�value_declared_type�inner_field_namer( )r] ra r^ rX rp r) r� � sh � � � z%BaseClient.sanitize_for_serializationc C s |d u p|t u S r# )r rW r( r( r) ri � 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, r8 rV rt )rp r^ rX r] r( r( r) rj � s z-BaseClient.raise_type_error_serializing_modelc C s t �|�}d }|r |�d�}|S �Nr )�DICT_VALUE_TYPE_REGEX�search�group�rp rg �m�resultr( r( r) rp s z4BaseClient.extract_dict_value_type_from_swagger_typec C s t �|�}d }|r |�d�}|S rz )�LIST_ITEM_TYPE_REGEXr| r} r~ r( r( r) r[ s z3BaseClient.extract_list_item_type_from_swagger_typec C s* t j|j||j||||||| | | d� �d S �N)�original_requestr r r> r? r@ rA rD )r r r1 rE � rp r� r rB rC r r r> r? r@ rA rD r( r( r) r: s �z BaseClient.raise_service_errorc C s* t j|j||j||||||| | | d� �d S r� )r �TransientServiceErrorr1 rE r� r( r( r) r9 ! s �z(BaseClient.raise_transient_service_errorc C sF | � |jd|�}d }d }t|t�r8|�d�}|�d�}n|}|||fS )Nr� �coderC )r< r7 rB r r� )rp r r� rD rB rC r( r( r) r5 0 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)�strictr8 z-python SDK time elapsed for deserializing: {}N)r� �should_allow_control_charsr �loadsrV r rX r r� r �_BaseClient__deserializer� r� r: r, r8 ) rp � response_datar� r� r� � 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. NrZ z list\[(.*)\]r c s g | ]}� � |���qS r( �r� )r� �sub_data�rp �sub_klsr( r) r_ x s �z,BaseClient.__deserialize.<locals>.<listcomp>rY zdict\(([^,]*), (.*)\)ra c s i | ]\}}|� � |���qS r( r� )r� r� r r� r( r) r� } s �z,BaseClient.__deserialize.<locals>.<dictcomp>� get_subtype)rf �re�matchr} r� r� �"_BaseClient__deserialize_primitiver� r� r� rD r �ur� r� r � _BaseClient__deserialize_dater �!_BaseClient__deserialize_datetime� _BaseClient__deserialize_model)rp r$ �clsr( r� r) � __deserializej 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� )rp r$ r� �valuer( r( r) �__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, )rp rN r( r( r) �__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)rl z,Failed to parse `{0}` into a datetime objectN) r �strptimer r �tzutcr r r� r� r, )rp rN � naivedatetime� awaredatetimer( r( r) �__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. )rb r� rd �setattrr� )rp r$ r� �instancere � attr_type�propertyr� r( r( r) �__deserialize_model� 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 �GLOBAL_RETRY_STRATEGY)�operation_retry_strategy�client_retry_strategy�retry_strategyr( r( r) � get_preferred_retry_strategy� 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)rp r� �request_configuration�client_configuration�global_configurationr( r( r) r� � s z%BaseClient.should_allow_control_chars) NNNNNTNNN)NNN)rJ )NN)NNNNNNN)NNNNNNN)N)N).rt ru rv r� rD r r� r� r r r� r� r� rn r� r� �setterr� r� r� r� r r r r� r� rT � staticmethodrU r� r� ri rj rp r[ r: r9 r5 r< r� r� r� r� r� r� r� r( r( r( r) r� � sp � T � b > U X *, r� )r+ )^� __future__r r r~ r. r* rm rK r� r� rN r� � _strptimer r r �timeitr r �_vendorr r r �dateutil.parserr �dateutilr r� �six.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� � APPEND_USER_AGENT_ENV_VAR_NAMEr� r� r3 r, r- �compiler{ r� r/ r� �expect_header_env_varrB rh r� r* r6 r: r@ rH r- r; r� r� r rW r` ri rj � connection�VerifiedHTTPSConnectionrw �HTTPSConnectionPoolr� � poolmanager�pool_classes_by_schemer� r� r( r( r( r) �<module> s| � T
Save
Cancel