Viewing: cloudstack.cpython-36.pyc
3 �N�b�E � @ s� d Z ddlZddlZddljZddlZddlZddlT ddl m Z ddl m Z ddl mZ y<ddlmZ eej�ed�k r�ddlZejjjd � d ZW n ek r� d ZY nX eje�Z e e e � �Z e e e � �Z e e e � �Z e e!e � �Z!e e"e � �Z"e e#e � �Z#e e$e � �Z$e e%e � �Z%e e&e � �Z&e e'e � �Z'e e(e � �Z(d Z)d d� Z*dd� Z+dd� Z,dd� Z-dd� Z.dd� Z/dd� Z0dd � Z1d d � Z2d d � Z3d!d"� Z4d#d$� Z5d%d&� Z6d'd(� Z7d/d)d*�Z8d+d,� Z9d-d.� Z:dS )0a� CloudStack Cloud Module ======================= The CloudStack cloud module is used to control access to a CloudStack based Public Cloud. :depends: libcloud >= 0.15 Use of this module requires the ``apikey``, ``secretkey``, ``host`` and ``path`` parameters. .. code-block:: yaml my-cloudstack-cloud-config: apikey: <your api key > secretkey: <your secret key > host: localhost path: /client/api driver: cloudstack � N)�*)�SaltCloudSystemExit)�namespaced_function)� LooseVersion)�CloudStackNetworkz1.4.0z/etc/ssl/certs/YaST-CA.pemTF� cloudstackc C s t � dkrdS t� dkr dS tS )zP Set up the libcloud functions and check for CloudStack configurations. F)�get_configured_provider�get_dependencies�__virtualname__� r r � /usr/lib/python3.6/cloudstack.py� __virtual__K s r c C s" yt j� S tk r t S X d S )N)Z__active_provider_name__�value�AttributeErrorr r r r �_get_active_provider_nameX s r c C s t jtt� ptd�S )z/ Return the first configured instance. �apikey� secretkey�host�path)r r r r )�configZis_provider_configured�__opts__r r r r r r r _ s r c C s t jtdti�S )z* Warn if dependencies aren't met. �libcloud)r Zcheck_driver_dependenciesr �HAS_LIBSr r r r r j s r c C s� t tj�} tjdt� tddd�}|dkr^yddl}d|j_ W n t t fk r\ t d��Y nX | tjdt� tdd �tjd t� tdd �tjd t� tddd�tjd t� tdd �tjd t� tdd �tjdt� tddd�d�S )z5 Return a conn object for the passed VM data �verify_ssl_certTF)�default� search_globalr NzCCould not disable SSL certificate verification. Not loading module.r )r r �securer r �port)�keyZsecretr r r r ) Z get_driverZProviderZ CLOUDSTACKr �get_cloud_config_valuer r �libcloud.security�securityZVERIFY_SSL_CERT� ImportErrorr r )�driverr r r r r �get_connq sF r$ c C sL | j � }tjd|tdd�}x,|D ]$}t|�t|j�t|j�fkr |S q W dS )z) Return the node location to use �location� )r N)Zlist_locationsr r r �str�id�name)�conn�vm_Z locations�locr% r r r � get_location� s r- c C s2 t jd|tdd�}|r*t jd|tdgd�S dS dS )zL Return a list of security groups to use, defaulting to ['default'] �securitygroup_enabledT)r Z securitygroupr FN)r r r )r* r+ r. r r r �get_security_groups� s r/ c C s" t jd| tt jd| tdd�dd�S )z$ Return the password to use �passwordZpasswdF)r )r r )r r r )r+ r r r � get_password� s r1 c C s t jdt� tdd�S )z3 Returns the ssh private key for VM access Z private_keyF)r )r r r r r r r r �get_key� s r2 c C s t jd| t�}|r|S dS dS )z# Return the keypair to use �keypairFN)r r r )r+ r3 r r r � get_keypair� s r4 c C s2 y| j d }W n tk r, | jd }Y nX |S )z� Return the IP address of the VM If the VM has public IP as defined by libcloud module then use it Otherwise try to extract the private IP and use that one. r )� public_ips� ExceptionZ private_ips)�dataZipr r r �get_ip� s r8 c C s" t jd| t�}|dk r|S dS dS )zC Return the networkid to use, only valid for Advanced Zone � networkidNF)r r r )r+ r9 r r r � get_networkid� s r: c C s� y | j � }W n tk r* tjd� dS X tjd|t�}|sBdS x,|D ]$}t|�t|j�t|j �fkrH|S qHW tjd|� dS )z$ Return the project to use. zECannot get projects, you may need to update libcloud to 0.15 or laterFZ projectidz$Couldn't find project %s in projects) Zex_list_projectsr �logZwarningr r r r' r( r) )r* r+ ZprojectsZprojid�projectr r r � get_project� s r= c ) C s< y0| d r.t jtt� pd| d | d�dkr.dS W n tk rD Y nX td dddj| d �td td d | d dd dg�td d� tjd| d � t � }| d t || �t || �t || �d�}t || �}|dk r�||d< t| �dk r�t| �|d< t| �dk �r&t| �|d< tddd|d dd�f|d< t|| �dk �rDt|| �|d< |j� }|d j|d< |d j|d< td ddd j| d �td d td d |d dd dddg�itd d� t| �}|�r�||d < n |d |d < i }t| �}|�r�x�|D ]�}d |k�rd!j| d t|��|d < td dd"d j|d �td d |d |d# |d$ d%�id&� y |j|d$ |d �||d# < W n: tk �r� } z tjd'|d | tjd(� dS d} ~ X nX �q�W ni }y|j f |�} W n: tk �r� } z tjd)| d | tjd(� dS d} ~ X nX xj|D ]b} y|j | || | � W nD tk �rd } z&tjd*|j d d+�| tj tj�d,� dS d} ~ X nX �qW t j d-| td.d/�} t!| �| d0< | j"d1 | d1< t#� | d2< td3 | t�} | j$| j%� d1| j"k�r�| j"d1= tjd4| d � tj&d5| d t'j(| j%�� td dd6d7j| d �td td d8| d dd dg�td d� | S )9z- Create a single VM from a data dict Zprofiler )r+ Fzcloud.fire_event�eventzstarting createzsalt/cloud/{}/creatingr) �sock_dirzcloud.filter_eventZcreatingZproviderr# � transport)r? �argsr@ zCreating Cloud VM %s)r) �image�sizer% Zex_security_groupsZ ex_keynameZ networkidsNZnetworksr< rB rC zrequesting instancezsalt/cloud/{}/requesting�kwargsZ requestingZex_displaynameZ VirtualNamez{}-{}zrequesting volumeZ DeviceNameZ VolumeSize)r) ZdevicerC )r? rA z~Error creating volume %s on CLOUDSTACK The following exception was thrown by libcloud when trying to requesting a volume: %s)Zexc_info_on_loglevelz~Error creating %s on CLOUDSTACK The following exception was thrown by libcloud when trying to run the initial deployment: %sz{Error attaching volume %s on CLOUDSTACK The following exception was thrown by libcloud when trying to attach a volume: %sZUNKNOWN)�exc_info� ssh_username�root)r Zssh_hostr0 Z key_filenamezcloud.bootstrapzCreated Cloud VM '%s'z '%s' VM creation details: %szcreated instancezsalt/cloud/{}/createdZcreated))r Zis_profile_configuredr r r � __utils__�formatr; �infor$ � get_image�get_sizer- r/ r4 r: r r= �copyr) �cloudstack_displayname�block_device_mappings�lenZ create_volumer6 �error�logging�DEBUGZ create_nodeZ attach_volume�getZ isEnabledForr r8 �extrar2 �update�__dict__�debug�pprintZpformat)r+ r* rD ZsgZ event_dataZ displayname�volumesZex_blockdevicemappingsZex_blockdevicemapping�excr7 Z device_namerF �retr r r �create s� r] c C s\ |dkrt d��td dddj| �td d| id � |s>t� }t|| �}|d kr\tjd | � |j|�}|d krztjd | � �xH|D �]>}|j d dkr�tj d|j d |j � q�tj d|j � td dddj|j �td d|j id � |j |��stjd|j � dS tj d|j � td dddj|j �td d|j id � tj d|j � td dddj|j �td d|j id � |j |��s�tjd|j � dS tj d|j � td dd d j|j �td d|j id � q�W tj d | � |j|�}|�s�tjd | � dS tj d | � tjjjd!td �}td dd"d j| �td d| id � td# d$k�rXtjjj|jd% � d$S )&z4 Delete a single VM, and all of its volumes ZfunctionzEThe destroy action must be called with -d, --destroy, -a or --action.zcloud.fire_eventr> zdestroying instancezsalt/cloud/{}/destroyingr? r) )r? rA NzUnable to find the VM %sz#Unable to find volumes of the VM %sZ volume_typeZDATADISKzIgnoring volume type %s: %szDetaching volume: %szdetaching volumezsalt/cloud/{}/detachingzFailed to Detach volume: %sFzDetached volume: %szdetached volumezsalt/cloud/{}/detachedzDestroying volume: %szdestroying volumez Failed to Destroy volume: %szDestroyed volume: %szdestroyed volumezsalt/cloud/{}/destroyedzDestroying VM: %szFailed to Destroy VM: %szDestroyed VM: %sZmasterzdestroyed instanceZdelete_sshkeysTr )r rH rI r r$ �get_noder; rQ Z list_volumesrU rJ r) Z detach_volumeZdestroy_volumeZ destroy_node�saltZutilsr> Z SaltEventZcloudZ remove_sshkeyr5 )r) r* ZcallZnoderZ Zvolumer\ r> r r r �destroy� s� r` c C s t jd| tdd�S )z� Return the block device mapping: :: [{'DeviceName': '/dev/sdb', 'VirtualName': 'ephemeral0'}, {'DeviceName': '/dev/sdc', 'VirtualName': 'ephemeral1'}] rO T)r )r r r )r+ r r r rO , s rO c C s t jd| tdd�S )z> Return display name of VM: :: "minion1" rN T)r )r r r )r+ r r r rN : s rN )NN);�__doc__rR rY Z salt.configr Zsalt.utils.cloudr_ Zsalt.utils.eventZsalt.cloud.libcloudfuncsZsalt.exceptionsr Zsalt.utils.functoolsr Zsalt.utils.versionsr Z _LooseVersionZ#libcloud.compute.drivers.cloudstackr r � __version__r r! Z CA_CERTS_PATH�appendr r" Z getLogger�__name__r; r^ �globalsrL rK Zavail_locationsZ avail_imagesZ avail_sizesZscriptZ list_nodesZlist_nodes_fullZlist_nodes_selectZ show_instancer r r r r r$ r- r/ r1 r2 r4 r8 r: r= r] r` rO rN r r r r �<module> s` 6 9 \
Return