Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cinderclient/__pycache__/client.cpython-39.pyc
Ðазад
a t�h} � @ s, d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddl mZ ddl mZ ddlmZ ddlmZ dd lmZ dd lmZ e�d �ZddlZdd lmZ ddlm m m Z dd l m Z ddl!m"Z" ddl!m#Z# ddl$Z!zddl%m&Z& W n e'�y> ddl(m&Z& Y n0 z ddl)Z)W n e'�yh ddl*Z)Y n0 ddgZ+dZ,dZ-e-e,d�Z.dZ/dD ]Z0e�1e0e �2d�d� �q�d8dd �Z3d9d d �Z4d d � Z5d!d"� Z6G d#d$� d$ej7�Z8G d%d&� d&e9�Z:d:d*d+�Z;d,d-� Z<d.d/� Z=d0d1� Z>d2d3� Z?d4d5� Z@d6d7� ZAdS );zAOpenStack Client interface. Handles the REST calls and responses.� )�print_functionN)�access)�adapter)�discover)�base)� encodeutils)� importutils)�strutilszosprofiler.web)�urllib)�_)� api_versions)� exceptions)�sleep�v2�v3�volumev3�volumev2��2�3zX-OpenStack-Request-ID)�volumer r z /v[12]/\w+/?$�/Fc C s@ d}d}t �t�}z�tj�| �}d}dD ]L}|j�|�sHd�|�|jv r(|jd|j� |�� } d|j |j | f } qvq(|s~| }|r�d} n|r�|} nd} t j || d�} t�| j�} | d } | D ].}d |d v r�|d }|d } q�q�d}d}q�W n< tj�y* } z |�d t�|j�� W Y d}~n d}~0 0 t�|�t�|�fS )a� Queries the server via the naked endpoint and gets version info. :param url: url of the cinder endpoint :param insecure: Explicitly allow client to perform "insecure" TLS (https) requests :param cacert: Specify a CA bundle file to use in verifying a TLS (https) server certificate :returns: APIVersion object for min and max version supported by the server z2.0N)r r z/{0}/z %s://%s%sFT)�verify�versionsz3.�version� min_versionz9Error in server version query:%s Returning APIVersion 2.0)�logging� getLogger�__name__r �parse�urlparse�path�endswith�format�rfind�scheme�netloc�requests�get�json�loads�textr �ClientException�warning�six� text_type�messager � APIVersion)�url�insecure�cacertr �current_version�logger�uZ version_url�verr! � verify_cert�response�datar r �e� r= ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cinderclient/client.py�get_server_versionG sF ��r? c C s* t | ||�\}}t�tj�}t||��� S )zCReturns highest supported version by client and server as a string.)r? r r1 Z MAX_VERSION�min� get_string)r2 r3 r4 Z min_serverZ max_serverZ max_clientr= r= r> �!get_highest_client_server_version� s rB c C sf t �| �\}}}}}|�d�}tD ] }||v r"|dd � S q"td�| d�t�d� }t�|��d S )Nr � z<Invalid url: '%(url)s'. It must include one of: %(version)s.�, )r2 r )r �urlsplit�split�_VALID_VERSIONSr �joinr �UnsupportedVersion) r2 r% r& r! �query�frag� componentsr �msgr= r= r> �get_volume_api_from_url� s �rN c C s0 |j �d�}|r,| �d|jj||j|d�� d S )N�x-openstack-request-idzW%(method)s call to %(service_type)s for %(url)s used request id %(response_request_id)s)�method� service_typer2 Zresponse_request_id)�headersr( �debug�requestrP r2 )r6 �resp� service_nameZ request_idr= r= r> �_log_request_id� s ��rW c s� e Zd Z� fdd�Z� fdd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z d dd�Z e dd� �Zdd� Zdd� Z� ZS ) � SessionClientc sx |� dd �pt�� }t|tj�s.t�t|��}|jdkrD|�� |d< |� dd�| _t� t �| _ t t | �j|i |�� d S )N� api_versionr Zdefault_microversion�retries)�popr r1 � isinstance�strZ ver_minorrA rZ r r r �_logger�superrX �__init__)�self�args�kwargsZapiver�� __class__r= r> r` � s zSessionClient.__init__c sl |� dd� |�dd�}tt| �j|ddi|��\}}|rP|jdkrPt�||��| jsd|j � d�| _||fS )N� authenticatedF� raise_excT� rO ) � setdefaultr[ r_ rX rT � status_coder � from_response�global_request_idrR r( )ra rb rc rg rU �bodyrd r= r> rT � s �� zSessionClient.requestc K s� |� dd� d}|d7 }z| j||fi |��W S tjy� } zB|| jksT|jdk rV� d|j }| j�|� t|j� W Y d }~qd }~0 0 qd S )Nrf Tr rC �Retrying after %s seconds.) ri rT r � OverLimitrZ � retry_afterr^ rS r )ra r2 rP rc �attempts�overlimrM r= r= r> � _cs_request� s zSessionClient._cs_requestc K s | j |dfi |��S �N�GET�rs �ra r2 rc r= r= r> r( � s zSessionClient.getc K s | j |dfi |��S �N�POSTrv rw r= r= r> �post� s zSessionClient.postc K s | j |dfi |��S �N�PUTrv rw r= r= r> �put� s zSessionClient.putc K s | j |dfi |��S �N�DELETErv rw r= r= r> �delete� s zSessionClient.deletec C sH | � � }t�d|�}|r(d|�d� }n d�|�d�d d� �d }|S )Nz (.+)/v[1-3].*z%s/rC r � )� get_endpoint�re�search�grouprH rF )ra Zendpoint�m�base_urlr= r= r> � _get_base_url� s zSessionClient._get_base_urlc C sX zt | �� �}W nB tjyR } z(td�t�|� }t�|��W Y d }~n d }~0 0 |S )N�(Service catalog returned invalid url. %s)rN r� r rI r r. r/ �ra r r< rM r= r= r> �$get_volume_api_version_from_endpoint� s � z2SessionClient.get_volume_api_version_from_endpointNc C s | � |� | �|�S �N)Z invalidate� get_token�ra �authr= r= r> � authenticate� s zSessionClient.authenticatec C s4 | j p | jj }t|tj�r(|�| j�jS td��d S )Nz9There is no service catalog for this type of auth plugin.)r� �sessionr\ r ZBaseIdentityPluginZ get_access�service_catalog�AttributeErrorr� r= r= r> r� � s z SessionClient.service_catalogc K s | � � }| j|| |fi |��S r� )r� rs )ra r2 rP rc r� r= r= r> �_cs_request_base_url s ��z"SessionClient._cs_request_base_urlc K s | j |dfi |��S rt )r� rw r= r= r> �get_with_base_url s z SessionClient.get_with_base_url)N)r � __module__� __qualname__r` rT rs r( rz r} r� r� r� r� �propertyr� r� r� � __classcell__r= r= rd r> rX � s rX c @ s� e Zd ZdZdZd-dd �Zd d � Zd d � Zdd� Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zd d � Zd.d d �Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� ZdS )/� HTTPClient)� X-Auth-TokenzX-Subject-Token�python-cinderclientNF� publicURL�keystone�Defaultc C s> || _ || _|| _|| _|p"t�� | _|| _|rF|dkrF|sFt� |��|sj|rj|dkrj|� � }|sjt� � �|rx|� d�nd | _ d| _| | _| | _| | _| | _|| _|r�|� d�n|| _t|p�d�| _|| _| jp�d | _d | _| | _|| _|| _ || _ || _ |�rd| _ n|�r|| _ nd| _ || _ || _!|�p6t"�#t$�| _%d S )Nr� r Zv1r FT)&�user�password� projectid� tenant_idr r1 rY rl r ZAuthSystemNotFoundZ get_auth_url�EndpointNotFound�rstrip�auth_url� ks_version� region_name� endpoint_typerQ rV �volume_service_name� os_endpoint�intrZ �http_log_debug�management_url� auth_token� proxy_token�proxy_tenant_id�timeout�user_domain_name�project_domain_namer9 � auth_system� auth_pluginr r r r^ )ra r� r� r� r� r3 r� r� r� r� r� r� rQ rV r� r� rZ r� r4 r� r� rY r6 r� r� rl r= r= r> r` sP � � zHTTPClient.__init__c C sP |t jv r8|�d�}t�|�}|�� }t�|�d| fS t�|�t�|�fS d S )Nzutf-8z{SHA1}%s)r� �SENSITIVE_HEADERS�encode�hashlib�sha1� hexdigestr Z safe_decode)ra �name�value�encoded�hashedZdigestedr= r= r> � _safe_headerM s �zHTTPClient._safe_headerc C s� | j s d S dg}|D ]*}|dv r0|�d| � q|�d| � q|d D ]&}d| �||d | � }|�|� qHd|v r�t�|d �}|�d| � | j�d d �|� � d S ) Nzcurl -i)ru ry r r| z -X %sz %srR z -H '%s: %s'r; z -d '%s'z REQ: %s � )r� �appendr� r � mask_passwordr^ rS rH )ra rb rc Z string_parts�element�headerr; r= r= r> � http_log_reqW s � zHTTPClient.http_log_reqc C sF | j s d S | j�d|j|jt�|j�� | jp2| j }t | j||� d S )Nz RESP: [%s] %s RESP BODY: %s ) r� r^ rS rj rR r r� r+ rV rQ rW )ra rU Zservicer= r= r> � http_log_respl s � zHTTPClient.http_log_respc K sP |� d|�di �� | j|d d< d|d d< trD|d �t�� � d|v rld|d d< t�|�d��|d< t � |d | j � | j r�|d � t | j � | jr�|� d| j� | �||f|� tj||fd | ji|��}| �|� d }|j�r0zt�|j�}W n4 t�y. } z| j�d |� W Y d }~n d }~0 0 |jd k�rHt�||��||fS ) NrR z User-Agentzapplication/json�Acceptrm z Content-Typer; r� r z!Load http response text error: %srh ) ri r( � USER_AGENT�osprofiler_web�updateZget_trace_id_headersr) �dumpsr[ r Zupdate_headersrY rl � REQ_ID_HEADERr� r� r' rT r9 r� r+ r* � ValueErrorr^ rS rj r rk )ra r2 rP rc rU rm r< r= r= r> rT y s@ ��� $ zHTTPClient.requestc K s� d}d}d}|d7 }| j r | js(| �� | j|�di �d< | jrN| j|d d< z8|�| j �sf| j | }| j||fi |��\}}||fW S tjy� || j kr�� Y �n� tj y� |dkr�� | j � d� d | _ | _|d8 }|d7 }Y q Y �n` tj �y^ } zR|| j k�s | jdk �r � d| j } | j � | � t| j� W Y d } ~ q W Y d } ~ n�d } ~ 0 tj�y� } z<|| j k�r~� d| j k�r�d k�r�n nn� W Y d } ~ n�d } ~ 0 tjj�y } z:| j � d | � || j k�r�d | } t�| ��W Y d } ~ nPd } ~ 0 tjj�yP } z*| j � d | � || j k�r<� W Y d } ~ n d } ~ 0 0 | j � d || j |f � t|� |d9 }q d S )Nr rC rR r� �X-Auth-Project-Idz Unauthorized, reauthenticating.rn i� iW zConnection error: %sz"Unable to establish connection: %szTimeout error: %sz0Failed attempt(%s of %s), retrying in %s seconds� )r� r� r� ri r� � startswithrT r Z BadRequestrZ � Unauthorizedr^ rS ro rp r r, �coder' �ConnectionError�Timeout) ra r2 rP rc Z auth_attemptsrq �backoffrU rm rr rM r< r= r= r> rs � sl ��zHTTPClient._cs_requestc K s | j |dfi |��S rt rv rw r= r= r> r( � s zHTTPClient.getc K s | j |dfi |��S rx rv rw r= r= r> rz � s zHTTPClient.postc K s | j |dfi |��S r{ rv rw r= r= r> r} � s zHTTPClient.putc K s | j |dfi |��S r~ rv rw r= r= r> r� � s zHTTPClient.deletec C sv zt | j�}W nb tjyp } zH| j| jkr@td�t�|� }ntd�t�|� }t�|��W Y d }~n d }~0 0 |S )Nz-Invalid url was specified in --os-endpoint %sr� )rN r� r rI r� r r. r/ r� r= r= r> r� � s �� z/HTTPClient.get_volume_api_version_from_endpointTc C s� |j dks|j dkr�z\|| _tj||d�| _| jj| _|rD| jj| _| jj| j| j | j | j d�}|� d�| _ W dS tjy� td� � Y q� ty� t�� �Y q� tjy� td� � Y q�0 n |j d kr�|jd S t�||��dS ) z�See what the auth service told us and process the response. We may get redirected to another site, fail or actually get back a service catalog with a token and our endpoints. �� �� )rU rm )r� � interfacerQ rV r NzAFound more than one valid endpoint. Use a more restrictive filterz5Could not find any suitable endpoint. Correct region?�1 �location)rj r� r �createZauth_refr� r� Zurl_forr� r� rQ rV r� r� r ZAmbiguousEndpoints�printr� �AuthorizationFailurer� rR rk )ra r2 rU rm � extract_tokenr� r= r= r> �_extract_service_catalog� s4 � z#HTTPClient._extract_service_catalogc C sX d� |dd| j| jf g�}| j�d| � | j|dd| jid�\}}| j|||dd �S ) a� We have a token, but don't know the final endpoint for the region. We have to go back to the auth service and ask again. This request requires an admin-level token to work. The proxy token supplied could be from a low-level enduser. We can't get this from the keystone service endpoint, we have to use the admin endpoint. This will overwrite our admin token with the user token. r �tokensz%s?belongsTo=%szUsing Endpoint URL: %sru r� �rR F)r� )rH r� r� r^ rS rT r� r� )ra r2 rU rm r= r= r> �_fetch_endpoints_from_auth s �� �z%HTTPClient._fetch_endpoints_from_authc C s || _ d S r� )r� )ra r2 r= r= r> �set_management_url1 s z HTTPClient.set_management_urlc C sn t �| j�}|\}}}}}|j}|d u r,d}|�d�}|D ]&} t| �dkr:| d dkr:| | _ qbq:|�d| dd �} t �|| |||f�} | j} d| jv s�d| jv r�| r�| j r�| j d kr�| � | �} q�| j r�| j r�| � | j � n | �| � | j | _nPz| �r| �| �} q�W n8 tj�y@ | �d �dk �r2| d } | � | � Y n0 | j �rX| � | j � n| j�sjt�d ��d S ) N�P r r �vz:%d)i � r r r� zv2.0z/v2.0z Cinder Client)r rE r� �portrF �lenr� �replace� urlunsplitr� �_v2_or_v3_authr� r� r� r� r� �_v1_authr r� �findr� r� ) ra Z magic_tupler% r& r! rJ rK r� � path_parts�partZ new_netlocZ admin_urlr� r= r= r> r� 4 sF � zHTTPClient.authenticatec C s� | j rt�� �| j| jd�}| jr,| j|d< | j|d|d�\}}|jdv r�z,d}|j| � d�| _ |jd | _ || _ W q� t tfy� t�� �Y q�0 n |jd kr�|jd S t�||��d S ) N)z X-Auth-Userz X-Auth-Keyr� ru r� )r� �� zx-server-management-urlr z x-auth-tokenr� r� )r� r ZNoTokenLookupExceptionr� r� r� rT rj rR r� r� r� r� �KeyError� TypeErrorr� rk )ra r2 rR rU rm Z mgmt_headerr= r= r> r� i s& � zHTTPClient._v1_authc C s� | j dkr~dddgdd| ji| j| jd�id�ii}d d d| jiii}| jr\| j|d d< n| jrp| j|d d < ||d d < n@dd | j| jd�ii}| jr�| j|d d< n| jr�| j|d d< | �||�S )z)Authenticate against a v2.0 auth service.r r� �identityr� r� r� )�domainr� r� )�methodsr� �projectr� �id�scopeZpasswordCredentials)�usernamer� Z tenantNameZtenantId)r� r� r� r� r� r� r� � _authenticate)ra r2 rm r� r= r= r> r� � s8 ���� ��zHTTPClient._v2_or_v3_authc C s@ | j dkr|d }n|d }| j|d|dd�\}}| �|||�S )z-Authenticate and extract the service catalog.r z /auth/tokensz/tokensry T)rm �allow_redirects)r� rT r� )ra r2 rm Z token_urlrU r= r= r> r� � s � zHTTPClient._authenticate)NFNNNNNr� NNNNNFNr� NNNr� r� N)T)r r� r� r� r� r` r� r� r� rT rs r( rz r} r� r� r� r� r� r� r� r� r� r= r= r= r> r� s< � : &9 )5 r� r� r r� c K s� |rF|� dd� |� d| � |� d| � tf ||| | |||d�|��S |�d�}t| |||||||||| | | | | |||||||d�S d S )N� user_agentr� r� Zendpoint_override)r� r� rQ rV r� rZ rY r6 )r� r� r3 r� r� r� r� r� r� rQ rV r� r� rZ r� r4 r� r� r6 rY )ri rX r( r� )r� r� Z project_idr� r3 r� r� r� r� r� rQ rV r� r� rZ r� r� r� r4 r� r� r� rY rc r6 r= r= r> �_construct_http_client� sL �� �r� c C sL t | tj�st�| �} n t�| � | �� r8t�td���| t � d| j �fS )Nz+The version should be explicit, not latest.z cinderclient.v%s.client.Client) r\ r r1 Zget_api_versionZcheck_major_versionZ is_latestr rI r r � import_classZ ver_major)r r= r= r> � _get_client_class_and_version� s ��r� c C sX ddd�}z|t | � }W n2 ttfyL d| d�|�f }t�|��Y n0 t�|�S )Nz cinderclient.v2.client.Clientz cinderclient.v3.client.Clientr z/Invalid client version '%s'. must be one of: %srD )r] r� r� rH r rI r r� )r Z version_mapZ client_pathrM r= r= r> �get_client_class� s � �r c C s< g }t �t� t| ��D ] \}}tj�||�}|�|� q|S r� )� itertools�chain�_discover_via_python_path�_discover_via_contrib_path� cinderclient� extension� Extensionr� )r � extensionsr� �moduler r= r= r> �discover_extensions s � r c c sJ t �� D ]<\} }}|�d�rt| d�s0| �|�} | �|�}||fV qd S )NZcinderclient_ext� load_module)�pkgutil� iter_modulesr" �hasattr� find_moduler )Z module_loaderr� �ispkgr r= r= r> r s r c c s� t j�t j�t��}d| �dd� }t j�||d�}t j�|d�}t�|�D ]8}t j� |�d d� }|dkrnqLt � ||�}||fV qLd S )Nzv%s�.r �contribz*.py���r` ) �osr! �dirname�abspath�__file__r� rH �glob�iglob�basename�impZ load_source)r � module_path� version_strZext_pathZext_globr� r r= r= r> r s r c O s t | �\}}||d|i|��S )a� Initialize client object based on given version. HOW-TO: The simplest way to create a client instance is initialization with your credentials:: .. code-block:: python >>> from cinderclient import client >>> cinder = client.Client(VERSION, USERNAME, PASSWORD, ... PROJECT_NAME, AUTH_URL) Here ``VERSION`` can be a string or ``cinderclient.api_versions.APIVersion`` obj. If you prefer string value, you can use ``2`` (deprecated now) or ``3.X`` (where X is a microversion). Alternatively, you can create a client instance using the keystoneclient session API. See "The cinderclient Python API" page at python-cinderclient's doc. rY )r� )r rb rc rY Z client_classr= r= r> �Client) s ��r )FN)FN)NNNNFNNNNr� r NNNNFr� NNNNNN)B�__doc__� __future__r r r� r r r r r r� r. Z keystoneauth1r r r Zkeystoneauth1.identityr Z oslo_utilsr r r Z try_importr� r' Z six.movesr Zsix.moves.urllib.parse�movesr r Zcinderclient._i18nr r r r Zcinderclient.extensionZeventletr � ImportError�timer) Z simplejsonrG ZV3_SERVICE_TYPEZV2_SERVICE_TYPEZ SERVICE_TYPESr� ZsvcZadd_catalog_discover_hack�compiler? rB rN rW ZLegacyJsonAdapterrX �objectr� r� r� r r r r r r= r= r= r> �<module> s� � A h $ � 8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка