Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/abiquo.cpython-39.pyc
Ðазад
a q�h){ � @ s� d Z ddlmZ ddlmZmZ ddlmZmZ ddl m Z m Z m Z ddlm Z mZmZ ddlmZ G dd � d e�ZG d d � d e�Zd S ) z� Abiquo Compute Driver The driver implements the compute Abiquo functionality for the Abiquo API. This version is compatible with the following versions of Abiquo: * Abiquo 3.4 (http://wiki.abiquo.com/display/ABI34/The+Abiquo+API) � )�ET)� NodeDriver�NodeSize)�Provider� LibcloudError)�AbiquoConnection�get_href�AbiquoResponse)� NodeLocation� NodeImage�Node)�tostringc s< e Zd ZdZejZdZdZe Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZ � fdd�Z dEdd�Z dd � Z d d � Z d d � Z!dFd!d"�Z"d#d$� Z#dGd%d&�Z$dHd'd(�Z%d)d*� Z&dId+d,�Z'dJd-d.�Z(d/d0� Z)d1d2� Z*d3d4� Z+d5d6� Z,d7d8� Z-d9d:� Z.dKd;d<�Z/d=d>� Z0d?d@� Z1dLdAdB�Z2dMdCdD�Z3� Z4S )N�AbiquoNodeDriverzN Implements the :class:`NodeDriver`'s for the Abiquo Compute Provider ZAbiquozhttp://www.abiquo.com/i� z*application/vnd.abiquo.virtualmachines+xmlz)application/vnd.abiquo.virtualmachine+xmlz,application/vnd.abiquo.virtualappliances+xmlz+application/vnd.abiquo.virtualappliance+xmlz-application/vnd.abiquo.virtualmachinetask+xmlz application/vnd.abiquo.user+xmlz%application/vnd.abiquo.enterprise+xmlz-application/vnd.abiquo.virtualdatacenters+xmlz,application/vnd.abiquo.virtualdatacenter+xmlz&application/vnd.abiquo.datacenters+xmlz2application/vnd.abiquo.virtualmachinetemplates+xmlz1application/vnd.abiquo.virtualmachinetemplate+xmlz application/vnd.abiquo.nics+xmlz1application/vnd.abiquo.datacenterrepositories+xmlz/application/vnd.abiquo.datacenterrepository+xmlz*application/vnd.abiquo.acceptedrequest+xmli @c s4 || _ tt| �jf ||dddd�|�� | �� dS )a� Initializes Abiquo Driver Initializes the :class:`NodeDriver` object and populate the cache. :param user_id: identifier of Abiquo user (required) :type user_id: ``str`` :param secret: password of the Abiquo user (required) :type secret: ``str`` :param endpoint: Abiquo API endpoint (required) :type endpoint: ``str`` that can be parsed as URL FN)�key�secret�secure�host�port)�endpoint�superr �__init__�ex_populate_cache)�selfZuser_idr r �kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/abiquo.pyr A s ��zAbiquoNodeDriver.__init__Nc C sn | j ||d�\}}| �|||�}| j||||d�} | �| � t| d�} d| ji} | jj| | d�j} | � | | �S )a? Create a new node instance in Abiquo All the :class:`Node`s need to be defined inside a VirtualAppliance (called :class:`NodeGroup` here). If there is no group name defined, 'libcloud' name will be used instead. This method wraps these Abiquo actions: 1. Create a group if it does not exist. 2. Register a new node in the group. 3. Deploy the node and boot it. 4. Retrieves it again to get schedule-time attributes (such as ips and vnc ports). The rest of the driver methods has been created in a way that, if any of these actions fail, the user can not reach an inconsistent state :keyword name: The name for this new node (required) :type name: ``str`` :keyword size: The size of resources allocated to this node. :type size: :class:`NodeSize` :keyword image: OS Image to boot on node. (required) :type image: :class:`NodeImage` :keyword location: Which data center to create a node in. If empty, undefined behavior will be selected. (optional) :type location: :class:`NodeLocation` :keyword ex_group_name: Which group this node belongs to. If empty, it will be created into 'libcloud' group. If it does not found any group in the target location (random location if you have not set the parameter), then it will create a new group with this name. :type ex_group_name: c{str} :return: The newly created node. :rtype: :class:`Node` )�image�location)�name�sizer �edit�Accept��headers) � _define_create_node_location�_define_create_node_group�_define_create_node_node�_deploy_remoter �NODE_MIME_TYPE� connection�request�object�_to_node) r r r r! r Z ex_group_name�xml_loc�loc�group�vm�edit_vmr% r r r � create_nodeT s 0� � z AbiquoNodeDriver.create_nodec C s� d| j i}| jj|jd |d�j}|�d�}|dv r>td| ��|dkr�t�d�}t� |d �}d |_ |jd d }| j | j d �}| jj |d t|�|d�}|dks�|�� r�| jj|jd dd� dS dS dS )aC Destroy a node Depending on the provider, this may destroy all data associated with the node, including backups. :param node: The node to be destroyed :type node: :class:`Node` :return: True if the destroy was successful, otherwise False :rtype: ``bool`` r# �uri_idr$ �state)Z ALLOCATEDZ CONFIGURED�LOCKED�UNKNOWN�Invalid Node state� NOT_ALLOCATED�virtualmachinetask� forceUndeploy�True�/action/undeploy�r# z Content-type�POST��action�method�datar% �DELETE�rB rC TFN)r* r+ r, �extrar- �findtextr r �Element� SubElement�text� AR_MIME_TYPE�VM_TASK_MIME_TYPE� async_requestr � async_success) r �noder% �e_vmr6 �vm_task�force_undeployZ destroy_uri�resr r r � destroy_node� s4 � ���z AbiquoNodeDriver.destroy_nodec C sl | j �|jd �j}|�d�}|dkr0td| ��| �|� t|d�}d| ji}| j j||d�j}| � || �S )a� Runs a node Here there is a bit difference between Abiquo states and libcloud states, so this method is created to have better compatibility. In libcloud, if the node is not running, then it does not exist (avoiding UNKNOWN and temporal states). In Abiquo, you can define a node, and then deploy it. If the node is in :class:`NodeState.TERMINATED` libcloud's state and in 'NOT_DEPLOYED' Abiquo state, there is a way to run and recover it for libcloud using this method. There is no way to reach this state if you are using only libcloud, but you may have used another Abiquo client and now you want to recover your node to be used by libcloud. :param node: The node to run :type node: :class:`Node` :return: The node itself, but with the new state :rtype: :class:`Node` r5 r6 r: r9 r" r# r$ ) r+ r, rG r- rH r r) r r* r. )r rP rQ r6 r3 r% r r r � ex_run_node� s z AbiquoNodeDriver.ex_run_nodec C s d| j i}| jjd|d�j}|| jjd< t| jjd d�}d| ji}| jj||d�j}|| jjd< d| ji}d}| jj||d�j}d| �� i} d| j i} | jjd| | d �j} i } | � d �D ]} t| d �}| | |< q�i | jjd < |� d �D ],}t|d�}|dur�t|d�| jjd |< q�dS )a� Populate the cache. For each connection, it is good to store some objects that will be useful for further requests, such as the 'user' and the 'enterprise' objects. Executes the 'login' resource after setting the connection parameters and, if the execution is successful, it sets the 'user' object into cache. After that, it also requests for the 'enterprise' and 'locations' data. List of locations should remain the same for a single libcloud connection. However, this method is public and you are able to refresh the list of locations any time. r# z/loginr$ �user� enterprisez/cloud/virtualdatacentersZ idEnterprisez/admin/datacenters)r% �params� datacenterr � locationsZvirtualDatacenterr Nr" ) �USER_MIME_TYPEr+ r, r- �cacher � ENT_MIME_TYPE�VDCS_MIME_TYPE�_get_enterprise_id� DCS_MIME_TYPE�findall)r Z user_headersrW Ze_entZ ent_headersZentZ vdcs_headersZuri_vdcsZe_vdcsrY Z dcs_headersZe_dcsZdc_dict�dcr �e_vdcr0 r r r r � s: � � �z"AbiquoNodeDriver.ex_populate_cachec C s� t �d�}t �|d�}||_|du r2| �� d }n|| �� vrFtd��| jjd | }d| ji}| jj ||d�j }t |d �}| j | j d �} | jj |t |�| d d �j }t |d �} t| |�d�| d�S )a� Create an empty group. You can specify the location as well. :param group: name of the group (required) :type group: ``str`` :param location: location were to create the group :type location: :class:`NodeLocation` :returns: the created group :rtype: :class:`NodeGroup` �virtualAppliancer Nr �Location does not existr[ r# r$ �virtualappliancesr? r@ �rD r% rC r" ��uri)r rI rJ rK �list_locationsr r+ r] � VDC_MIME_TYPEr, r- r �VAPP_MIME_TYPEr � NodeGrouprH ) r r r �vappZ vapp_name�link_vdc�hdr_vdcrd Z creation_linkr% �uri_vappr r r �ex_create_group" s* �� �z AbiquoNodeDriver.ex_create_groupc C s� | j �|j�j}|�d�}|dvr0d}t|| ��|dkr�t�d�}t�|d�}d|_ |jd }| j | j d �}| j j |d t |�|d �} |d ks�| �� r�| j j|jd d� dS dS dS )a� Destroy a group. Be careful! Destroying a group means destroying all the :class:`Node` instances there and the group itself! If there is currently any action over any :class:`Node` of the :class:`NodeGroup`, then the method will raise an exception. :param name: The group (required) :type name: :class:`NodeGroup` :return: If the group was destroyed successfully :rtype: ``bool`` r6 )� NOT_DEPLOYED�DEPLOYEDz.Can not destroy group because of current stateru r; r< r= r> r? r@ rA rt rE rF TFN)r+ r, rj r- rH r r rI rJ rK rL rM rN r rO ) r r1 Ze_groupr6 �errorrR rS Z undeploy_urir% rT r r r �ex_destroy_groupJ s0 �� �z!AbiquoNodeDriver.ex_destroy_groupc C s� g }| � |�D ]�}| jjd | }d| ji}| jj||d�j}t|d�}d| ji}| jj||d�j} | �d�D ]t} g } t| d�} d| j i} | jj| | d�j}|�d�D ]}| � | � || �� q�t | | � d�| t| d ��}|� |� qnq|S ) z� List all groups. :param location: filter the groups by location (optional) :type location: a :class:`NodeLocation` instance. :return: the list of :class:`NodeGroup` r[ r# r$ rg re Zvirtualmachines�virtualMachiner r" )�_get_locationsr+ r] rl r, r- r �VAPPS_MIME_TYPErb �NODES_MIME_TYPE�appendr. rn rH )r r �groups�vdcrp rq rd Z apps_linkZ hdr_vappsZvappsro �nodesZvms_linkr% Zvmsr2 r1 r r r �ex_list_groups{ s, � �z AbiquoNodeDriver.ex_list_groupsc C s4 | � � }d| }d| ji}| jj||d�j}g }|�d�D ]�}| �|�D ]�}| jjd | } d| ji} | jj| | d�j} t | d�} t |d�} | � d�d | � d�d krHt |d �}| � d �}d |i}d| j i}| jj|||d�j}|�d �D ]>}|� d�}dd� |D �}||vr�|� | �|| t |d��� q�qHq:|S )a List images on Abiquo Repositories :keyword location: The location to list images for. :type location: :class:`NodeLocation` :return: list of node image objects :rtype: ``list`` of :class:`NodeImage` z-/admin/enterprises/%s/datacenterrepositories/r# r$ ZdatacenterRepositoryr[ r rZ �/���ZvirtualmachinetemplatesZhypervisorTypeZhypervisorTypeNameZvirtualMachineTemplate�idc S s g | ] }|j �qS r )r� )�.0r r r r � <listcomp>� � z0AbiquoNodeDriver.list_images.<locals>.<listcomp>r" )r` �DCRS_MIME_TYPEr+ r, r- rb ry r] rl r �splitrH �VMTPLS_MIME_TYPEr| � _to_nodeimage)r r Z enterprise_idrj Z repos_hdrZreposZimages�repor~ rp rq rd Z dc_link_vdcZ dc_link_repoZ url_templatesZhypervisor_typerY r% Z templatesZtemplZ id_templateZidsr r r � list_images� s@ � � �� z AbiquoNodeDriver.list_imagesc C s t | jjd �� �S )z� Return list of locations where the user has access to. :return: the list of :class:`NodeLocation` available for the current user :rtype: ``list`` of :class:`NodeLocation` r[ )�listr+ r] �keys�r r r r rk � s z AbiquoNodeDriver.list_locationsc C s$ g }| � |�D ]}|�|j� q|S )z� List all nodes. :param location: Filter the groups by location (optional) :type location: a :class:`NodeLocation` instance. :return: List of node objects :rtype: ``list`` of :class:`Node` )r� �extendr )r r r r1 r r r � list_nodes� s zAbiquoNodeDriver.list_nodesc C sT t dddddd| d�t ddd d dd| d�t d d d ddd| d�t dddddd| d�gS )aG List sizes on a provider. Abiquo does not work with sizes. However, this method returns a list of predefined ones (copied from :class:`DummyNodeDriver` but without price neither bandwidth) to help the users to create their own. If you call the method :class:`AbiquoNodeDriver.create_node` with the size informed, it will just override the 'ram' value of the 'image' template. So it is no too much usefull work with sizes... :return: The list of sizes :rtype: ``list`` of :class:`NodeSizes` � ZSmall� � N)r� r �ramZdisk� bandwidthZprice�driver� ZMediumi � � ZBigi � zXXL Bigi )r )r r r r r � list_sizes� sB �����zAbiquoNodeDriver.list_sizesc C s2 |j d d }d| ji}| jj|d|d�}|�� S )z� Reboot a node. :param node: The node to be rebooted :type node: :class:`Node` :return: True if the reboot was successful, otherwise False :rtype: ``bool`` r5 z /action/resetr# r@ )rB rC r% )rG rL r+ rN rO )r rP Z reboot_uriZ reboot_hdrrT r r r � reboot_node s �z AbiquoNodeDriver.reboot_nodec C s d| j iS )a Set the endpoint as an extra :class:`AbiquoConnection` argument. According to Connection code, the "url" argument should be parsed properly to connection. :return: ``dict`` of :class:`AbiquoConnection` input arguments �url)r r� r r r �_ex_connection_class_kwargs' s z,AbiquoNodeDriver._ex_connection_class_kwargsc C sb t �d�}t �|d�}d|_| j| jd�}t|d�}| jj|dt |�|d�}|� � s^t d| ��d S ) z7 Asynchronous call to create the node. r; ZforceEnterpriseSoftLimitsr= r? Zdeployr@ rA zCould not run the nodeN) r rI rJ rK rL rM r r+ rN r rO r )r rQ rR Z force_deployr% Z link_deployrT r r r r) 3 s � �z AbiquoNodeDriver._deploy_remotec C s, |� d�}|� d�}|� d�}t||||�S )z< Generates the :class:`NodeLocation` class. r� r )rH r )r r~ rc r� � identifierr Zcountryr r r � _to_locationI s z AbiquoNodeDriver._to_locationc C s8 |� d�}|� d�}tj|� d� }t|d�}d| ji}| jj||d�j}t|d�} | �|| | �} g } g } d| j i} | jjt|d�| d�j}|� d �D ]N}|� d �}|� d �D ]4}|j d }|d kr�| � |� q�|dv r�| � |� q�q�dt|d�i}|� d�du�r |� d�|d< |� d�|d< t|||| | || |d�S )z4 Generates the :class:`Node` class. r� �labelr6 �virtualmachinetemplater# r$ ZdatacenterrepositoryZnics�nic�ip�link�relZprivatenetwork)Z publicnetworkZexternalnetworkZunmanagednetworkr5 r" ZvdrpIpNZvdrpIPZvdrp_ipZvdrpPortZ vdrp_port)r rG )rH r ZNODE_STATE_MAPr �VMTPL_MIME_TYPEr+ r, r- r� �NICS_MIME_TYPErb �attribr| �findr )r r2 r� r� r r6 Z link_imageZlink_hdrZ image_elementZ repo_linkr Z private_ipsZ public_ipsZnics_hdrZ nics_elementr� r� r� r� rG r r r r. R s> � � �zAbiquoNodeDriver._to_nodec C sB |� d�}|� d�}t|d�}|� d�}|||d�}t||||�S )z9 Generates the :class:`NodeImage` class. r� r r" Z hdRequired)r� r� Z hdrequired)rH r r ) r �templater� r� r� r r� ZhdreqdrG r r r r� z s z AbiquoNodeDriver._to_nodeimagec c s( |dur|V n| � � D ] }|V qdS )z7 Returns the locations as a generator. N)rk )r r r0 r r r ry � s z AbiquoNodeDriver._get_locationsc C s | j jd �d�S )zI Returns the identifier of the logged user's enterprise. rX r� )r+ r] rH r� r r r r` � s z#AbiquoNodeDriver._get_enterprise_idc C s� |sd}t || ��|r*|| �� vr*t d��d}d}| �|�D ]X}| jjd | }d| ji}| jj||d�j} | �|�D ] } | j |j krv| }|} q<qvq<|du r�d}t || ��||fS )z� Search for a location where to create the node. Based on 'create_node' **kwargs argument, decide in which location will be created. z 'image' parameter is mandatoryrf Nr[ r# r$ z)The image can not be used in any location) r rk ry r+ r] rl r, r- r� r� ) r r r rv r0 Z target_locZ candidate_locrp rq rd Zimgr r r r& � s* z-AbiquoNodeDriver._define_create_node_locationc C s� |s t j}t|d�}d| ji}| jj||d�j}d}|�d�D ]4}|�d�|kr>t|d�} t | |�d�| d� S q>|du r�| � ||�S dS ) z� Search for a group where to create the node. If we can not find any group, create it into argument 'location' rg r# r$ Nre r r" ri ) rn �DEFAULT_GROUP_NAMEr rz r+ r, r- rb rH rs ) r r/ r0 � group_nameZ groups_linkZ groups_hdrZ vapps_elementZ target_groupro rr r r r r' � s � z*AbiquoNodeDriver._define_create_node_groupc C s� t �d�}|r t �|d�}||_| jd|jd d�}t j|d|d� | j| jd�}|rnt �|d �} t|j�| _|j d } | j j | t |�|d d �j }t|d �} d| ji}| j j | |d�j S )z� Defines the node before to create. In Abiquo, you first need to 'register' or 'define' the node in the API before to create it into the target hypervisor. rx r� r� r� )�typer� �hrefr� )r� r? r� z/virtualmachinesr@ rh r" r# r$ )r rI rJ rK r� rG r* �strr� rj r+ r, r r- r ) r r1 r r! r r2 Zvmnamer� r% r� Z nodes_linkr3 r r r r( � s, �� � z)AbiquoNodeDriver._define_create_node_node)NNNN)N)N)N)N)N)N)N)NNN)5�__name__� __module__� __qualname__�__doc__r ZABIQUOr� r Zwebsiter Z connectionCls�timeoutr{ r* rz rm rM r\ r^ r_ rl ra r� r� r� r� Z DCR_MIME_TYPErL ZGIGABYTEr r4 rU rV r rs rw r� r� rk r� r� r� r� r) r� r. r� ry r` r& r' r( � __classcell__r r r r r ! sd � C.+2 (1 / / ( % �r c @ s4 e Zd ZdZdZeg dfdd�Zdd� Zdd � Zd S ) rn a� Group of virtual machines that can be managed together All :class:`Node`s in Abiquo must be defined inside a Virtual Appliance. We offer a way to handle virtual appliances (called NodeGroup to maintain some kind of name conventions here) inside the :class:`AbiquoNodeDriver` without breaking compatibility of the rest of libcloud API. If the user does not want to handle groups, all the virtual machines will be created inside a group named 'libcloud' Zlibcloud� c C s || _ || _|| _|| _dS )z0 Initialize a new group object. N)r� r r rj )r r� r r rj r r r r s zNodeGroup.__init__c C s d| j d�tt| j��f S )Nz!<NodeGroup: name=%s, nodes=[%s] >�,)r �join�mapr� r r� r r r �__repr__ s �zNodeGroup.__repr__c C s | j �| �S )zc Destroys the group delegating the execution to :class:`AbiquoNodeDriver`. )r� rw r� r r r �destroy s zNodeGroup.destroyN)r� r� r� r� r� r r� r� r r r r rn � s rn N)r� Zlibcloud.utils.py3r Zlibcloud.compute.baser r Zlibcloud.compute.typesr r Zlibcloud.common.abiquor r r r r r r r r- rn r r r r �<module> s Z
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка