Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/common/__pycache__/abiquo.cpython-39.pyc
Ðазад
a q�hK( � @ s� d Z ddlZddlmZmZ ddlmZ ddlmZmZ ddl m Z ddl m Z ddl m Z dd l mZ d d � ZG d d � d e�ZG dd� dee�ZG dd� de�ZdS )zk Abiquo Utilities Module for the Abiquo Driver. Common utilities needed by the :class:`AbiquoNodeDriver`. � N)�ConnectionUserAndKey�PollingConnection)� XmlResponse)�InvalidCredsError� LibcloudError)�httplib)�urlparse)�b)� NodeStatec C sj | � d�}|D ]V}|jd |kr|jd }d}t�|�j}|�|�}||t|� d d� }| S qdS )aH Search a RESTLink element in the :class:`AbiquoResponse`. Abiquo, as a REST API, it offers self-discovering functionality. That means that you could walk through the whole API only navigating from the links offered by the entities. This is a basic method to find the 'relations' of an entity searching into its links. For instance, a Rack entity serialized as XML as the following:: <?xml version="1.0" encoding="UTF-8" standalone="yes"?> <rack> <link href="http://host/api/admin/datacenters/1" type="application/vnd.abiquo.datacenter+xml" rel="datacenter"/> <link href="http://host/api/admin/datacenters/1/racks/1" type="application/vnd.abiquo.rack+xml" rel="edit"/> <link href="http://host/api/admin/datacenters/1/racks/1/machines" type="application/vnd.abiquo.machines+xml" rel="machines"/> <haEnabled>false</haEnabled> <id>1</id> <longDescription></longDescription> <name>racacaca</name> <nrsq>10</nrsq> <shortDescription></shortDescription> <vlanIdMax>4094</vlanIdMax> <vlanIdMin>2</vlanIdMin> <vlanPerVdcReserved>1</vlanPerVdcReserved> <vlansIdAvoided></vlansIdAvoided> </rack> offers link to datacenters (rel='datacenter'), to itself (rel='edit') and to the machines defined in it (rel='machines') A call to this method with the 'rack' element using 'datacenter' as 'rel' will return: 'http://10.60.12.7:80/api/admin/datacenters/1' :type element: :class:`xml.etree.ElementTree` :param element: Xml Entity returned by Abiquo API (required) :type rel: ``str`` :param rel: relation link name :rtype: ``str`` :return: the 'href' value according to the 'rel' input parameter �link�rel�hrefz/api/� N)�findall�attribr �path�find�len) �elementr �linksr r �needleZurl_path�index�result� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/common/abiquo.py�get_href s 0 r c @ sN e Zd ZdZejejejejejejejejd�Z dd� Z dd� Z dd� Z d S ) �AbiquoResponsezt Abiquo XML Response. Wraps the response in XML bodies or extract the error data in case of error. )Z NOT_ALLOCATEDZ ALLOCATEDZ CONFIGURED�ONZPAUSEDZOFF�LOCKED�UNKNOWNc C s� | j tjkr t| jjd��nv| j tjkr6t| jj��n\| j tjkrLt d��nF| � � }|dur�t |d�r�| � � � d�}t |d � d���n t | j��dS )a Parse the error messages. Response body can easily be handled by this class parent :class:`XmlResponse`, but there are use cases which Abiquo API does not respond an XML but an HTML. So we need to handle these special cases. )�driverzNot AcceptableNr �errorr �message)�statusr � UNAUTHORIZEDr � connectionr � FORBIDDEN�ForbiddenError�NOT_ACCEPTABLEr � parse_body�hasattrr �findtext�body)�selfZ parsebody�errorsr r r � parse_errors s zAbiquoResponse.parse_errorc C s | j tjtjtjtjfv S )z� Determine if the request was successful. Any of the 2XX HTTP response codes are accepted as successful requests :rtype: ``bool`` :return: successful request or not. )r# r �OK�CREATED� NO_CONTENT�ACCEPTED)r- r r r �success� s �zAbiquoResponse.successc C s& | � � r | �� }|�d�dkS dS dS )a� Determinate if async request was successful. An async_request retrieves for a task object that can be successfully retrieved (self.status == OK), but the asynchronous task (the body of the HTTP response) which we are asking for has finished with an error. So this method checks if the status code is 'OK' and if the task has finished successfully. :rtype: ``bool`` :return: successful asynchronous request or not �state�FINISHED_SUCCESSFULLYFN)r4 r) r+ )r- �taskr r r � async_success� s z AbiquoResponse.async_successN) �__name__� __module__� __qualname__�__doc__r Z TERMINATEDZPENDINGZRUNNINGr ZNODE_STATE_MAPr/ r4 r8 r r r r r _ s � r c s> e Zd ZdZeZd � fdd� Zdd� Zdd � Zd d � Z � Z S ) �AbiquoConnectionz� A Connection to Abiquo API. Basic :class:`ConnectionUserAndKey` connection with :class:`PollingConnection` features for asynchronous tasks. TNc s. t t| �j||||||||| | d� i | _d S )N) �user_id�key�secure�host�port�url�timeout� retry_delay�backoff� proxy_url)�superr= �__init__�cache) r- r> r? r@ rA rB rC rD rE rF rG �� __class__r r rI � s � zAbiquoConnection.__init__c C s8 t d| j| jf �}t�|��d�}d| }||d< |S )a| Add Basic Authentication header to all the requests. It injects the 'Authorization: Basic Base64String===' header in each request :type headers: ``dict`` :param headers: Default input headers :rtype: ``dict`` :return: Default input headers with the 'Authorization' header z%s:%szutf-8zBasic � Authorization)r r> r? �base64� b64encode�decode)r- �headersZ b64string�encoded� authorizationr r r �add_default_headers� s z$AbiquoConnection.add_default_headersc C s4 |j }t|d�}ddi}||d< d|d< ||d< |S )az Manage polling request arguments. Return keyword arguments which are passed to the :class:`NodeDriver.request` method when polling for the job status. The Abiquo Asynchronous Response returns and 'acceptedrequest' XmlElement as the following:: <acceptedrequest> <link href="http://uri/to/task" rel="status"/> <message>You can follow the progress in the link</message> </acceptedrequest> We need to extract the href URI to poll. :type response: :class:`xml.etree.ElementTree` :keyword response: Object returned by poll request. :type request_kwargs: ``dict`` :keyword request_kwargs: Default request arguments and headers :rtype: ``dict`` :return: Modified keyword arguments r# �Acceptz application/vnd.abiquo.task+xml�action�GET�methodrQ )�objectr )r- �response�contextZrequest_kwargsZaccepted_request_objZ link_pollZhdr_pollr r r �get_poll_request_kwargs� s z(AbiquoConnection.get_poll_request_kwargsc C s |j }|�d�}|dv S )a Decide if the asynchronous job has ended. :type response: :class:`xml.etree.ElementTree` :param response: Response object returned by poll request :rtype: ``bool`` :return: Whether the job has completed r5 )r6 ZABORTEDZFINISHED_UNSUCCESSFULLY)rY r+ )r- rZ r7 Z task_stater r r � has_completed� s z AbiquoConnection.has_completed)TNNNNNNN) r9 r: r; r< r Z responseClsrI rT r\ r] � __classcell__r r rK r r= � s �"r= c s e Zd ZdZ� fdd�Z� ZS )r' zN Exception used when credentials are ok but user has not permissions. c s d}t t| ��||� d S )Nz-User has not permission to perform this task.)rH r' rI )r- r r" rK r r rI s zForbiddenError.__init__)r9 r: r; r< rI r^ r r rK r r' s r' )r< rN Zlibcloud.common.baser r r Zlibcloud.common.typesr r Zlibcloud.utils.py3r r r Zlibcloud.compute.baser r r r= r' r r r r �<module> s @M_
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка