File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/azure_arm.cpython-310.pyc
Back
o ;j@Q � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZm Z m Z ddl m Z ddl mZmZmZmZmZmZmZmZmZ ddlmZmZmZ ddlm Z dd l m Z dd l m Z dd l!m"Z" dd l#m$Z$ d Z%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.d Z/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8G dd� de�Z9G dd� de�Z:G d d � d e�Z;G d d � d �Z<G d d!� d!�Z=G d"d#� d#�Z>G d$d%� d%�Z?G d&d'� d'�Z@G d(d)� d)�ZAG d*d+� d+e�ZBd,d-� ZCdS ).z� Driver for Microsoft Azure Resource Manager (ARM) Virtual Machines provider. http://azure.microsoft.com/en-us/services/virtual-machines/ � N)�iso8601)�parse_qs�urlparse� basestring)� LibcloudError) �Node�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume�NodeAuthSSHKey�VolumeSnapshot�NodeAuthPassword)� NodeState�StorageVolumeState�VolumeSnapshotState)�ObjectDoesNotExistError)�!AzureResourceManagementConnection)� BaseHTTPError)�Provider)�AzureBlobsStorageDriverz2016-04-30-previewz 2023-01-02z 2015-06-15z 2019-06-01z 2015-01-01z 2018-06-01z 2016-09-01z2016-08-31-previewz2015-05-01-previewz 2021-11-01i, c �( e Zd ZdZ� fdd�Zdd� Z� ZS )� AzureImagezCRepresents a Marketplace node image that an Azure VM can boot from.c sb || _ || _|| _|| _|| _d�| j | j| j| j�}d�| j | j| j| j�}t� �|||� d S )Nz {}:{}:{}:{}z {} {} {} {})� publisher�offer�sku�version�location�format�super�__init__) �selfr r r r r �driver�urn�name�� __class__� �V/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/azure_arm.pyr! Q s zAzureImage.__init__c C � d| j | j| jf S )Nz)<AzureImage: id=%s, name=%s, location=%s>��idr% r �r" r( r( r) �__repr__[ � �zAzureImage.__repr__��__name__� __module__� __qualname__�__doc__r! r. � __classcell__r( r( r& r) r N s r c r )� AzureVhdImagez;Represents a VHD node image that an Azure VM can boot from.c s( d� ||jj||�}t� �|||� d S )Nzhttps://{}.blob{}/{}/{})r � connection�storage_suffixr r! )r" �storage_account�blob_containerr% r# r$ r& r( r) r! f s �zAzureVhdImage.__init__c C � d| j | jf S )Nz <AzureVhdImage: id=%s, name=%s>�r, r% r- r( r( r) r. o � zAzureVhdImage.__repr__r0 r( r( r& r) r6 c s r6 c r )�AzureComputeGalleryImagezBRepresents a Compute Gallery image that an Azure VM can boot from.c s$ d||||f }t � �|||� d S )NzV/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Compute/galleries/%s/images/%s)r r! )r" �subscription_id�resource_groupZgalleryr% r# r, r& r( r) r! v s ��� z!AzureComputeGalleryImage.__init__c C r; )Nz*<AzureComputeGalleryImage: id=%s, name=%s>r< r- r( r( r) r. � r= z!AzureComputeGalleryImage.__repr__r0 r( r( r& r) r> s s r> c @ � e Zd ZdZdd� Zdd� ZdS )�AzureResourceGroupz"Represent an Azure resource group.c C � || _ || _|| _|| _d S �N�r, r% r �extra�r" r, r% r rF r( r( r) r! � � zAzureResourceGroup.__init__c C r* )Nz5<AzureResourceGroup: id=%s, name=%s, location=%s ...>r+ r- r( r( r) r. � r/ zAzureResourceGroup.__repr__N�r1 r2 r3 r4 r! r. r( r( r( r) rB � � rB c @ rA )�AzureNetworkSecurityGroupz*Represent an Azure network security group.c C rC rD rE rG r( r( r) r! � rH z"AzureNetworkSecurityGroup.__init__c C r* )Nz<<AzureNetworkSecurityGroup: id=%s, name=%s, location=%s ...>r+ r- r( r( r) r. � r/ z"AzureNetworkSecurityGroup.__repr__NrI r( r( r( r) rK � rJ rK c @ rA )� AzureNetworkz#Represent an Azure virtual network.c C rC rD rE rG r( r( r) r! � rH zAzureNetwork.__init__c C r* )Nz/<AzureNetwork: id=%s, name=%s, location=%s ...>r+ r- r( r( r) r. � r/ zAzureNetwork.__repr__NrI r( r( r( r) rL � rJ rL c @ rA )� AzureSubnetz0Represents a subnet of an Azure virtual network.c C � || _ || _|| _d S rD �r, r% rF �r" r, r% rF r( r( r) r! � � zAzureSubnet.__init__c C r; )Nz!<AzureSubnet: id=%s, name=%s ...>r< r- r( r( r) r. � r= zAzureSubnet.__repr__NrI r( r( r( r) rM � � rM c @ rA )�AzureNicz?Represents an Azure virtual network interface controller (NIC).c C rC rD rE rG r( r( r) r! � rH zAzureNic.__init__c C r; )Nz <AzureNic: id=%s, name=%s ...>r< r- r( r( r) r. � r= zAzureNic.__repr__NrI r( r( r( r) rS � rJ rS c @ rA )�AzureIPAddressz/Represents an Azure public IP address resource.c C rN rD rO rP r( r( r) r! � rQ zAzureIPAddress.__init__c C r; )Nz$<AzureIPAddress: id=%s, name=%s ...>r< r- r( r( r) r. � r= zAzureIPAddress.__repr__NrI r( r( r( r) rT � rR rT c sZ e Zd ZdZeZdZdZej Z dddgiZ i dd�d d �d d �d d�d d �dd�dd�dd�dd�dd�dd�dd�d d �d d �d d!�d"d#�d$d%�Z e je je je jd&�Z ' ( ( ( (d�� fd)d*� Zd+d,� Zd�d-d.�Z ( ( ( ( (d�d/d0�Zd�d1d2�Zd�d3d4�Zd(d5d(d6d(d(d(i d7d8d(d9d8f d:d;�Zd<d=� Z ' ' > > 'd�d?d@�Z ( ( ( ( ( ( ( (d�dAdB�Z d�dCdD�Z ( ( 8d�dEdF�Z dGdH� Z d�dIdJ�Z dKdL� Z! (d�dMdN�Z"dOdP� Z#d�dQdR�Z$dSdT� Z%d�dUdV�Z&d�dWdX�Z'dYdZ� Z(d�d^d_�Z)d�d`da�Z*dbdc� Z+ddde� Z,dfdg� Z-dhdi� Z.djdk� Z/d�dldm�Z0d�dndo�Z1dpdq� Z2drds� Z3d�dtdu�Z4dvdw� Z5dxdy� Z6dzd{� Z7d|d}� Z8d~d� Z9d�d�� Z:d�d�� Z;d�d�� Z<d�d�� Z=d�d�� Z> (d�d�d��Z?d�d�� Z@ (d�d�d��ZAd�d�d��ZBd�d�� ZCd�d�� ZDd�d�d��ZEd�d�� ZFd�d�d��ZGd�d�� ZHd�d�� ZIg d�d(d(d(fd�d��ZJd�d�� ZK� fd�d��ZLd�d�� ZMd�d�d��ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZR 5d�d�d��ZS� ZTS )��AzureNodeDriverz/Compute node driver for Azure Resource Manager.zAzure Virtual machinesz;http://azure.microsoft.com/en-us/services/virtual-machines/� create_nodeZssh_key�passwordZ centralusz Iowa, USAZeastusz Virginia, USAZeastus2Z usgoviowaZ usgovvirginiaZnorthcentralusz Illinois, USAZsouthcentralusz Texas, USAZwestuszCalifornia, USAZ northeuropeZIrelandZ westeuropeZ NetherlandsZeastasiaz Hong KongZ southeastasiaZ SingaporeZ japaneastz Tokyo, JapanZ japanwestz Osaka, JapanZ brazilsouthzSao Paulo State, BrazilZ australiaeastzNew South Wales, AustraliaZaustraliasoutheastzVictoria, Australia)�creating�updating� succeeded�failedTNc s� || _ || _| �d�| _t� jd||||||| d�| �� | jd ur<| j�� �dd�} | j �| �} t | | j| | �| _ d S d | _ d S )N�cloud_environment)�key�secret�secure�host�port� api_version�region� � r( ) � tenant_idr? �getr\ r r! rc �lower�replace�_location_to_countryr �default_location) r" rf r? r] r^ r_ r` ra rb rc �kwargs�loc_idZcountryr& r( r) r! s& �� zAzureNodeDriver.__init__c sX d� j }� jj|dtid�}|jd D ]}|d dkr)� fdd�|d D � S qg S ) z� List data centers available with the current subscription. :return: list of node location objects :rtype: ``list`` of :class:`.NodeLocation` z-/subscriptions/%s/providers/Microsoft.Compute� api-version��paramsZ resourceTypesZ resourceTypeZvirtualMachinesc � g | ]}� � |��qS r( )� _to_location)�.0r r- r( r) � <listcomp>3 � z2AzureNodeDriver.list_locations.<locals>.<listcomp>� locations)r? r7 �request�LOCATIONS_API_VERSION�object)r" �action�rZrtr( r- r) �list_locations& s �z AzureNodeDriver.list_locationsc sZ |du r� j r � j }ntd��d� j|jf }� jj|dtid�}� fdd�|jd D �S ) a< List available VM sizes. :param location: The location at which to list sizes (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :return: list of node size objects :rtype: ``list`` of :class:`.NodeSize` N�location is required.zB/subscriptions/%s/providers/Microsoft.Compute/locations/%s/vmSizesrn ro c rq r( )� _to_node_size)rs �dr- r( r) rt M ru z.AzureNodeDriver.list_sizes.<locals>.<listcomp>�value)rk � ValueErrorr? r, r7 rw �VM_SIZE_API_VERSIONry �r" r rz r{ r( r- r) � list_sizes7 s �zAzureNodeDriver.list_sizesc C s& g }|du r | j g}n|g}|D ]�}|s| �|�} n d| j|j|f |fg} | D ]g} |s4| �| d �} n d�| d |�|fg} | D ]M} |sM| �| d �} n d�| d |�|fg} | D ]3}|sf| �|d �}n d�|d |�|fg}|D ]}|�t |d |d | d | d |j| j j �� qsqZqAq(q|S )a List available VM images to boot from. :param location: The location at which to list images (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :param ex_publisher: Filter by publisher, or None to list all publishers. :type ex_publisher: ``str`` :param ex_offer: Filter by offer, or None to list all offers. :type ex_offer: ``str`` :param ex_sku: Filter by sku, or None to list all skus. :type ex_sku: ``str`` :param ex_version: Filter by version, or None to list all versions. :type ex_version: ``str`` :return: list of node image objects. :rtype: ``list`` of :class:`.AzureImage` NzH/subscriptions/%s/providers/Microsoft.Compute/locations/%s/publishers/%sr z"{}/artifacttypes/vmimage/offers/{}z {}/skus/{}z{}/versions/{}� ) rk �ex_list_publishersr? r, �ex_list_offersr � ex_list_skus�ex_list_image_versions�appendr r7 r# )r" r � ex_publisher�ex_offer�ex_sku� ex_versionZimagesrv �locZ publishers�pubZoffersZoffZskusr Zversions�vr( r( r) � list_imagesO sX ��� ��������"zAzureNodeDriver.list_imagesc C sZ |� d�rt|�\}}}t|||| �S |�d�\}}}} | �||||| �} | r+| d S dS )a� Returns a single node image from a provider. :param image_id: Either an image urn in the form `Publisher:Offer:Sku:Version` or a Azure blob store URI in the form `http://storageaccount.blob.core.windows.net/container/image.vhd` pointing to a VHD file. :type image_id: ``str`` :param location: The location at which to search for the image (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :rtype :class:`.AzureImage`: or :class:`.AzureVhdImage`: :return: AzureImage or AzureVhdImage instance on success. �http�:r N)� startswith�_split_blob_urir6 �splitr� ) r" Zimage_idr �storageAccount� blobContainer�blobr� r� r� r� �ir( r( r) � get_image� s zAzureNodeDriver.get_imagec s� |r d�j |f }nd�j }dti}tt�� �}|t }g }t�� |k rg�jj||d�} |�� ��fdd�| jd D �� | j� d�sG |S t � | jd �} |� d d � t | j ��� D �� | j}t�� |k s%|S ) a� List all nodes. :param ex_resource_group: The resource group to list all nodes from. :type ex_resource_group: ``str`` :param ex_fetch_nic: Fetch NIC resources in order to get IP address information for nodes. If True, requires an extra API call for each NIC of each node. If False, IP addresses will not be returned. :type ex_fetch_nic: ``bool`` :param ex_fetch_power_state: Fetch node power state. If True, requires an extra API call for each node. If False, node state will be returned based on provisioning state only. :type ex_fetch_power_state: ``bool`` :return: list of node objects :rtype: ``list`` of :class:`.Node` NOTE: With the default arguments, the function may result in M * (1 + (N * 3)) HTTP requests where M is number of API pages and N is number of nodes returned per page. zO/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Compute/virtualMachinesz=/subscriptions/%s/providers/Microsoft.Compute/virtualMachinesrn ro c 3 s � | ] }�j |� �d �V qdS ))� fetch_nic�fetch_power_stateN)�_to_node)rs �n�� ex_fetch_nic�ex_fetch_power_stater" r( r) � <genexpr>� s � � �z-AzureNodeDriver.list_nodes.<locals>.<genexpr>r� �nextLinkc S � i | ] \}}||d �qS �r r( �rs �kr� r( r( r) � <dictcomp>� � z.AzureNodeDriver.list_nodes.<locals>.<dictcomp>)r? �VM_API_VERSION�int�time� LIST_NODES_PAGINATION_TIMEOUTr7 rw �extendry rg r �updater �query�items�path) r" �ex_resource_groupr� r� rz rp �now_ts� deadline_tsZnodesr{ �parsed_next_linkr( r� r) � list_nodes� s2 ��� � � � zAzureNodeDriver.list_nodes�vhdsZ azureuserre FZ Standard_LRSc C s� |s |du r t d��|du r| j}| du r<| du r t d��| du r#d} d| j|| | f }t|| i �}| �|d |||�} | �|�}d| j||f }t|t�rz| j||||d�}d |d d d d |j id |id�i}|rod|d d< |ryt dt |� ��nWt|t �s�t|t �r�t|t �r�|j|j|j|jd�}nd|j i}||d d d d�d�}|r�d|d d< |r�d|i|d d< n| j||||d�}d |i|d d< nt dt |� ��||d|j | d|j i|d |id d| j igid �d �}|r�|d d! d �d"|i� |�rt�|�|d d# d$< | |d d# d%< t|t��r<t�t�d&���d'�|d d# d(< d)d*d+| |jd,�gid-�|d d# d.< n t|t ��rVd/d0i|d d# d.< |j |d d# d(< nt d1��| j j |d2t i|d3d4�}| �!|j"�}||_#||_$|S )5a� Create a new node instance. This instance will be started automatically. This driver supports the ``ssh_key`` feature flag for ``created_node`` so you can upload a public key into the new instance:: >>> from libcloud.compute.drivers.azure_arm import AzureNodeDriver >>> driver = AzureNodeDriver(...) >>> auth = NodeAuthSSHKey('pubkey data here') >>> node = driver.create_node("test_node", auth=auth) This driver also supports the ``password`` feature flag for ``create_node`` so you can set a password:: >>> driver = AzureNodeDriver(...) >>> auth = NodeAuthPassword('mysecretpassword') >>> node = driver.create_node("test_node", auth=auth, ...) If you don't provide the ``auth`` argument libcloud will assign a password: >>> driver = AzureNodeDriver(...) >>> node = driver.create_node("test_node", ...) >>> password = node.extra["properties"] ["osProfile"]["adminPassword"] :param name: String with a name for this new node (required) :type name: ``str`` :param size: The size of resources allocated to this node. (required) :type size: :class:`.NodeSize` :param image: OS Image to boot on node (required) :type image: :class:`.AzureImage` or :class:`.AzureVhdImage` or :class:`.AzureComputeGalleryImage` :param location: Which data center to create a node in. (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :param auth: Initial authentication information for the node (optional) :type auth: :class:`.NodeAuthSSHKey` or :class:`NodeAuthPassword` :param ex_resource_group: The resource group in which to create the node :type ex_resource_group: ``str`` :param ex_storage_account: The storage account id in which to store the node's disk image. Note: when booting from a user image (AzureVhdImage) the source image and the node image must use the same storage account. :type ex_storage_account: ``str`` :param ex_blob_container: The name of the blob container on the storage account in which to store the node's disk image (optional, default "vhds") :type ex_blob_container: ``str`` :param ex_user_name: User name for the initial admin user (optional, default "azureuser") :type ex_user_name: ``str`` :param ex_network: The virtual network the node will be attached to. Must provide either `ex_network` (to create a default NIC for the node on the given network) or `ex_nic` (to supply the NIC explicitly). :type ex_network: ``str`` :param ex_subnet: If ex_network is provided, the subnet of the virtual network the node will be attached to. Optional, default is the "default" subnet. :type ex_subnet: ``str`` :param ex_nic: A virtual NIC to attach to this Node, from `ex_create_network_interface` or `ex_get_nic`. Must provide either `ex_nic` (to supply the NIC explicitly) or ex_network (to create a default NIC for the node on the given network). :type ex_nic: :class:`AzureNic` :param ex_tags: Optional tags to associate with this node. :type ex_tags: ``dict`` :param ex_customdata: Custom data that will be placed in the file /var/lib/waagent/CustomData https://azure.microsoft.com/en-us/documentation/ articles/virtual-machines-how-to-inject-custom-data/ :type ex_customdata: ``str`` :param ex_use_managed_disks: Enable this feature to have Azure automatically manage the availability of disks to provide data redundancy and fault tolerance, without creating and managing storage accounts on your own. Managed disks may not be available in all regions (default False). :type ex_use_managed_disks: ``bool`` :param ex_disk_size: Custom OS disk size in GB :type ex_disk_size: ``int`` :param ex_storage_account_type: The Storage Account type, ``Standard_LRS``(HDD disks) or ``Premium_LRS``(SSD disks). :type ex_storage_account_type: str :param ex_os_disk_delete: Enable this feature to have Azure automatically delete the OS disk when you delete the VM. :type ex_os_disk_delete: ``bool`` :return: The newly created node. :rtype: :class:`.Node` Nz>ex_use_managed_disks is False, must provide ex_storage_accountz(Must provide either ex_network or ex_nic�defaultz]/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/virtualnetworks/%s/subnets/%sz-nic�R/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Compute/virtualMachines/%s)r% r� �ex_storage_account�ex_blob_container�osDisk�linuxZ ReadWriteZ FromImage�uri)r% �osType�caching� createOption�image�vhdZDeleteZ deleteOptionz=Creating managed OS disk from %s image type is not supported.)r r r r r, )r% r� r� r� )�imageReferencer� ZstorageAccountType� managedDiskr� z[Unknown image type %s, expected one of AzureImage, AzureVhdImage, AzureComputeGalleryImage.�!Microsoft.Compute/virtualMachinesZvmSizeZ computerName�networkInterfaces)ZhardwareProfile�storageProfile� osProfile�networkProfile)r, r% �typer �tags� propertiesr� r� � diskSizeGBr� Z customDataZ adminUsername� zutf-8Z adminPassword�trueZ publicKeysz /home/%s/.ssh/authorized_keys)r� ZkeyData)� disablePasswordAuthenticationZsshZlinuxConfigurationr� �falsez7Must provide NodeAuthSSHKey or NodeAuthPassword in authrn �PUT�rp �data�method)%r� rk r? rM �ex_create_network_interfaceZ_get_and_check_auth� isinstancer6 �_get_instance_vhdr, r r� r r> r r r r r� �base64� b64encoder �binascii�hexlify�os�urandom�decodeZpubkeyr rW r7 rw r� r� ry �sizer� ) r" r% r� r� Zauthr� r� r� r Z ex_user_nameZ ex_networkZ ex_subnetZex_nic�ex_tagsZ ex_customdataZex_use_managed_disksZ ex_disk_sizeZex_storage_account_typeZex_os_disk_deleteZ subnet_id�subnet�target� instance_vhdZstorage_profiler� r� r{ �noder( r( r) rV � s� �� � �� ��� �� � �� ������ ������ �� zAzureNodeDriver.create_nodec C sf d|j }z| jj|dtidd� W dS ty2 } z|jdkr'W Y d}~dS W Y d}~dS d}~ww ) 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`` z %s/restartrn �POST�rp r� T�� NF)r, r7 rw r� r �code)r" r� r� �hr( r( r) � reboot_node s ��zAzureNodeDriver.reboot_node� c C s� |p|p|}z| j j|jdtidd� W n! ty5 } z|jdkr"n |jdkr*d}n� W Y d}~nd}~ww |} |rs| dkrszt�|� | j j|jdtid � | d 8 } W n tyl } z |jd v rgW Y d}~n � d}~ww |rs| dks>|jd d d } |r�| D ]C} |} | dkr�z | � | � | �� W n0 ty� } z | d 8 } |jdkr�|j � d�r�| dkr�t�|� n� W Y d}~nd}~ww | dks�q�|jd d d � d�} |�r'| du�r'|} |j�d�d } | dk�r'z | �| | d �r�W n5W n* t�y } z | d 8 } dt|�v �r| dk�rt�|� n� W Y d}~nd}~ww t�d� | dks�|j� d i �� di �� di �� d�}|�ro|du�ro|d }z| j j|dtidd� W d S t�yn } z|jdv�rc� W Y d}~d S d}~ww d S ) a� Destroy a node. :param node: The node to be destroyed :type node: :class:`.Node` :param ex_destroy_nic: Destroy the NICs associated with this node (default True). :type node: ``bool`` :param ex_destroy_vhd: Destroy the OS disk blob associated with this node (default True). :type node: ``bool`` :param ex_poll_qty: Number of retries checking if the node is gone, destroying the NIC or destroying the VHD (default 10). :type node: ``int`` :param ex_poll_wait: Delay in seconds between retries (default 10). :type node: ``int`` :param ex_destroy_os_disk: Destroy the OS disk associated with this node either if it is a managed disk (default True). :type node: ``bool`` :return: True if the destroy was successful, raises exception otherwise. :rtype: ``bool`` rn �DELETEr� r� �� FNr ro r� )r� i� r� r� r� i� z [NicInUse]r� r� r� �/� r� ZLeaseIdMissingr� r� r, �r� r� T)r7 rw r, r� r r� r� �sleeprF �ex_destroy_nic�_to_nic�messager� rg r� �_ex_delete_old_vhdr �str�DISK_API_VERSION)r" r� r� Zex_destroy_vhdZ ex_poll_qtyZ ex_poll_waitZex_destroy_os_diskZdo_node_pollingr� ZretriesZ interfaces�nicr� Z resourceGroup�eZ managed_diskZmanaged_disk_idr( r( r) � destroy_node$ s� ' � �� �� � ����� � ��� � � �� ���z AzureNodeDriver.destroy_nodec C s� |du rt d��|du rt d��dj| j||d�} |dur |ni } |du r)ddind|jd �} |j| | |d �d �}|durCd |i|d < |durK||d< | durU| |d d< | dur_| |d d< | jj| ddti|d�}| j|j||d�S )a3 Create a new managed volume. :param size: Size of volume in gigabytes. :type size: ``int`` :param name: Name of the volume to be created. :type name: ``str`` :param location: Which data center to create a volume in. (required) :type location: :class:`NodeLocation` :param snapshot: Snapshot from which to create the new volume. :type snapshot: :class:`VolumeSnapshot` :param ex_resource_group: The name of resource group in which to create the volume. (required) :type ex_resource_group: ``str`` :param ex_sku_name: The Disk SKU name. Refer to the API reference for options. :type ex_sku_name: ``str`` :param ex_tags: Optional tags to associate with this resource. :type ex_tags: ``dict`` :param ex_zones: The list of availability zones to create the volume in. Options are any or all of ["1", "2", "3"]. (optional) :type ex_zones: ``list`` of ``str`` :param ex_iops: The max IOPS this volume is capable of. :type ex_iops: ``int`` :param ex_throughput: The max throughput of this volume in MBps. :type ex_throughput: ``int`` :return: The newly created volume. :rtype: :class:`StorageVolume` Nz Must provide `location` value.z'Must provide `ex_resource_group` value.�p/subscriptions/{subscription_id}/resourceGroups/{resource_group}/providers/Microsoft.Compute/disks/{volume_name}�r? r@ � volume_namer� �Empty�Copy�r� � sourceUri)� creationDatar� �r r� r� r% r Zzonesr� ZdiskIopsReadWriteZdiskMBpsReadWriter� rn �r� rp r� �r% r� ) r� r r? r, r7 rw r� � _to_volumery )r" r� r% r �snapshotr� Z ex_sku_namer� Zex_zonesZex_iopsZ ex_throughputrz r� Z creation_datar� �responser( r( r) � create_volume� sD 4�� �� �z AzureNodeDriver.create_volumec s� |rd}nd}|j � j|d�}dti}tt�� �}|t }g }t�� |k rf� jj|d|d�}|�� fdd�|j d D �� |j � d �sF |S t � |j d �}|� d d � t |j��� D �� |j}t�� |k s%|S ) a Lists all the disks under a resource group or subscription. :param ex_resource_group: The identifier of your subscription where the managed disks are located. :type ex_resource_group: ``str`` :rtype: list of :class:`StorageVolume` zb/subscriptions/{subscription_id}/resourceGroups/{resource_group}/providers/Microsoft.Compute/diskszB/subscriptions/{subscription_id}/providers/Microsoft.Compute/disks�r? r@ rn �GET�r� rp c 3 s � | ]}� � |�V qd S rD )r )rs �volumer- r( r) r� , s � z/AzureNodeDriver.list_volumes.<locals>.<genexpr>r� r� c S r� r� r( r� r( r( r) r� 1 r� z0AzureNodeDriver.list_volumes.<locals>.<dictcomp>)r r? r� r� r� � LIST_VOLUMES_PAGINATION_TIMEOUTr7 rw r� ry rg r r� r r� r� r� ) r" r� rz rp r� r� Zvolumesr r� r( r- r) � list_volumes s, �� � � z AzureNodeDriver.list_volumesc s� |j d }|j d }|j d d d } |du r9dd� | D �� � fd d�td d �D �} t| �d kr5| d }ntd ��|durN|j|j||rFd ndd|id�} n |dd|jid�} | �| � | jj |ddt idd| ii|d�d� dS )a� Attach a volume to node. :param node: A node to attach volume. :type node: :class:`Node` :param volume: A volume to attach. :type volume: :class:`StorageVolume` :param ex_lun: Specifies the logical unit number (LUN) location for the data drive in the virtual machine. Each data disk must have a unique LUN. :type ex_lun: ``int`` :param ex_vhd_uri: Attach old-style unmanaged disk from VHD blob. (optional) :type ex_vhd_uri: ``str`` :param ex_vhd_create: Create a new VHD blob for unmanaged disk. (optional) :type ex_vhd_create: ``bool`` :rtype: ``bool`` r, r r� r� � dataDisksNc S s g | ]}|d �qS )�lunr( �rs �diskr( r( r) rt \ s z1AzureNodeDriver.attach_volume.<locals>.<listcomp>c s g | ]}|� vr|�qS r( r( )rs r �Z used_lunsr( r) rt ] s r �@ z$No LUN available to attach new disk.�empty�attachr� )r% r� r r� r� )r r� r� r� rn �r� r r T) rF �range�lenr r% r� r, r� r7 rw r� ) r" r� r Zex_lunZ ex_vhd_uriZ ex_vhd_createZ ex_kwargsrz r �disksZ free_lunsZnew_diskr( r r) � attach_volume5 s< ! � � �� z AzureNodeDriver.attach_volumec C s` dj | j||jd�}|jd ||jd d d�d�}| jj|dd ti|d �}| j|j|j|d �S ) as Resize a volume. :param volume: A volume to resize. :type volume: :class:`StorageVolume` :param new_size: The new size to resize the volume to in Gib. :type new_size: ``int`` :param resource_group: The name of the resource group in which to create the volume. :type resource_group: ``str`` r r r r� r )r� r �r r� r� rn r r ) r r? r% rF r7 rw r� r ry )r" r Znew_sizer@ rz r� r r( r( r) �ex_resize_volume s$ � ���z AzureNodeDriver.ex_resize_volumec sz |du rt d��|jd }|jd }|jd d d }� fdd �|D �|dd�< | jj|d d tidd|ii|d �d � dS )z6 Detach a managed volume from a node. Nz Must provide `ex_node` value.r, r r� r� r c s8 g | ]}|� d �� jkr|� di �� d�� jkr|�qS )r% r� r, )rg r% r, r �r r( r) rt � s �z1AzureNodeDriver.detach_volume.<locals>.<listcomp>r� rn r r T)r� rF r7 rw r� )r" r Zex_noderz r r r( r$ r) � detach_volume� s" � �� z AzureNodeDriver.detach_volumec C � | � |� dS )z" Delete a volume. T��ex_delete_resource�r" r r( r( r) �destroy_volume� � z AzureNodeDriver.destroy_volumec C s� |du rt d��|du rt d��|du rt d��dj| j||d�}|dur'|ni }|j|dd|jd �id �}| jj|d |d tid �} | j| j||d�S )a� Create snapshot from volume. :param volume: Instance of ``StorageVolume``. :type volume: :class`StorageVolume` :param name: Name of snapshot. (required) :type name: ``str`` :param location: Which data center to create a volume in. (required) :type location: :class:`NodeLocation` :param ex_resource_group: The name of resource group in which to create the snapshot. (required) :type ex_resource_group: ``str`` :param ex_tags: Optional tags to associate with this resource. :type ex_tags: ``dict`` :rtype: :class:`VolumeSnapshot` NzMust provide `name` valuez Must provide `location` valuez&Must provide `ex_resource_group` value�v/subscriptions/{subscription_id}/resourceGroups/{resource_group}/providers/Microsoft.Compute/snapshots/{snapshot_name}�r? r@ Z snapshot_namer r r r r� rn )r� r� rp r ) r� r r? r, r7 rw �SNAPSHOT_API_VERSION� _to_snapshotry ) r" r r% r r� r� � snapshot_idr� r� r r( r( r) �create_volume_snapshot� s2 � ���z&AzureNodeDriver.create_volume_snapshotc s � fdd�| � � D �S )Nc s g | ] }|j d � jkr|�qS )� source_id)rF r, )rs r r$ r( r) rt s �z9AzureNodeDriver.list_volume_snapshots.<locals>.<listcomp>)�list_snapshotsr) r( r$ r) �list_volume_snapshots s �z%AzureNodeDriver.list_volume_snapshotsc sL |rd}nd}|j � j|d�}� jj|ddtid�}� fdd�|jd D �S ) a2 Lists all the snapshots under a resource group or subscription. :param ex_resource_group: The identifier of your subscription where the managed snapshots are located (optional). :type ex_resource_group: ``str`` :rtype: list of :class:`VolumeSnapshot` zf/subscriptions/{subscription_id}/resourceGroups/{resource_group}/providers/Microsoft.Compute/snapshotszF/subscriptions/{subscription_id}/providers/Microsoft.Compute/snapshotsr r rn r c rq r( )r/ )rs Zsnapr- r( r) rt ( ru z2AzureNodeDriver.list_snapshots.<locals>.<listcomp>r� )r r? r7 rw r. ry )r" r� rz r r( r- r) r3 s �� �z AzureNodeDriver.list_snapshotsc C r& )z$ Delete a snapshot. Tr' )r" r r( r( r) �destroy_volume_snapshot* r+ z'AzureNodeDriver.destroy_volume_snapshotc C s |� d�}|� d�}t|�}|d }|� d�}|dur t|�}|� dd��� } |� dd��� } | d kr7tj} n#| d kr?tj} n| d krW| d v rKtj} n| d krStj} ntj } ntj } |du ro|duro|durodj | j ||d�}|du ry|dury|}t |||| | |d�S )a� Parse the JSON element and return a StorageVolume object. :param volume_obj: A volume object from an azure response. :type volume_obj: ``dict`` :param name: An optional name for the volume. :type name: ``str`` :param ex_resource_group: An optional resource group for the volume. :type ex_resource_group: ``str`` :rtype: :class:`StorageVolume` r, r% r� r� N�provisioningStatere Z diskStaterX rY rZ )ZattachedZreservedZ activesasZ unattachedr r )r, r% r� r# �staterF ) rg �dictr� rh r �CREATING�UPDATINGZINUSE� AVAILABLE�UNKNOWNr r? r ) r" Z volume_objr% r� � volume_idr rF r� r� Zprovisioning_stateZ disk_stater7 r( r( r) r 1 sJ � �zAzureNodeDriver._to_volumec C s� |� d�}|� d|�}|d }|� d�}|dur t|�}t|�}|d d |d< d |d v r4|d |d < | j� |� d d ��� tj�}z t�|� d ��} W n t t tj fy[ d} Y nw |du rq|durq|durqdj | j ||d�}t|||| ||| d�S )a� Parse the JSON element and return a VolumeSnapshot object. :param snapshot_obj: A snapshot object from an azure response. :type snapshot_obj: ``dict`` :param name: An optional name for the volume. :type name: ``str`` :param ex_resource_group: An optional resource group for the volume. :type ex_resource_group: ``str`` :rtype: :class:`VolumeSnapshot` r, r% r� r� Nr r r2 z#/providers/Microsoft.Compute/disks/r= r6 re Z timeCreatedr, r- )r% r� r# r7 rF �created)rg r� r8 �SNAPSHOT_STATE_MAPrh r r< r Z parse_date� TypeErrorr� Z ParseErrorr r? r ) r" Z snapshot_objr% r� r0 r� r� rF r7 Z created_atr( r( r) r/ o sD ��� �z AzureNodeDriver._to_snapshotc C s0 t |t�s|j}| jj|ddtid�}|jdv S )z$ Delete a resource. r� rn r ��� r� r� )r� r r, r7 rw �RESOURCE_API_VERSION�status)r" �resourcer{ r( r( r) r( � s � z"AzureNodeDriver.ex_delete_resource�USD�en-US�USc C s8 d| j f }td||||f d�}| jj||d�}|jS )a} Get rate card :param offer_durable_id: ID of the offer applicable for this user account. (e.g. "0026P") See http://azure.microsoft.com/en-us/support/legal/offer-details/ :type offer_durable_id: str :param currency: Desired currency for the response (default: "USD") :type currency: ``str`` :param locale: Locale (default: "en-US") :type locale: ``str`` :param region: Region (two-letter code) (default: "US") :type region: ``str`` :return: A dictionary of rates whose ID's correspond to nothing at all :rtype: ``dict`` z7/subscriptions/%s/providers/Microsoft.Commerce/RateCardz\OfferDurableId eq 'MS-AZR-%s' and Currency eq '%s' and Locale eq '%s' and RegionInfo eq '%s')rn z$filterro )r? �RATECARD_API_VERSIONr7 rw ry )r" Zoffer_durable_id�currency�localerc rz rp r{ r( r( r) �ex_get_ratecard� s � ��z AzureNodeDriver.ex_get_ratecardc C sR |du r| j r | j }ntd��d| j|jf }| jj|dtid�}dd� |jD �S )a\ List node image publishers. :param location: The location at which to list publishers (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :return: A list of tuples in the form ("publisher id", "publisher name") :rtype: ``list`` Nr} zE/subscriptions/%s/providers/Microsoft.Compute/locations/%s/publishersrn ro c S � g | ] }|d |d f�qS r< r( �rs �pr( r( r) rt � � z6AzureNodeDriver.ex_list_publishers.<locals>.<listcomp>)rk r� r? r, r7 rw �IMAGES_API_VERSIONry r� r( r( r) r� � s �z"AzureNodeDriver.ex_list_publishersc C �, d| }| j j|dtid�}dd� |jD �S )a9 List node image offers from a publisher. :param publisher: The complete resource path to a publisher (as returned by `ex_list_publishers`) :type publisher: ``str`` :return: A list of tuples in the form ("offer id", "offer name") :rtype: ``list`` z %s/artifacttypes/vmimage/offersrn ro c S rM r< r( rN r( r( r) rt � rP z2AzureNodeDriver.ex_list_offers.<locals>.<listcomp>�r7 rw rQ ry )r" r rz r{ r( r( r) r� � � z AzureNodeDriver.ex_list_offersc C rR )a List node image skus in an offer. :param offer: The complete resource path to an offer (as returned by `ex_list_offers`) :type offer: ``str`` :return: A list of tuples in the form ("sku id", "sku name") :rtype: ``list`` z%s/skusrn ro c S rM r< r( )rs r r( r( r) rt rP z0AzureNodeDriver.ex_list_skus.<locals>.<listcomp>rS )r" r rz r{ r( r( r) r� rT z AzureNodeDriver.ex_list_skusc C rR )a% List node image versions in a sku. :param sku: The complete resource path to a sku (as returned by `ex_list_skus`) :type publisher: ``str`` :return: A list of tuples in the form ("version id", "version name") :rtype: ``list`` z %s/versionsrn ro c S rM r< r( )rs Zimgr( r( r) rt rP z:AzureNodeDriver.ex_list_image_versions.<locals>.<listcomp>rS )r" r rz r{ r( r( r) r� rT z&AzureNodeDriver.ex_list_image_versionsc C �2 d| j }| jj|dtid�}dd� |jd D �S )z� List resource groups. :return: A list of resource groups. :rtype: ``list`` of :class:`.AzureResourceGroup` z!/subscriptions/%s/resourceGroups/rn ro c S �* g | ]}t |d |d |d |d ��qS �r, r% r r� )rB )rs �grpr( r( r) rt , � ��z;AzureNodeDriver.ex_list_resource_groups.<locals>.<listcomp>r� )r? r7 rw �RESOURCE_GROUP_API_VERSIONry �r" rz r{ r( r( r) �ex_list_resource_groups" s �z'AzureNodeDriver.ex_list_resource_groupsc C s6 d| j |f }| jj|dtid�}dd� |jd D �S )a% List network security groups. :param resource_group: List security groups in a specific resource group. :type resource_group: ``str`` :return: A list of network security groups. :rtype: ``list`` of :class:`.AzureNetworkSecurityGroup` zU/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/networkSecurityGroupsrn ro c S rV rW )rK �rs �netr( r( r) rt B rY zCAzureNodeDriver.ex_list_network_security_groups.<locals>.<listcomp>r� )r? r7 rw �NSG_API_VERSIONry �r" r@ rz r{ r( r( r) � ex_list_network_security_groups1 s ���z/AzureNodeDriver.ex_list_network_security_groupsc C �T |du r| j r | j }ntd��d| j||f }d|ji}| jj|dti|dd� dS )a� Update tags on any resource supporting tags. :param name: Name of the network security group to create :type name: ``str`` :param resource_group: The resource group to create the network security group in :type resource_group: ``str`` :param location: The location at which to create the network security group (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` Nr} �X/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/networkSecurityGroups/%sr rn r� r� �rk r� r? r, r7 rw r_ �r" r% r@ r r� r� r( r( r) � ex_create_network_security_groupG � ��� �z0AzureNodeDriver.ex_create_network_security_groupc C rb )a� Update tags on any resource supporting tags. :param name: Name of the network security group to delete :type name: ``str`` :param resource_group: The resource group to create the network security group in :type resource_group: ``str`` :param location: The location at which to create the network security group (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` Nr} rc r rn r� r� rd re r( r( r) � ex_delete_network_security_groupi rg z0AzureNodeDriver.ex_delete_network_security_groupc C rU )z� List virtual networks. :return: A list of virtual networks. :rtype: ``list`` of :class:`.AzureNetwork` z=/subscriptions/%s/providers/Microsoft.Network/virtualnetworksrn ro c S rV rW )rL r] r( r( r) rt � rY z4AzureNodeDriver.ex_list_networks.<locals>.<listcomp>r� )r? r7 rw �VIRTUAL_NETWORK_API_VERSIONry r[ r( r( r) �ex_list_networks� s ��z AzureNodeDriver.ex_list_networksc C s2 d|j }| jj|dtid�}dd� |jd D �S )z� List subnets of a virtual network. :param network: The virtual network containing the subnets. :type network: :class:`.AzureNetwork` :return: A list of subnets. :rtype: ``list`` of :class:`.AzureSubnet` z %s/subnetsrn ro c S s$ g | ]}t |d |d |d ��qS )r, r% r� )rM r] r( r( r) rt � s $ z3AzureNodeDriver.ex_list_subnets.<locals>.<listcomp>r� )r, r7 rw �SUBNET_API_VERSIONry )r" �networkrz r{ r( r( r) �ex_list_subnets� s z AzureNodeDriver.ex_list_subnetsc sN |du r d� j }nd� j |f }� jj|dtid�}� fdd�|jd D �S ) aK List available virtual network interface controllers in a resource group :param resource_group: List NICS in a specific resource group containing the NICs(optional). :type resource_group: ``str`` :return: A list of NICs. :rtype: ``list`` of :class:`.AzureNic` Nz?/subscriptions/%s/providers/Microsoft.Network/networkInterfaceszQ/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/networkInterfacesrn ro c rq r( )r� r] r- r( r) rt � ru z0AzureNodeDriver.ex_list_nics.<locals>.<listcomp>r� )r? r7 rw �NIC_API_VERSIONry r` r( r- r) � ex_list_nics� s ����z AzureNodeDriver.ex_list_nicsc C � | j j|dtid�}| �|j�S )z� Fetch information about a NIC. :param id: The complete resource path to the NIC resource. :type id: ``str`` :return: The NIC object :rtype: :class:`.AzureNic` rn ro )r7 rw rn r� ry �r" r, r{ r( r( r) � ex_get_nic� � zAzureNodeDriver.ex_get_nicc C s\ d| j ||jf }||jd�}| jj|dti|dd�}t|jd |jd |jd |jd �S ) a� Update the properties of an already existing virtual network interface (NIC). :param network_interface: The NIC to update. :type network_interface: :class:`.AzureNic` :param resource_group: The resource group to check the ip address in. :type resource_group: ``str`` :param properties: The dictionary of the NIC's properties :type properties: ``dict`` :return: The NIC object :rtype: :class:`.AzureNic` �T/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/networkInterfaces/%sr rn r� r� r, r% r r� )r? r% r r7 rw rn rS ry )r" Znetwork_interfacer@ r� r� r� r{ r( r( r) �ex_update_nic_properties� s ��� ��z(AzureNodeDriver.ex_update_nic_propertiesc C sD |j d }|j d }| jj|ddti|j|jd|d|id�d� d S ) aK Update the network profile of a node. This method can be used to attach or detach a NIC to a node. :param node: A node to attach the network interface to. :type node: :class:`Node` :param network_profile: The new network profile to update. :type network_profile: ``dict`` r, r r� rn r� r� )r, r% r� r r� r N)rF r7 rw r� r, r% )r" r� Znetwork_profilerz r r( r( r) �!ex_update_network_profile_of_node� s � �z1AzureNodeDriver.ex_update_network_profile_of_nodec C sR z| j j|jdtidd� W dS ty( } z |jdv r#W Y d}~dS � d}~ww )z� Destroy a NIC. :param nic: The NIC to destroy. :type nic: ``.AzureNic`` :return: True on success :rtype: ``bool`` rn r� r� Tr� N)r7 rw r, rn r r� )r" r� r� r( r( r) r� s � ��z AzureNodeDriver.ex_destroy_nicc C s@ dt i}d| j||jf }|dur||d< | jj||d�}|jS )a� Checks whether a private IP address is available for use. Also returns an object that contains the available IPs in the subnet. :param resource_group: The resource group to check the ip address in. :type resource_group: ``str`` :param network: The virtual network. :type network: :class:`.AzureNetwork` :param ip_address: The private IP address to be verified. :type ip_address: ``str`` rn zm/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/virtualNetworks/%s/CheckIPAddressAvailabilityN� ipAddressro )ri r? r% r7 rw ry )r" r@ rl � ip_addressrp rz r{ r( r( r) � ex_check_ip_address_availability+ s ��z0AzureNodeDriver.ex_check_ip_address_availabilityc C rp )z� Fetch information about a node. :param id: The complete resource path to the node resource. :type id: ``str`` :return: The Node object :rtype: :class:`.Node` rn ro )r7 rw r� r� ry rq r( r( r) � ex_get_nodeD rs zAzureNodeDriver.ex_get_nodec C rp )z� Fetch information about a volume. :param id: The complete resource path to the volume resource. :type id: ``str`` :return: The StorageVolume object :rtype: :class:`.StorageVolume` rn ro )r7 rw r� r ry rq r( r( r) � ex_get_volumeR rs z AzureNodeDriver.ex_get_volumec C rp )z� Fetch information about a snapshot. :param id: The complete resource path to the snapshot resource. :type id: ``str`` :return: The VolumeSnapshot object :rtype: :class:`.VolumeSnapshot` rn ro )r7 rw r. r/ ry rq r( r( r) �ex_get_snapshot` rs z AzureNodeDriver.ex_get_snapshotc C rp )z� Fetch information about a public IP resource. :param id: The complete resource path to the public IP resource. :type id: ``str` :return: The public ip object :rtype: :class:`.AzureIPAddress` rn ro )r7 rw �IP_API_VERSION�_to_ip_addressry rq r( r( r) �ex_get_public_ipn rs z AzureNodeDriver.ex_get_public_ipc s: d� j |f }� jj|dtid�}� fdd�|jd D �S )a List public IP resources. :param resource_group: List public IPs in a specific resource group. :type resource_group: ``str`` :return: List of public ip objects :rtype: ``list`` of :class:`.AzureIPAddress` zQ/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/publicIPAddressesrn ro c rq r( )r~ r] r- r( r) rt � ru z6AzureNodeDriver.ex_list_public_ips.<locals>.<listcomp>r� )r? r7 rw r} ry r` r( r- r) �ex_list_public_ips| s ��z"AzureNodeDriver.ex_list_public_ipsc C sx |du r| j r | j }ntd��d| j||f }|ji ddid�}|dkr*d|d d< | jj|d ti|d d �}| �|j�S ) a� Create a public IP resources. :param name: Name of the public IP resource :type name: ``str`` :param resource_group: The resource group to create the public IP :type resource_group: ``str`` :param location: The location at which to create the public IP (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :param public_ip_allocation_method: Call ex_create_public_ip with public_ip_allocation_method="Static" to create a static public IP address :type public_ip_allocation_method: ``str`` :return: The newly created public ip object :rtype: :class:`.AzureIPAddress` Nr} zT/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Network/publicIPAddresses/%sZpublicIPAllocationMethod�Dynamicr ZStaticr� rn r� r� ) rk r� r? r, r7 rw r} r~ ry )r" r% r@ r Zpublic_ip_allocation_methodr� r� r{ r( r( r) �ex_create_public_ip� s$ ��� � z#AzureNodeDriver.ex_create_public_ipc C s& |j }| jj|ddtid�}|jdv S )z� Delete a public ip address resource. :param public_ip: Public ip address resource to delete :type public_ip: `.AzureIPAddress` r� rn r rA )r, r7 rw r} rD )r" � public_iprE r{ r( r( r) �ex_delete_public_ip� s � z#AzureNodeDriver.ex_delete_public_ipc C s� |du r| j r | j }ntd��d| j||f }|ji ddd|jidd�d �gid �}|r=|d d d }d|ji|d d < | jj|dti|dd�} t| jd | jd | jd | jd �S )a� Create a virtual network interface (NIC). :param name: Name of the NIC resource :type name: ``str`` :param subnet: The subnet to attach the NIC :type subnet: :class:`.AzureSubnet` :param resource_group: The resource group to create the NIC :type resource_group: ``str`` :param location: The location at which to create the NIC (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :param public_ip: Associate a public IP resource with this NIC (optional). :type public_ip: :class:`.AzureIPAddress` :return: The newly created NIC :rtype: :class:`.AzureNic` Nr} rt �ipConfigurationsZmyip1r, r� )r� ZprivateIPAllocationMethod)r% r� r r� r �publicIPAddressrn r� r� r% r ) rk r� r? r, r7 rw rn rS ry ) r" r% r� r@ r r� r� r� Z ip_configr{ r( r( r) r� � s> ������� ��z+AzureNodeDriver.ex_create_network_interfacec C sj t |t�s|j}| jj|dtid�}|r||jd< n|jd �|� | jj|d|jd idtidd� dS )a� Update tags on any resource supporting tags. :param resource: The resource to update. :type resource: ``str`` or Azure object with an ``id`` attribute. :param tags: The tags to set. :type tags: ``dict`` :param replace: If true, replace all tags with the new tags. If false (default) add or update tags. :type replace: ``bool`` rn ro r� �PATCH�r� rp r� N)r� r r, r7 rw �TAG_API_VERSIONry r� )r" rE r� ri r{ r( r( r) �ex_create_tags s �z AzureNodeDriver.ex_create_tagsc C sH d| j ||jf }|jd d|id�}| jj||dtidd�}|jdv S ) a" Set the additional capabilities on a stopped node. :param node: The node to be updated :type node: :class:`.Node` :param ex_additional_capabilities: Optional additional capabilities allowing Ultra SSD and hibernation on this node. :type ex_additional_capabilities: ``dict`` :param resource_group: The resource group of the node to be updated :type resource_group: ``str`` :return: True if the update was successful, otherwise False :rtype: ``bool`` r� r ZadditionalCapabilitiesr" rn r� r� rA )r? r% rF r7 rw r� rD )r" r� Zadditional_capabilitiesr@ r� r� r{ r( r( r) �!ex_create_additional_capabilities3 s ���� z1AzureNodeDriver.ex_create_additional_capabilitiesc C s& d|j }| jj|dtidd�}|jS )zw Start a stopped node. :param node: The node to be started :type node: :class:`.Node` z%s/startrn r� r� �r, r7 rw r� ry )r" r� r� r{ r( r( r) � start_node^ s zAzureNodeDriver.start_nodec C s6 |rd|j }nd|j }| jj|dtidd�}|jS )a� Stop a running node. :param node: The node to be stopped :type node: :class:`.Node` :param deallocate: If True (default) stop and then deallocate the node (release the hardware allocated to run the node). If False, stop the node but maintain the hardware allocation. If the node is not deallocated, the subscription will continue to be billed as if it were running. :type deallocate: ``bool`` z %s/deallocatez %s/powerOffrn r� r� r� )r" r� � ex_deallocater� r{ r( r( r) � stop_nodej s zAzureNodeDriver.stop_nodec C s | j |d�S )N)r� )r� )r" r� r( r( r) � ex_start_node s z AzureNodeDriver.ex_start_nodec C s | j ||d�S )N)r� r� )r� )r" r� Z deallocater( r( r) � ex_stop_node� s z AzureNodeDriver.ex_stop_nodec C s2 d|j }d|j i}| jj|dti|dd�}|jS )z� Resize the node to a different machine size. :param node: Node to resize :type node: :class:`Node` :param size: New size for this machine :type node: :class:`NodeSize` z %s/resizer� rn r� r� r� )r" r� r� r� r� r{ r( r( r) �ex_resize_node� s �z AzureNodeDriver.ex_resize_nodec C s, d| j ||f }| jj|dtidd�}|jS )a� Get account keys required to access to a storage account (using AzureBlobsStorageDriver). :param resource_group: The resource group containing the storage account :type resource_group: ``str`` :param storage_account: Storage account to access :type storage_account: ``str`` :return: The account keys, in the form `{"key1": "XXX", "key2": "YYY"}` :rtype: ``.dict`` z[/subscriptions/%s/resourceGroups/%s/providers/Microsoft.Storage/storageAccounts/%s/listKeysrn r� r� )r? r7 rw �STORAGE_ACCOUNT_API_VERSIONry )r" r@ r9 rz r{ r( r( r) �ex_get_storage_account_keys� s �� �z+AzureNodeDriver.ex_get_storage_account_keysr c C s� |du r| j r | j }ntd��d}|jd | } |j|ddd|||d�d �d �} |r5|r5||d �| d d < | jj| dti| dd�} | jS )a� Run a command on the node as root. Does not require ssh to log in, uses Windows Azure Agent (waagent) running on the node. :param node: The node on which to run the command. :type node: :class:``.Node`` :param command: The actual command to run. Note this is parsed into separate arguments according to shell quoting rules but is executed directly as a subprocess, not a shell command. :type command: ``str`` :param filerefs: Optional files to fetch by URI from Azure blob store (must provide storage_account_name and storage_account_key), or regular HTTP. :type command: ``list`` of ``str`` :param location: The location of the virtual machine (if None, use default location specified as 'region' in __init__) :type location: :class:`.NodeLocation` :param storage_account_name: The storage account from which to fetch files in `filerefs` :type storage_account_name: ``str`` :param storage_account_key: The storage key to authorize to the blob store. :type storage_account_key: ``str`` :type: ``list`` of :class:`.NodeLocation` Nr} �initz /extensions/zMicrosoft.OSTCExtensionsZCustomScriptForLinuxz1.3)ZfileUrisZcommandToExecute� timestamp)r r� ZtypeHandlerVersionZsettings)r r% r� )ZstorageAccountNameZstorageAccountKeyr� ZprotectedSettingsrn r� r� )rk r� r, r7 rw �VM_EXTENSION_API_VERSIONry ) r" r� ZcommandZfilerefsr� Zstorage_account_nameZstorage_account_keyr r% r� r� r{ r( r( r) �ex_run_command� s8 .�����z AzureNodeDriver.ex_run_commandc C sb z&t |�\}}}| �||�}t||d d�|| jj�d�}|�|�||��W S ty0 Y dS w )NZkey1z {}.blob{})r` T) r� r� r r r7 r8 Z delete_objectZ get_objectr )r" r@ r� r� r� r� �keysZ blobdriverr( r( r) r� s � �z"AzureNodeDriver._ex_delete_old_vhdc s, t � �� }| j|d< | j|d< | j|d< |S )Nrf r? r\ )r �_ex_connection_class_kwargsrf r? r\ )r" rl r& r( r) r� s z+AzureNodeDriver._ex_connection_class_kwargsc C s* t j}z�d|d }| jj|dtid�}|jd D ]n}|d dv r(t j} W |S |d dkr5t j} W |S |d �d �rCt j } W |S |d d krPt j } W |S |d d krW |d d krdt j } W |S |d d krqt j } W |S |d dkr~t j} W |S |d dkr�t j }qW |S ty� Y |S w )Nz%s/InstanceViewr, rn ro Zstatusesr� )zProvisioningState/creatingzProvisioningState/deletingzProvisioningState/failedzProvisioningState/updatingzProvisioningState/succeededzPowerState/deallocatedzPowerState/stoppedzPowerState/deallocatingzPowerState/running)r r< r7 rw �INSTANCE_VIEW_API_VERSIONry �PENDING� TERMINATEDr� �ERRORr: ZSTOPPEDZPAUSED�RUNNINGr )r" r� r7 rz r{ rD r( r( r) �_fetch_power_state sX �� � � � � ��� ��z"AzureNodeDriver._fetch_power_statec C sN g }g }|d d d }|rZ|D ]I}z>| � |d �}|jd d d �d�} | r-|�| � |jd d d �d�} | rO| �| d �} | j�d �} | rO|�| � W q tyY Y qw tj} |re| �|�} n/|d d � � }|d krutj } n |d kr}tj } n|d kr�tj } n|dkr�tj } n|dkr�tj} t|d |d | ||| jj|d�}|S )Nr� r� r� r, r� r ZprivateIPAddressr� rw r6 rX Zdeletingr[ rY rZ r% )r# rF )rr rF rg r� r r r r< r� rh r� r� r� r: r� r r7 r# )r" r� r� r� Z private_ipsZ public_ipsZnicsr� r� Zprivr� Zpub_addr�addrr7 Zpsr� r( r( r) r� D sX � � � zAzureNodeDriver._to_nodec C sD t |d |d |d |d d dd| jj|d |d |d d �d �S ) Nr% Z memoryInMBZresourceDiskSizeInMBi r � numberOfCores�osDiskSizeInMB�maxDataDiskCount)r� r� r� )r, r% Zramr Z bandwidthZpricer# rF )r r7 r# �r" r� r( r( r) r~ t s ��z AzureNodeDriver._to_node_sizec C s$ t |d |�d�|�d�|�d��S )Nr, r% r r� )rS rg r� r( r( r) r� � s $zAzureNodeDriver._to_nicc C s t |d |d |d �S )Nr, r% r� )rT r� r( r( r) r~ � s z AzureNodeDriver._to_ip_addressc C s* |� � �dd�}t||| j�|�| jj�S )Nrd re )rh ri r rj rg r7 r# )r" r� rm r( r( r) rr � s �z AzureNodeDriver._to_locationc C s� d}g }|dk r@zd|| j j|||f }| �||�r |W S W n ty7 } z |�t|�� W Y d }~nd }~ww |d7 }|dk stdd�|� ��)Nr r� z!https://%s.blob%s/%s/%s-os_%i.vhdr� zTUnable to find a name for a VHD to use for instance in 10 tries, errors were: - %sz - )r7 r8 r� r r� r� �join) r" r% r� r� r� r� �errorsr� Zlcer( r( r) r� � s2 � ������z!AzureNodeDriver._get_instance_vhd)TNNNNrD )NNNNN)NTT)TTr� r� T)NNNNNNNN)NNF)NNNN)NN)rF rG rH )F)T)TT)r� )Ur1 r2 r3 r4 r Z connectionClsr% Zwebsiter Z AZURE_ARMr� Zfeaturesrj r r9 r: r; r� r? r! r| r� r� r� r� rV r� r� r r r! r# r% r* r1 r4 r3 r5 r r/ r( rL r� r� r� r� r\ ra rf rh rj rm ro rr ru rv r� ry rz r{ r| r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r~ r� r~ rr r� r5 r( r( r& r) rU � sF �������� � � � � ������ �! � X = � � � c* �J ) �; >6 # "" ' �2 � D + �U $0 �rU c C s@ | � d�} | d � d�d }| d }d�| dd � �}|||fS )Nr� � �.r � r� )r� r� )r� r9 r: Z blob_namer( r( r) r� � s r� )Dr4 r� r� r� r� Zlibcloud.utilsr Zlibcloud.utils.py3r r r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r r r r Zlibcloud.compute.typesr r r Zlibcloud.storage.typesr Zlibcloud.common.azure_armr Zlibcloud.common.exceptionsr Zlibcloud.compute.providersr Z$libcloud.storage.drivers.azure_blobsr rC r� rQ r� r} rx rn r_ rI rZ r. r� rk r� ri r� r� r� r� r r r6 r> rB rK rL rM rS rT rU r� r( r( r( r) �<module> s~ , a
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings