File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/__pycache__/azure.cpython-310.pyc
Back
o ;j � � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl mZmZmZ ddl mZ ddl mZmZ dd lmZ dd lmZmZ dd lmZ dd l m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$ ddl%m&Z& ej'Z'e(Z)e(Z*dZ+dZ,e�-d�Z. i dddddddddd��dd d d ddd d dd��d!d"d#d$ddd%d&d d��d'd(d)d*ddd+d,d&d��d-d.d/d0ddd1d2d,d��d3d3d4d0ddd5d&d d��d6d6d7d8ddd9d,d&d��d:d:d;d<ddd=d2d,d��d>d>d?d<ddd@d2d,d��dAdAdBdCdddDd2d2d��dEdEdFd<dddGd2d,d��dHdHdIdCdddJd2d2d��dKdLdMd$dddNd dd��dOdPdQd*dddRd&d d��dSdTdUd0dddVd,d&d��dWdXdYd8dddZd2d,d��d[d\d]d0ddd^d&d d��d_d`d8dddad,d&d�dbdcd<ddddd2d,d�dedfdCdddgdhd2d�di��Z/i djdk�dldm�dndo�dpdq�drds�dtdu�dvdw�dxdy�dzd{�d|d}�d~d�d�d��d�d��d�d��d�d��d�d��d�d��d�d�i�Z0G d�d�� d�e �Z1 d�d�� Z2G d�d�� d��Z3 G d�d�� d��Z4G d�d�� d�e4�Z5G d�d� de4�Z6G d�d�� d�e4�Z7G d�d�� d�e4�Z8G d�d�� d�e4�Z9G d�d�� d�e4�Z:G d�d�� d�e4�Z;G d�d�� d�e5�Z<G d�d�� d�e4�Z=G d�d�� d�e4�Z>G d�d�� d�e5�Z?G d�d�� d�e4�Z@G d�d�� d�e5�ZAG d�d�� d�e4�ZBG d�d�� d�e4�ZCG d�d�� d�e5�ZDG d�d�� d�e4�ZEG d�d�� d�e5�ZFG d�d�� d�e4�ZGG d�d�� d�e5�ZHG d�d�� d�e4�ZIG d�d�� d�e4�ZJG d�d d�e4�ZKG d�dĄ d�e5�ZLG d�dƄ d�e4�ZMG d�dȄ d�e5�ZNG d�dʄ d�e4�ZOG d�d̄ d�e5�ZPG d�d΄ d�e4e�ZQG d�dЄ d�e5e�ZRG d�d҄ d�e4�ZSG d�dԄ d�e4�ZTG d�dք d�e5�ZUG d�d d�e4�ZVG d�dڄ d�e4�ZWG d�d܄ d�e5�ZXG d�dބ d�e4�ZYG d�d� d�e5�ZZG d�d� d�e4�Z[G d�d� d�e5�Z\G d�d� d�e4�Z]G d�d� d�e5�Z^G d�d�� d�e4�Z_G d�d� d�e4�Z`G d�d� d�e4�ZaG d�d� d�e5�ZbG d�d� d�e4�ZcG d�d� d�e4�ZdG d�d�� d�e4�ZeG d�d�� d�e4�ZfG d�d�� d�e4�ZgG d�d�� d�e5�ZhG d�d�� d�e4�ZiG d�d�� d�e5�ZjG d��d � �d e4�ZkG �d�d� �de4�ZlG �d�d� �de4�ZmG �d�d� �de5�ZnG �d�d� �d�ZoG �d �d � �d �Zp G �d �d � �d e(�ZqG �d �d� �der�ZsG �d�d� �der�ZtG �d�d� �deu�ZvG �d�d� �de!�ZwdS ( zs Driver for Microsoft Azure Virtual Machines service. http://azure.microsoft.com/en-us/services/virtual-machines/ � N)�minidom)�datetime)�escape)�ET�httplib�urlparse)�urlquote)� _real_unicode� ensure_string)� ReprMixin)�AzureRedirectException� AzureServiceManagementConnection)� LibcloudError)�Node�NodeSize� NodeImage� NodeDriver� NodeLocation� StorageVolume)� NodeState)�Providerzmanagement.core.windows.netz 2013-08-01z0Win|SQL|SharePoint|Visual|Dynamics|DynGP|BizTalkZA0Z ExtraSmallzExtra Small Instancei � z0.0211� ZShared)�id�name�ram�disk� bandwidth�price�max_data_disks�coresZA1ZSmallzSmall Instancei z0.0633� ZA2ZMediumzMedium Instancei z0.1266� ZA3ZLargezLarge Instancei z0.2531� ZA4Z ExtraLargezExtra Large Instancei 8 z0.5062� ZA5zMemory Intensive Instancez0.2637ZA6z A6 Instancei p z0.5273ZA7z A7 Instancei � z1.0545ZA8z A8 Instancez2.0774ZA9z A9 Instancei � z4.7137ZA10z A10 Instancez1.2233ZA11z A11 Instancez2.1934ZD1Z Standard_D1zD1 Faster Compute Instancez0.0992ZD2Z Standard_D2zD2 Faster Compute Instancez0.1983ZD3Z Standard_D3zD3 Faster Compute Instancez0.3965ZD4Z Standard_D4zD4 Faster Compute Instancez0.793ZD11Z Standard_D11zD11 Faster Compute Instancez0.251Z Standard_D12zD12 Faster Compute Instancez0.502Z Standard_D13zD13 Faster Compute Instancez0.9038Z Standard_D14zD14 Faster Compute Instancez1.6261� )ZD12ZD13ZD14Z include_apisZ IncludeAPIsZ message_idZ MessageIdZ content_md5z Content-MD5� last_modifiedz Last-Modified� cache_controlz Cache-Control�account_admin_live_email_idZAccountAdminLiveEmailId�service_admin_live_email_idZServiceAdminLiveEmailId�subscription_idZSubscriptionID�fqdnZFQDN� private_idZ PrivateID�os_virtual_hard_disk�OSVirtualHardDisk�logical_disk_size_in_gb�LogicalDiskSizeInGB�logical_size_in_gbZLogicalSizeInGB�os�OS�persistent_vm_downtime_info�PersistentVMDowntimeInfoZcopy_idZCopyId�os_disk_configuration�OSDiskConfiguration�is_dns_programmedZIsDnsProgrammedc s� e Zd ZeZdZdZejZ e Z dZ ddgiZ e�dddg�Zi dej�d ej�d ej�d ej�d ej�d ej�dej�dej�dej�dej�dej�dej�dej�dej�dej�dej�dej�deji�Zd�� fdd � Zd d � Zd�d d �Zd!d"� Z d#d$� Z d�d%d&�Z d�d'd(�Z ) * + d�d,d-�Z d�d.d/�Z!d0d1� Z"d�d2d3�Z#d4d5� Z$d�d6d7�Z%d�d8d9�Z& d�d:d;�Z'd<d=� Z( d>d?� Z)d@dA� Z*dBdC� Z+dDdE� Z,dFdG� Z- dHdI� Z.dJdK� Z/dLdM� Z0dNdO� Z1d�dPdQ�Z2dRdS� Z3dTdU� Z4dVdW� Z5dXdY� Z6dZd[� Z7d\d]� Z8d�d^d_�Z9d�d`da�Z:dbdc� Z;ddde� Z<dfdg� Z=d�dhdi�Z>d�djdk�Z?dldm� Z@dndo� ZAdpdq� ZBdrds� ZCdtdu� ZDdvdw� ZEdxdy� ZFdzd{� ZGd|d}� ZHd~d� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�d��ZVd�d�� ZWd�d�� ZXd�d�d��ZYd�d�� ZZd�d�d��Z[d�d�d��Z\d�d�d��Z]d�d�d��Z^d�d�d��Z_d�d�d��Z`d�d�d��Zad�d�d��Zbd�d�� Zc� ZdS )��AzureNodeDriverzAzure Virtual machinesz;http://azure.microsoft.com/en-us/services/virtual-machines/z.blob.core.windows.net� create_node�password�service_location�is_affinity_groupZRoleStateUnknownZ CreatingVMZ StartingVMZ ProvisioningZ CreatingRoleZ StartingRoleZ ReadyRoleZBusyRoleZ StoppingRoleZ StoppingVMZ DeletingVMZ StoppedVMZRestartingRoleZ CyclingRoleZFailedStartingRoleZFailedStartingVMZUnresponsiveRoleZStoppedDeallocatedNc s< || _ || _|�dd�| _t� j| j | jfddi|�� dS )z� subscription_id contains the Azure subscription id in the form of GUID key_file contains the Azure X509 certificate in .pem form �follow_redirectsTZsecureN)r* �key_file�getr> �super�__init__)�selfr* r? �kwargs�� __class__� �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/compute/drivers/azure.pyrB G s "zAzureNodeDriver.__init__c C s6 g }| j �� D ]\}}| �t�|��}|�|� q|S )zP Lists all sizes :rtype: ``list`` of :class:`NodeSize` )�_instance_types�items� _to_node_size�copy�deepcopy�append)rC Zsizes�_�valuesZ node_sizerG rG rH � list_sizesQ s zAzureNodeDriver.list_sizesc sh �� ��� t�}�� ��� t�}�fdd�|D �}|��fdd�|D �� � dur2� fdd�|D �}|S )zR Lists all images :rtype: ``list`` of :class:`NodeImage` c � g | ]}� � |��qS rG )� _to_image)�.0�i�rC rG rH � <listcomp>i � z/AzureNodeDriver.list_images.<locals>.<listcomp>c 3 s � | ]}� � |�V qd S �N)� _vm_to_image)rT �jrV rG rH � <genexpr>j s � z.AzureNodeDriver.list_images.<locals>.<genexpr>Nc s g | ] }� |j d v r|�qS ��location)�extra)rT �imager] rG rH rW m s )� _perform_get�_get_image_path�Images�_get_vmimage_path�VMImages�extend)rC r^ �dataZcustom_image_dataZimagesrG )r^ rC rH � list_images_ s zAzureNodeDriver.list_imagesc s( � � d� j d t�}� fdd�|D �S )zX Lists all locations :rtype: ``list`` of :class:`NodeLocation` �/z /locationsc rR rG )� _to_location)rT r^ rV rG rH rW y rX z2AzureNodeDriver.list_locations.<locals>.<listcomp>)ra r* � Locations�rC rg rG rV rH �list_locationsq s z AzureNodeDriver.list_locationsc s� �� ��� �d d�}��|d� ��|t�}d�t|j�dkr3|jd jdur3dd� |jd jD ��z� ��fdd�|jd jD �W S t yN g Y S w )a� List all nodes ex_cloud_service_name parameter is used to scope the request to a specific Cloud Service. This is a required parameter as nodes cannot exist outside of a Cloud Service nor be shared between a Cloud Service within Azure. :param ex_cloud_service_name: Cloud Service name :type ex_cloud_service_name: ``str`` :rtype: ``list`` of :class:`Node` z?embed-detail=TrueN�� r c S � g | ]}|j �qS rG )�address)rT �viprG rG rH rW � � z.AzureNodeDriver.list_nodes.<locals>.<listcomp>c s g | ] }�� |� ���qS rG )�_to_node)rT �n��ex_cloud_service_namerC ZvipsrG rH rW � s ��) ra �_get_hosted_service_path�raise_for_response�_parse_response� HostedService�len� deployments� virtual_ips�role_instance_list� IndexError)rC rv �responserg rG ru rH � list_nodes{ s � � �zAzureNodeDriver.list_nodesc C s� |du r|j dur|j �d�}|std��|sd}| j||d�j}z$| �| �||�d t|j� d d�}| � |d � | � |�rCW d S W d S t yO Y d S w ) ah Reboots a node. ex_cloud_service_name parameter is used to scope the request to a specific Cloud Service. This is a required parameter as nodes cannot exist outside of a Cloud Service nor be shared between a Cloud Service within Azure. :param ex_cloud_service_name: Cloud Service name :type ex_cloud_service_name: ``str`` :param ex_deployment_slot: Options are "production" (default) or "Staging". (Optional) :type ex_deployment_slot: ``str`` :rtype: ``bool`` Nrv z"ex_cloud_service_name is required.� Production�� service_name�deployment_slotz/roleinstances/z ?comp=reboot� �� TF) r_ r@ � ValueError�_get_deploymentr � _perform_post� _get_deployment_path_using_name�_strr rx � _parse_response_for_async_op� Exception)rC �noderv �ex_deployment_slot�_deployment_namer� rG rG rH � reboot_node� s< �� ���� �zAzureNodeDriver.reboot_nodec s( �� ��� t�}� �fdd�|D �}|S )a Lists volumes of the disks in the image repository that are associated with the specified subscription. Pass Node object to scope the list of volumes to a single instance. :rtype: ``list`` of :class:`StorageVolume` c s g | ] }�j |� d ��qS ))�volumer� )� _to_volume)rT �v�r� rC rG rH rW � s z0AzureNodeDriver.list_volumes.<locals>.<listcomp>)ra �_get_disk_path�Disks)rC r� rg ZvolumesrG r� rH � list_volumes� s z AzureNodeDriver.list_volumesFr� � azureuserc # K s~ | � | �} | j}t|t�std��t|t�std��| j|d�}| du r(t� }n| }d|_| r5| j | d�} t � |j t j�r�t||| d�}d|_|rK|rNd}n)t�d d �}| j||d �}|jD ]}d d � |jD �}||v rvt�d d �}||v slq^tdd|dddd�}nM|r�|r�d}n4t�d d �}| j||d �}|jD ]#}g }|jdur�|jD ]}||jg7 }q�||v r�t�d d �}||v s�q�tdd|dddd�}t|| |d| �}|jj�|� | j |d�}|du r�|}t j dd|� � t j d�}| j |d�r�| j!||j"|j#d� |�r|�rX|�s |}d}d}|j$�%dd��r|j }nd| } d�&||t'�(d ��} d �&| | �} t)|j | �}| �*| �+|�t,�-||||||d |dd|j | |� �} | �.| d � | �/| � nW| j||d �j0} d}d}|j$�%dd��rp|j }nd| } d�&||t'�(d ��} d �&| | �} t)|j | �}| �1|| �}!t,�2|||d |dd||j � }"| �*|!|"�} | �.| d � | �/| � t3||t4j5g g | j6j7d |id!�S )"a- Create Azure Virtual Machine Reference: http://bit.ly/1fIsCb7 [www.windowsazure.com/en-us/documentation/] We default to: + 3389/TCP - RDP - 1st Microsoft instance. + RANDOM/TCP - RDP - All succeeding Microsoft instances. + 22/TCP - SSH - 1st Linux instance + RANDOM/TCP - SSH - All succeeding Linux instances. The above replicates the standard behavior of the Azure UI. You can retrieve the assigned ports to each instance by using the following private function: _get_endpoint_ports(service_name) Returns public,private port key pair. @inherits: :class:`NodeDriver.create_node` :keyword image: The image to use when creating this node :type image: `NodeImage` :keyword size: The size of the instance to create :type size: `NodeSize` :keyword ex_cloud_service_name: Required. Name of the Azure Cloud Service. :type ex_cloud_service_name: ``str`` :keyword ex_storage_service_name: Optional: Name of the Azure Storage Service. :type ex_storage_service_name: ``str`` :keyword ex_new_deployment: Optional. Tells azure to create a new deployment rather than add to an existing one. :type ex_new_deployment: ``boolean`` :keyword ex_deployment_slot: Optional: Valid values: production| staging. Defaults to production. :type ex_deployment_slot: ``str`` :keyword ex_deployment_name: Optional. The name of the deployment. If this is not passed in we default to using the Cloud Service name. :type ex_deployment_name: ``str`` :type ex_custom_data: ``str`` :keyword ex_custom_data: Optional script or other data which is injected into the VM when it's beginning provisioned. :keyword ex_admin_user_id: Optional. Defaults to 'azureuser'. :type ex_admin_user_id: ``str`` :keyword ex_virtual_network_name: Optional. If this is not passed in no virtual network is used. :type ex_virtual_network_name: ``str`` :keyword ex_network_config: Optional. The ConfigurationSet to use for network configuration :type ex_network_config: `ConfigurationSet` z$Size must be an instance of NodeSizezAImage must be an instance of NodeImage, produced by list_images())rv N�NetworkConfiguration)rg )� computer_name�admin_password�admin_user_nameZ3389i� i�� r� c S ro rG )� public_port)rT �eprG rG rH rW d rr z/AzureNodeDriver.create_node.<locals>.<listcomp>�Remote DesktopZtcpF)r �protocol�port� local_port� load_balanced_endpoint_set_name�enable_direct_server_returnZ22�SSH)r� z[\W_-]+r� )�flags)r� r^ r= �vm_imagez http://%s.blob.core.windows.netz {}-{}-{}.vhdz%Y-%m-%dz {}/vhds/{}�PersistentVMRoler� rv �r r �state� public_ipsZ private_ips�driverr_ )8Z_get_and_check_authr; � isinstancer r� r r� �ConfigurationSet�configuration_set_type�_encode_base64�WINDOWS_SERVER_REGEX�searchr �re�I�WindowsConfigurationSet� domain_join�random�randintr� r~ �instance_endpoints� ConfigurationSetInputEndpointr� �LinuxConfigurationSet�input_endpointsrJ rN �_get_cloud_service_location�sub�lower�UNICODE�_is_storage_service_unique�_create_storage_accountr< r= r_ r@ �format�time�strftimer. r� r� �AzureXmlSerializer�!virtual_machine_deployment_to_xmlrx �"_ex_complete_async_azure_operationr �_get_role_path�add_role_to_xmlr r �PENDING� connectionr� )#rC r �sizer` rv Zex_storage_service_nameZex_new_deploymentr� Zex_deployment_nameZex_admin_user_idZex_custom_dataZex_virtual_network_nameZex_network_configZauthrD r; Z node_list�network_configZmachine_configr� � endpointsZ instancesZports�endpointr� Z_storage_locationZ vm_image_idZ disk_configZblob_url� disk_name� media_linkr� r� �path�bodyrG rG rH r: � s: Y � � ��� � ��� � � � � �� ��� � �zAzureNodeDriver.create_nodec C s� t |t�s td��|du r|jdur|j�d�}|s td��| j||d�}|j}t|j�}|dkr:| � |||j �}n| � ||�}|d7 }| � |� dS ) a� Remove Azure Virtual Machine This removes the instance, but does not remove the disk. You will need to use destroy_volume. Azure sometimes has an issue where it will hold onto a blob lease for an extended amount of time. :keyword ex_cloud_service_name: Required. Name of the Azure Cloud Service. :type ex_cloud_service_name: ``str`` :keyword ex_deployment_slot: Optional: The name of the deployment slot. If this is not passed in we default to production. :type ex_deployment_slot: ``str`` z#A libcloud Node object is required.Nrv z.Unable to get ex_cloud_service_name from Node.r� r z ?comp=mediaT) r� r r� r_ r@ r� r r{ r~ r� r r� �_perform_delete)rC r� rv r� Z _deploymentr� Z_server_deployment_countr� rG rG rH � destroy_node s" � z AzureNodeDriver.destroy_nodec C s | � | �� t�S rY )ra rw �HostedServicesrV rG rG rH �ex_list_cloud_services4 � z&AzureNodeDriver.ex_list_cloud_servicesc C s6 | � | �� t�|| �|�||d|��}| �|d� dS )a� Create an azure cloud service. :param name: Name of the service to create :type name: ``str`` :param location: Standard azure location string :type location: ``str`` :param description: Optional description :type description: ``str`` :param extended_properties: Optional extended_properties :type extended_properties: ``dict`` :rtype: ``bool`` N�� T)� _perform_cloud_service_createrw r� � create_hosted_service_to_xmlr� rx )rC r r^ � description�extended_propertiesr� rG rG rH �ex_create_cloud_service7 s �� z'AzureNodeDriver.ex_create_cloud_servicec C � | � | �|��}| �|d� dS )z� Delete an azure cloud service. :param name: Name of the cloud service to destroy. :type name: ``str`` :rtype: ``bool`` rn T)� _perform_cloud_service_deleterw rx �rC r r� rG rG rH �ex_destroy_cloud_serviceZ s z(AzureNodeDriver.ex_destroy_cloud_servicec C s0 dd� |j d D �}|�|� | �|||�}|S )Nc S s" g | ] }|j |j|j|jd ��qS ))r r� r� r� )r r� r� r� )rT r� rG rG rH rW j s ���z=AzureNodeDriver.ex_add_instance_endpoints.<locals>.<listcomp>r� )r_ rf �ex_set_instance_endpoints)rC r� r� r� Z all_endpoints�resultrG rG rH �ex_add_instance_endpointsi s � z)AzureNodeDriver.ex_add_instance_endpointsc C s� |j d }|j}t� }d|_|D ]}tdi |��}|jj�|� q| j||d�j} | � | � || |�t � dddd|dddd� �} | � | d� dS )a� For example:: endpoint = ConfigurationSetInputEndpoint( name='SSH', protocol='tcp', port=port, local_port='22', load_balanced_endpoint_set_name=None, enable_direct_server_return=False ) { 'name': 'SSH', 'protocol': 'tcp', 'port': port, 'local_port': '22' } rv r� r� Nr� r� rG )r_ r r� r� r� r� rJ rN r� � _perform_putr� r� r� rx ) rC r� r� r� rv Z vm_role_namer� r� Z new_endpointr� r� rG rG rH r� y s6 �� ��z)AzureNodeDriver.ex_set_instance_endpointsc C s8 | � | �� tj|| �|�||||d��}| �|d� dS )a� Create an azure storage service. :param name: Name of the service to create :type name: ``str`` :param location: Standard azure location string :type location: ``str`` :param description: (Optional) Description of storage service. :type description: ``str`` :param affinity_group: (Optional) Azure affinity group. :type affinity_group: ``str`` :param extended_properties: (Optional) Additional configuration options support by Azure. :type extended_properties: ``dict`` :rtype: ``bool`` �r� �labelr� r^ �affinity_groupr� r� T)� _perform_storage_service_create�_get_storage_service_pathr� � create_storage_service_to_xmlr� rx )rC r r^ r� r� r� r� rG rG rH �ex_create_storage_service� s �� z)AzureNodeDriver.ex_create_storage_servicec C r� )aw Destroy storage service. Storage service must not have any active blobs. Sometimes Azure likes to hold onto volumes after they are deleted for an inordinate amount of time, so sleep before calling this method after volume deletion. :param name: Name of storage service. :type name: ``str`` :rtype: ``bool`` rn T)� _perform_storage_service_deleter� rx r� rG rG rH �ex_destroy_storage_service� s z*AzureNodeDriver.ex_destroy_storage_servicec C � t d��)Nz6You cannot create snapshots of Azure VMs at this time.��NotImplementedErrorrV rG rG rH �create_volume_snapshot� � z&AzureNodeDriver.create_volume_snapshotc C r� )Nz,attach_volume is not supported at this time.r� rV rG rG rH � attach_volume� r� z AzureNodeDriver.attach_volumec C r� )Nz,create_volume is not supported at this time.r� rV rG rG rH � create_volume� r� z AzureNodeDriver.create_volumec C r� )Nz,detach_volume is not supported at this time.r� rV rG rG rH � detach_volume� r� z AzureNodeDriver.detach_volumec C r� )Nz-destroy_volume is not supported at this time.r� rV rG rG rH �destroy_volume� r� z AzureNodeDriver.destroy_volumec C �J t � }d|_t|_||_||_| �|�\|_|_| �|�|_ | � |�}|S �N�POST� �AzureHTTPRequest�method� AZURE_SERVICE_MANAGEMENT_HOST�hostr� r� �_update_request_uri_query�query�_update_management_header�headers�_perform_request�rC r� rg �requestr� rG rG rH r� � z-AzureNodeDriver._perform_cloud_service_createc C �D t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}|S �N�DELETE� r r r r r� r r r r r �rC r� r r� rG rG rH r� � z-AzureNodeDriver._perform_cloud_service_deletec C r� r� r� r rG rG rH r� r z/AzureNodeDriver._perform_storage_service_createc C r r r r rG rG rH r� % r z/AzureNodeDriver._perform_storage_service_deletec C s� d}d}|pg }|j dur1t|j �dkr|j d jg}|j D ]}|jdkr(|j}|jdkr0|j}q t|j|j| j�|j t j �||j g| j j|j |||j|j|d�d�S ) zK Convert the data from a Azure response object into a Node r� Nr r r� r� )r� �remote_desktop_port�ssh_port� power_state� instance_sizerv r� )r� r{ rq r r� r � role_name�NODE_STATE_MAPr@ �instance_statusr �UNKNOWN� ip_addressr� r� r r )rC rg rv r} r r r� r� rG rG rH rs 0 s6 ���zAzureNodeDriver._to_nodec C sr |j }d|j v r d}d|j v rd}d|j v rd}d|j v r d}d|j v r&d}|jj}t|j|j || jj|j|d�S )zO Convert the data from a Azure response object into a location ZAsiaZEuropeZUSZJapanZBrazil)r r �countryr� �available_services�virtual_machine_role_sizes)� display_name�compute_capabilities�virtual_machines_role_sizes�AzureNodeLocationr r� r� r )rC rg r Z vm_role_sizesrG rG rH rj U s( �z AzureNodeDriver._to_locationc C sB t |d |d |d |d |d |d | jj|d |d d �d �S ) zH Convert the AZURE_COMPUTE_INSTANCE_TYPES into NodeSize r r r r r r r r )r r )r r r r r r r� r_ )r r� r� rl rG rG rH rK u s �z AzureNodeDriver._to_node_sizec C s4 t |j|j| jj|j|j|j|j|j |j dd�d�S )NF)r2 �categoryr� r^ r� r� r� �r r r� r_ ) r r r� r� r� r2 r" r� r^ r� r� rl rG rG rH rS � s ��zAzureNodeDriver._to_imagec C s8 t |j|j| jj|jj|j|j|jj |j |j dd�d�S )NT)r2 r" r^ r� r� �deployment_namer� r# ) r r r� r� r� r6 r2 r" r^ r� r� r$ rl rG rG rH rZ � s ��z AzureNodeDriver._vm_to_imagec C s� |j |j|j|j|jd�}t|jdd �}t|jdd �}t|jdd �}|d ur*||d< |d ur2||d< |d ur:||d< |rY|d urU||jkrWt|j |j t |j �| j j |d�S d S d S t|j |j t |j �| j j |d�S )N)r� r2 r^ r� �source_image_namer �hosted_service_namer$ )r r r� r� r_ )r� r2 r^ r� r% �getattr� attached_tor r r �intr/ r� r� )rC r� r� r_ r r& r$ rG rG rH r� � s@ ��� �zAzureNodeDriver._to_volumec K s< |d }|d }| � | �||�d �}| �|d� | �|t�S )Nr� r� rn )ra � _get_deployment_path_using_slotrx ry � Deployment)rC rD Z _service_nameZ_deployment_slotr� rG rG rH r� � s � z AzureNodeDriver._get_deploymentc C sf |st d��| �d| �|� t�}|jj}|jj}|d ur'|dkr'| �d|�S |d ur1| �d|�S d S )N�service_name is required.z%s?embed-detail=Falser� TF)r� ra rw rz �hosted_service_propertiesr� r^ r< )rC r� �resZ_affinity_groupZ_cloud_service_locationrG rG rH r� � s � z+AzureNodeDriver._get_cloud_service_locationc C s< |st d��| �d| �� t|�df t�}| �|d� |jS )Nr, z %s/operations/isavailable/%s%sr� rn )r� ra r� r� �AvailabilityResponserx r� )rC r� Z_check_availabilityrG rG rH r� � s �� z*AzureNodeDriver._is_storage_service_uniquec K s� |d du r)| � | �� t�|d |d | �|d �|d d dd ��}| �|d� n"| � | �� t�|d |d | �|d �d |d dd ��}| �|d� | �|d� d S )Nr= Tr� r^ r� Zcreate_storage_account)r� r� r� �#create_storage_service_input_to_xmlr� rx r� )rC rD r� rG rG rH r� � s8 �� �� z'AzureNodeDriver._create_storage_accountc C s | � d| j d t|� t�S )Nri z /operations/)ra r* r� � Operation�rC � request_idrG rG rH �_get_operation_status s �z%AzureNodeDriver._get_operation_statusc C sX t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}|d ur*| � ||�S |S )N�GET) r r r r r� r r r r r ry )rC r� � response_typer r� rG rG rH ra $ s z AzureNodeDriver._perform_getc C �T t � }d|_t|_||_t| �|��|_| �|�\|_|_ | � |�|_ | � |�}|S r� � r r r r r� r �_get_request_bodyr� r r r r r �rC r� r� r6 r r� rG rG rH r� 2 � z AzureNodeDriver._perform_postc C r7 )N�PUTr8 r: rG rG rH r� > r; z AzureNodeDriver._perform_putc C sP t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}| � |d� d S )Nr r� ) r r r r r� r r r r r rx r rG rG rH r� J s z AzureNodeDriver._perform_deletec C s| z| j j|j|j|j|jd�W S ty0 } zt�|j�}|j |_ | � |�W Y d }~S d }~w t y= } z|�d }~ww )N)�actionrg r r ) r� r r� r� r r r r r^ �netlocr r r� )rC r �eZ parsed_urlrG rG rH r U s � ���z AzureNodeDriver._perform_requestc C s� d|j v r/|j �d�\|_ }}|r/|�d�}|D ]}d|v r.|�d�\}}}|j�||f� qt|j d�|_ |jrc| j d7 _ |jD ]\}}|durZ| j d�|t|d�d�7 _ qC|j dd� |_ |j |jfS )a pulls the query string out of the URI and moves it into the query portion of the request object. If there are already query parameters on the request the parameters in the URI will appear after the existing parameters �?�&�=z/()$=',Nz{}={}{}���)r� � partition�splitr rN � url_quoter� )rC r rO Z query_stringZ query_paramsr r �valuerG rG rH r d s$ � � z)AzureNodeDriver._update_request_uri_queryc C sX |j dv rtt|j��|jd< |j dvr)|jD ] }d|�� kr# |jS qd|jd< |jS )z8 Add additional headers for management. )r< r� ZMERGEr zContent-Length)r5 �HEADz content-typezapplication/xmlz Content-Type)r �strr{ r� r r� )rC r �keyrG rG rH r � s � z)AzureNodeDriver._update_management_headerc C s | j ||d�S )zj Parse the HTTPResponse's body and fill all the data into a class of return_type. )r� � return_type)�"_parse_response_body_from_xml_text)rC r� rK rG rG rH ry � s z AzureNodeDriver._parse_responsec C sB |j }t�|�}|� }| �||j�D ]}| �||� q|j|_|S �zQ parse the xml and fill all the data into a class of return_type )r� r Z parseString�_get_child_nodes�__name__�_fill_data_to_return_object�status)rC r� rK Zrespbody�doc� return_objr� rG rG rH rL � s z2AzureNodeDriver._parse_response_body_from_xml_textc s � fdd�� � |�D �S )Nc s g | ] }|j � kr|�qS rG )Z parentNode)rT Z childNode�r� rG rH rW � s �z4AzureNodeDriver._get_child_nodes.<locals>.<listcomp>)ZgetElementsByTagName)rC r� Ztag_namerG rT rH rN � s �z AzureNodeDriver._get_child_nodesc C sL t t|��}|�� D ]�\}}t|t�r!t||| �||j|j�� q t|t �r8t||| � ||j| � |�|j�� q t|t �rQt||| � || � |�|j|j|j�� q t|t�rct||| �|||j�� q t|t �rvt||| �|| � |��� q t|t�r�| �||d�}|d ur�| �|�}t|||� q | �|||�}|d ur�t|||� q d S �Nr� )�dict�varsrJ r� �_ListOf�setattr� _fill_list_of� list_type�xml_element_name� ScalarListOf�_fill_scalar_list_of�_get_serialization_name�_DictOf� _fill_dict_of�pair_xml_element_name�key_xml_element_name�value_xml_element_name�WindowsAzureData�_fill_instance_childrF � _fill_dict� _Base64String�_fill_data_minidom�_decode_base64_to_text)rC r� rS �membersr rG rG rG rH rP � sj � �� �� � � ��z+AzureNodeDriver._fill_data_to_return_objectc s �� ||�}� �fdd�|D �S )Nc � g | ]}�� |� ��qS rG )�"_parse_response_body_from_xml_node�rT � xmlelement�� element_typerC rG rH rW � s ��z1AzureNodeDriver._fill_list_of.<locals>.<listcomp>�rN )rC �xmldocrq r\ � xmlelementsrG rp rH rZ � s �z AzureNodeDriver._fill_list_ofc C s |� }| � ||� |S rM )rP )rC r� rK rS rG rG rH rm � s z2AzureNodeDriver._parse_response_body_from_xml_nodec s8 �� ||�}|r�� |d |�}� �fdd�|D �S d S )Nr c rl rG )�_get_node_valuern rp rG rH rW s z8AzureNodeDriver._fill_scalar_list_of.<locals>.<listcomp>rr )rC rs rq �parent_xml_element_namer\ rt rG rp rH r^ � s �z$AzureNodeDriver._fill_scalar_list_ofc C s6 |j j}|tu r | �|�S |tu r|�� dkS ||�S )N�false)� firstChild� nodeValuer � _to_datetime�boolr� )rC ro Z data_typerG rG rG rH ru s z AzureNodeDriver._get_node_valuec C s| t �|�}|dur |S |�d�r|�dd�S |�d�r!|�dd�}dD ] }|�|�r0|�dd�}q#d �d d � |�d�D ��S ) zB Converts a Python name into a serializable name. NZx_ms_rO �-Z_id�ID)Zcontent_r& Zif_r' z-_r� c s s � | ]}|� � V qd S rY )� capitalize)rT r rG rG rH r\ ! s � z:AzureNodeDriver._get_serialization_name.<locals>.<genexpr>)�_KNOWN_SERIALIZATION_XFORMSr@ � startswith�replace�endswith�joinrE )rC � element_nameZknownr rG rG rH r_ s �z'AzureNodeDriver._get_serialization_namec C sr i }| � ||�}|r7| � |d |�}|D ]"}| � ||�} | � ||�} | r6| r6| d jj} | d jj} | || < q|S �Nr )rN rx ry ) rC rs rv rb rc rd rS rt �pair�keysrP rJ rG rG rG rH ra # s �z AzureNodeDriver._fill_dict_ofc C s4 | � || �|��}|s dS |� }| �|d |� |S )zT Converts a child of the current dom element to the specified type. Nr )rN r_ rP )rC rs r� rK rt rS rG rG rH rf ; s z$AzureNodeDriver._fill_instance_childc C s@ | � ||�}|r i }|d jD ] }|jr|jj||j< q|S d S r� )rN � childNodesrx ry ZnodeName)rC rs r� rt rS �childrG rG rH rg I s ��zAzureNodeDriver._fill_dictc C s( t |t�r |�d�}t�|�}|�d�S �N�utf-8)r� � _unicode_type�encode�base64� b64encode�decode)rC rg �encodedrG rG rH r� S s z AzureNodeDriver._encode_base64c C s t |t�r |�d�}t�|�S r� )r� r� r� r� � b64decoderl rG rG rH �_decode_base64_to_bytesY s z'AzureNodeDriver._decode_base64_to_bytesc C s | � |�}|�d�S r� )r� r� )rC rg Z decoded_bytesrG rG rH rj ^ s z&AzureNodeDriver._decode_base64_to_textc C s� | � || �|��}|r|d jsd S |d jj}|d u r |S t|t�r(| �|�S t|�t u r4|� � dkS t|�t u r>t |�S t|�|�S )Nr rw ) rN r_ r� rx ry r� r rz �typer{ r� rI r )rC rs r� Z data_memberrt rG rG rG rH ri b s z"AzureNodeDriver._fill_data_minidomc C s t �|d�S )Nz%Y-%m-%dT%H:%M:%S.%f)r �strptime)rC ZstrtimerG rG rH rz u � z AzureNodeDriver._to_datetimec C sb |d u rdS t |t�r| �|�}t |t�r|S t |t�r!|�d�S t|�}t |t�r/|�d�S |S )N� r� )r� re �_convert_class_to_xml�bytesr� r� rI )rC Z request_bodyrG rG rH r9 x s z!AzureNodeDriver._get_request_bodyTc C s, t �� }| �||�}tt j|ddd��}|S )Nr� �xml)�encodingr )r �Element�_construct_element_treer �tostring)rC �sourceZ xml_prefix�rootrR r� rG rG rH r� � s z%AzureNodeDriver._convert_class_to_xmlc C s� |d u rt �� S t|t�r |D ] }|�| �||�� q|S t|t�rm|jj}|�t �|�� t |�� � D ]0\}}|d urdt|t�sFt|t�rP|�| �||�� q4t �| � |��}t t |��|_|�|� q4|�t �|�� |S rY )r r� r� �listrN r� re rF rO rW rJ r_ � xml_escaperI �text)rC r� ZetreerG � class_namer ZelerG rG rH r� � s& � �z'AzureNodeDriver._construct_element_treec C sB |d u rd S t � }|jr |j�� D ] \}}|�� dkr ||_q|S )Nzx-ms-request-id)�AsynchronousOperationResultr rJ r� r3 )rC r� r� r rG rG rG rH r� � s �z,AzureNodeDriver._parse_response_for_async_opc C s$ dt |�dg}d�|�}| �||�S )N�services/hostedservices/z /deploymentsr� �r� r� � _get_path)rC r� r$ � components�resourcerG rG rH r� � s z/AzureNodeDriver._get_deployment_path_using_namec C s. d| j d | }|d ur|dt|� 7 }|S )Nri )r* r� )rC r� r r� rG rG rH r� � s zAzureNodeDriver._get_pathc C � | � d|�S )Nzservices/images�r� �rC Z image_namerG rG rH rb � r� z AzureNodeDriver._get_image_pathc C r� )Nzservices/vmimagesr� r� rG rG rH rd � r� z!AzureNodeDriver._get_vmimage_pathc C r� )Nzservices/hostedservicesr� �rC r� rG rG rH rw � r� z(AzureNodeDriver._get_hosted_service_pathc C s | � dt|� |�S )Nz*services/hostedservices/%s/deploymentslots)r� r� )rC r� ZslotrG rG rH r* � s �z/AzureNodeDriver._get_deployment_path_using_slotc C r� )Nzservices/disksr� )rC r� rG rG rH r� � r� z AzureNodeDriver._get_disk_pathc C s( dt |�d|dg}d�|�}| �||�S )Nr� z /deployments/z/rolesr� r� )rC r� r$ r r� r� rG rG rH r� � s � z AzureNodeDriver._get_role_pathc C r� )Nzservices/storageservicesr� r� rG rG rH r� � r� z)AzureNodeDriver._get_storage_service_pathc C s� | � |�}| �|j�}d}d}d}|jdkr7||k r7| �|�}|jdkr%n||7 }t�|� |jdkr7||k s|jdkrFtd| | jjd��d S ) Ni, r � Z InProgressZ SucceededZFailedz2Message: Async request for operation %s has failed�r� ) r� r4 r3 rQ r� �sleepr r� r� )rC r� Zoperation_typer3 Zoperation_status�timeout�waittime�intervalrG rG rH r� � s$ � ��z2AzureNodeDriver._ex_complete_async_azure_operationc C s2 |j |kr|j|j|j f}d| }t|| d��d S )Nz&Message: %s, Body: %s, Status code: %sr� )rQ �errorr� r )rC r� Zvalid_responserP �messagerG rG rH rx � s �z"AzureNodeDriver.raise_for_response�NNrY ) NFr� Nr� NNNN)Nr� )r� )NNN)T)Nr: )erO � __module__� __qualname__r Z connectionClsr Zwebsiter ZAZUREr� � AZURE_COMPUTE_INSTANCE_TYPESrI Z _blob_urlZfeatures� collections� namedtupler< r r r� ZRUNNINGZSTOPPEDZ REBOOTINGZ TERMINATEDr rB rQ rh rm r� r� r� r: r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rs rj rK rS rZ r� r� r� r� r� r4 ra r� r� r� r r r ry rL rN rP rZ rm r^ ru r_ ra rf rg r� r� rj ri rz r9 r� r� r� r� r� rb rd rw r* r� r� r� r� rx � __classcell__rG rG rE rH r9 % s ��������� � � � � ������ # 2 � (/ # 6 �. % ) % 9 r9 c C s | � � S rY )r� )r� rG rG rH �_lower r� r� c @ s� e Zd Zedd� �Zedd� �Zedd� �Zedd� �Ze dHd d ��Ze dId d ��Z edd� �Z edd� �Z edd� �Z edd� �Z edd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Zed*d+� �Zed,d-� �Zed.d/� �Zed0d1� �Zed2d3� �Z ed4d5� �Z ed6d7� �Z ed8d9� �Z ed:d;� �Z ed<d=� �Z!ed>d?� �Z"edId@dA��Z#edIdBdC��Z$edIdDdE��Z%edFdG� �Z&d S )Jr� c C s4 t �dd| fd|fd|fd|fd|fd|tfg|�S )N�CreateStorageServiceInput� ServiceName� Description�Label� AffinityGroup�Location�GeoReplicationEnabled�r� � doc_from_datar� )r� r� r� r� r^ �geo_replication_enabledr� rG rG rH r0 s ��z6AzureXmlSerializer.create_storage_service_input_to_xmlc C s& t �dd| fd|tjfd|tfg|�S )NZUpdateStorageServiceInputr� r� r� �r� r� r9 r� r� )r� r� r� r� rG rG rH �#update_storage_service_input_to_xml" s ��z6AzureXmlSerializer.update_storage_service_input_to_xmlc C � t �dd| fg�S )NZRegenerateKeysZKeyType�r� r� )Zkey_typerG rG rH �regenerate_keys_to_xml0 � z)AzureXmlSerializer.regenerate_keys_to_xmlc C s t �dd| tjfd|fg|�S )NZUpdateHostedServicer� r� �r� r� r9 r� )r� r� r� rG rG rH � update_hosted_service_to_xml4 s ��z/AzureXmlSerializer.update_hosted_service_to_xmlNc C sP |rt �dd| fd|fd|fd|fg|�S t �dd| fd|fd|fd|fg|�S )NZCreateHostedServicer� r� r� r� r� r� r� rG rG rH r� ? s& �� ��z/AzureXmlSerializer.create_hosted_service_to_xmlc C s, t �dd| fd|fd|fd|fd|fg|�S )Nr� r� r� r� r� r� r� r� rG rG rH r� _ s ��z0AzureXmlSerializer.create_storage_service_to_xmlc C s: t �dd| fd|fd|tjfd|fd|tfd|tfg|�S )NZCreateDeployment�Name� PackageUrlr� � ConfigurationZStartDeployment�TreatWarningsAsErrorr� )r � package_urlr� � configurationZstart_deployment�treat_warnings_as_errorr� rG rG rH �create_deployment_to_xmlt s ��z+AzureXmlSerializer.create_deployment_to_xmlc C s t �dd| fd|fg�S )NZSwapr� ZSourceDeploymentr� )� productionZsource_deploymentrG rG rH �swap_deployment_to_xml� s �z)AzureXmlSerializer.swap_deployment_to_xmlc C r� )NZUpdateDeploymentStatusZStatusr� )rQ rG rG rH � update_deployment_status_to_xml� r� z2AzureXmlSerializer.update_deployment_status_to_xmlc C s" t �dd| fd|tfd|fg|�S )NZChangeConfigurationr� r� �Moder� )r� r� �moder� rG rG rH �change_deployment_to_xml� s ��z+AzureXmlSerializer.change_deployment_to_xmlc C s8 t �dd| fd|fd|fd|tjfd|fd|tfg|�S )NZUpgradeDeploymentr� r� r� r� Z RoleToUpgrade�Forcer� )r� r� r� r� Zrole_to_upgrade�forcer� rG rG rH �upgrade_deployment_to_xml� s ��z,AzureXmlSerializer.upgrade_deployment_to_xmlc C s t �dd| fd|tfg�S )NZRollbackUpdateOrUpgrader� r� r� )r� r� rG rG rH �rollback_upgrade_to_xml� s �z*AzureXmlSerializer.rollback_upgrade_to_xmlc C r� )NZWalkUpgradeDomainZ UpgradeDomainr� )Zupgrade_domainrG rG rH �walk_upgrade_domain_to_xml� s �z-AzureXmlSerializer.walk_upgrade_domain_to_xmlc C � t �dd| fd|fd|fg�S )NZCertificateFileZDataZCertificateFormat�Passwordr� )rg Zcertificate_formatr; rG rG rH �certificate_file_to_xml� � ��z*AzureXmlSerializer.certificate_file_to_xmlc C s( t �dd| fd|tjfd|fd|fg�S )NZCreateAffinityGroupr� r� r� r� r� )r r� r� r^ rG rG rH � create_affinity_group_to_xml� s ��z/AzureXmlSerializer.create_affinity_group_to_xmlc C s t �dd| tjfd|fg�S )NZUpdateAffinityGroupr� r� r� )r� r� rG rG rH � update_affinity_group_to_xml� s ��z/AzureXmlSerializer.update_affinity_group_to_xmlc C r� )N�SubscriptionCertificateZ SubscriptionCertificatePublicKeyZ!SubscriptionCertificateThumbprintZSubscriptionCertificateDatar� )Z public_key� thumbprintrg rG rG rH � subscription_certificate_to_xml� r� z2AzureXmlSerializer.subscription_certificate_to_xmlc C s$ t �dd| fd|fd|fd|fg�S )N�OSImager� � MediaLinkr� r3 r� )r� r� r r2 rG rG rH �os_image_to_xml� s �z"AzureXmlSerializer.os_image_to_xmlc C s6 t �dd| fd|fd|fd|fd|fd|fd|fg�S ) N�DataVirtualHardDisk� HostCaching� DiskLabel�DiskName�Lunr0 r� ZSourceMediaLinkr� )� host_caching� disk_labelr� �lunr/ r� Zsource_media_linkrG rG rH � data_virtual_hard_disk_to_xml� s ��z0AzureXmlSerializer.data_virtual_hard_disk_to_xmlc C s, t �dd| tfd|fd|fd|fd|fg�S )N�DiskZHasOperatingSystemr� r� r� r3 r� )�has_operating_systemr� r� r r2 rG rG rH � disk_to_xml s ��z AzureXmlSerializer.disk_to_xmlc C �2 t �d�} d| _t�d| �}tt j|dd��}|S )N� OperationTypeZRestartRoleOperationr� �r� �r r� r� r� � doc_from_xmlr r� �r� rR r� rG rG rH � restart_role_operation_to_xml � z0AzureXmlSerializer.restart_role_operation_to_xmlc C r� )Nr� ZShutdownRoleOperationr� r� r� r rG rG rH � shutdown_role_operation_to_xml$ r z1AzureXmlSerializer.shutdown_role_operation_to_xmlc C r� )Nr� ZStartRoleOperationr� r� r� r rG rG rH �start_role_operation_to_xml, r z.AzureXmlSerializer.start_role_operation_to_xmlc C s� t �d| jfg|� t �d| jfg|� t �d| jfg|� t �d| jtfg|� t �d| jtfg|� t �d| jfg|� | j d ur�t � d�}t � d�}|� |� |� |� t �d | j jjfg|� t �d | j jjfg|� t �d | j jjfg|� t �d | j jfg|� t �d | j jfg|� | jd ur�t �d�}|� |� | jD ],}t �d�}|� |� |� t �d|jfg�� t �d|jfg|� t �d|jfg|� q�t �d| jfg|� |S )N�ConfigurationSetTypeZ ComputerNameZ AdminPasswordZResetPasswordOnFirstLogonZEnableAutomaticUpdatesZTimeZone� DomainJoin� CredentialsZDomainZUsernamer� Z JoinDomainZMachineObjectOU�StoredCertificateSettings�CertificateSettingZ StoreLocationZ StoreNameZ ThumbprintZ AdminUsername)r� � data_to_xmlr� r� r� � reset_password_on_first_logonr� �enable_automatic_updates� time_zoner� r r� ZappemndrN � credentials�domain�usernamer; � join_domain�machine_object_ou�stored_certificate_settingsr� �store_location� store_namer� r� )r� r� r ZcredsZ cert_settings�certZ cert_settingrG rG rH � windows_configuration_to_xml4 sp ���� ��� ���� � �z/AzureXmlSerializer.windows_configuration_to_xmlc C sb t �d| jfg|� t �d| jfg|� t �d| jfg|� t �d| jfg|� t �d| jtfg|� | jd ur�t � d�}t � d�}t � d�}|� |� |� |� |� |� | jj D ] }t � d �}|� |� t �d |j fg|� t �d |jfg|� qZ| jjD ] }t � d �}|� |� t �d |j fg|� t �d |jfg|� q| jd ur�t �d | jfg|� |S )Nr ZHostNameZUserNameZ UserPasswordZ DisableSshPasswordAuthenticationr� � PublicKeys�KeyPairs� PublicKeyZ Fingerprint�PathZKeyPairZ CustomData)r� r r� � host_name� user_name� user_password�#disable_ssh_password_authenticationr� �sshr r� rN � public_keys� fingerprintr� � key_pairs� custom_data)r� r� r! ZpkeysZkpairsrJ ZpkeyZkpairrG rG rH �linux_configuration_to_xml} sD ���� z-AzureXmlSerializer.linux_configuration_to_xmlc C sf t �d| jfg|� t�d�}|�|� | jD ]�}t�d�}|�|� t �d|jfg|� t �d|jfg|� t �d|j fg|� t �d|j fg|� |j j sW|j j sW|j j r�t�d�}|�|� t �d |j j fg|� t �d|j j fg|� t �d |j j fg|� t �d |j fg|� t �d |jtfg|� qt�d �}|�|� | jD ] }t �d |fg|� q�|S )Nr �InputEndpoints� InputEndpointZLoadBalancedEndpointSetNameZ LocalPortr� ZPort�LoadBalancerProber �ProtocolZEnableDirectServerReturnZ SubnetNames� SubnetName)r� r r� r r� rN r� r� r� r r� �load_balancer_prober� r� r� r� � subnet_names)r� r� r� r� Zinput_endpointr, r- r rG rG rH � network_configuration_to_xml� sd � ��� ��� �� ���� z/AzureXmlSerializer.network_configuration_to_xmlc C s2 t �d|fg| � t �d|fg| � t�d�} | �| � |d urAt�d�} | �| � t|t�r6t �|| � n t|t�rAt � || � |d urUt�d�} | �| � t � || � | d urbt �d| fg| � |d ur�t�d�} | �| � |D ]H} t�d�}| �|� t �d| j fg|� t �d | j fg|� t �d | j fg|� t �d | jfg|� t �d | jfg|� t �d | jfg|� qr|d ur�t�d�} | �| � t �d|j fg| � t �d |j fg| � t �d |j fg| � t �d |jfg| � t �d|jfg| � |d u�r t �d|fg| � |d u�rt �d|fg| � | S )NZRoleNameZRoleType�ConfigurationSetsr� ZAvailabilitySetNameZDataVirtualHardDisksr� r� r� r� r� r0 r� r. ZSourceImageNameZ VMImageName�RoleSize)r� r r r� rN r� r� r r� r& r. r� r� r� r� r/ r� r% )�availability_set_name�data_virtual_hard_disks�network_configuration_setr- � vm_image_namer � role_size� role_type�system_configuration_setr� Z config_setsZ config_setZvhdsZhdZvhdrG rG rH � role_to_xml� s` � � � z AzureXmlSerializer.role_to_xmlc C s< t �d�} t �|||||| |||| � } ttj| dd��} | S �Nr� r� r� �r� r r8 r r r� ) r r7 r- r6 r3 r1 r2 r4 r5 rR r� r� rG rG rH r� 3 s � z"AzureXmlSerializer.add_role_to_xmlc C s< t �d�}t �|||||| ||d |� ttj|dd��} | S r9 r: ) r r- r6 r3 r1 r2 r4 r5 rR r� rG rG rH �update_role_to_xmlO s � z%AzureXmlSerializer.update_role_to_xmlc C s� t �dg�}t �d| fg|� |d ur4t�d�}|�|� t|t�r)t �||� n t|t�r4t � ||� t �d|fg|� t �d|fg|� t � d|�}t tj |dd��}|S ) N)r� �CaptureRoleOperationZPostCaptureActionZProvisioningConfigurationZTargetImageLabelZTargetImageNamer< r� r� ) r� r r r� rN r� r� r r� r& r r r� )Zpost_capture_actionZtarget_image_nameZtarget_image_labelZprovisioning_configurationr� Zprovisioning_configrR r� rG rG rH �capture_role_to_xmlk s$ � � z&AzureXmlSerializer.capture_role_to_xmlc C s� t �d�} t �d| fg| � t �d|fg| � t �d|fg| � t�d�}t�d�}|�|� | �|� t �|| ||| || |||� | d urQ| �t �d| fg�� ttj| dd ��}|S ) Nr+ r� ZDeploymentSlotr� �RoleList�RoleZVirtualNetworkNamer� r� ) r� r r r r� rN r8 r r� )r$ r� r� r r7 r- r6 r3 r1 r2 r5 Zvirtual_network_namer4 rR � role_listZroler� rG rG rH r� � s4 � �z4AzureXmlSerializer.virtual_machine_deployment_to_xmlc C s� | D ]B}|d }|d }t |�dkr|d }nd}|durD|dur*t|t|���}nt|�}t�|�}||_|dur@|�|� q| S q|S )a Creates an xml fragment from the specified data. data: Array of tuples, where first: xml element name second: xml element text third: conversion function r r r! N)r{ r� r r� r� rN )rg r� �elementr �val� converterr� �entryrG rG rH r � s" � z AzureXmlSerializer.data_to_xmlc C s. t �| �}|�dd� |dur|�|� |S )zf Wraps the specified xml in an xml root element with default azure namespaces Zxmlnsz)http://schemas.microsoft.com/windowsazureN)r r� �setrN )�document_element_nameZ inner_xmlr� rG rG rH r � s z AzureXmlSerializer.doc_from_xmlc C sD t �| �}t �||� |d ur|�t �|�� ttj|dd��}|S )Nr� r� )r� r r rN �(extended_properties_dict_to_xml_fragmentr r r� )rF rg r� rR r� rG rG rH r� � s �z AzureXmlSerializer.doc_from_datac C s� | d urBt | �dkrDt�d�}| �� D ],\}}t�d�}t�d�}t|�|_t�d�}t|�|_|�|� |�|� |�|� q|S d S d S )Nr ZExtendedProperties�ExtendedPropertyr� �Value)r{ r r� rJ r� r� rN )r� r� rJ rB Zextended_propertyr rG rG rG rH rG � s �z;AzureXmlSerializer.extended_properties_dict_to_xml_fragmentr� rY )'rO r� r� � staticmethodr0 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r& r. r8 r� r; r= r� r r r� rG rG rG rG rH r� s� � � H + ? I . r� c @ s e Zd ZdZdS )re ze This is the base of data class. It is only used to check whether it is instance or not. N)rO r� r� �__doc__rG rG rG rH re s re c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zdd � ZdS ) �WindowsAzureDataTypedListNc C s t | j| j�| _d S rY )rX r[ r\ rJ rV rG rG rH rB s z"WindowsAzureDataTypedList.__init__c C � t | j�S rY )�iterrJ rV rG rG rH �__iter__# � z"WindowsAzureDataTypedList.__iter__c C rM rY )r{ rJ rV rG rG rH �__len__& rP z!WindowsAzureDataTypedList.__len__c C s | j | S rY )rJ )rC �indexrG rG rH � __getitem__) rP z%WindowsAzureDataTypedList.__getitem__) rO r� r� r[ r\ rB rO rQ rS rG rG rG rH rL s rL c @ � e Zd Z ddd�ZdS )r. Nc C s( || _ || _|| _|| _|| _d| _d S rU )r% r� r� r� r� r2 )rC r% r� r� r� r� rG rG rH rB . s zOSVirtualHardDisk.__init__�NNNNN�rO r� r� rB rG rG rG rH r. - � �c @ rT )r� Nc C s0 d| _ || _|| _|| _|| _t� | _|| _d S )NZ LinuxProvisioningConfiguration)r� r r r r r� r! r% )rC r r r r r% rG rG rH rB ? s z LinuxConfigurationSet.__init__rU rV rG rG rG rH r� > rW r� c @ s" e Zd Z ddd�ZdS )r� Nc C s> d| _ || _|| _|| _|| _|| _|| _t� | _t � | _ d S )NZ WindowsProvisioningConfiguration) r� r� r� r r r r� r r� r r )rC r� r� r r r r� rG rG rH rB Q s z WindowsConfigurationSet.__init__)NNNNNNrV rG rG rG rH r� P � �r� c @ � e Zd Zdd� ZdS )r c C s t � | _d| _d| _d S rU )r r r r rV rG rG rH rB f s zDomainJoin.__init__NrV rG rG rG rH r e � r c @ rY )r c C � d| _ d| _d| _d S rU )r r r; rV rG rG rH rB m � zCredentials.__init__NrV rG rG rG rH r l rZ r c @ s e Zd ZdZddd�ZdS )r a� Initializes a certificate setting. thumbprint: Specifies the thumbprint of the certificate to be provisioned. The thumbprint must specify an existing service certificate. store_name: Specifies the name of the certificate store from which retrieve certificate. store_location: Specifies the target certificate store location on the virtual machine The only supported value is LocalMachine. r� c C s || _ || _|| _d S rY )r� r r )rC r� r r rG rG rH rB � r\ zCertificateSetting.__init__N)r� r� r� )rO r� r� rK rB rG rG rG rH r s s r c @ � e Zd ZeZdgZdS )r rJ N)rO r� r� r r[ �_repr_attributesrG rG rG rH r � � r c @ rY )r� c C s t � | _t� | _d S rY )r r" r r$ rV rG rG rH rB � s z SSH.__init__NrV rG rG rG rH r� � rZ r� c @ � e Zd Zddd�ZdS )r r� c C � || _ || _d S rY �r# r� �rC r# r� rG rG rH rB � � zPublicKey.__init__N�r� r� rV rG rG rG rH r � � r c @ r] )r rJ N)rO r� r� r r[ r^ rG rG rG rH r � r_ r c @ r` )� AzureKeyPairr� c C ra rY rb rc rG rG rH rB � rd zAzureKeyPair.__init__Nre rV rG rG rG rH rg � rf rg c @ r] )r rJ N)rO r� r� rg r[ r^ rG rG rG rH r � r_ r c @ rY )r) c C r[ rU )r� r� r� rV rG rG rH rB � r\ zLoadBalancerProbe.__init__NrV rG rG rG rH r) � rZ r) c @ rY )r� c C s$ d| _ d| _t� | _ttd�| _d S )Nr� r+ )r� r6 � ConfigurationSetInputEndpointsr� r] rI r- rV rG rG rH rB � s zConfigurationSet.__init__NrV rG rG rG rH r� � rZ r� c @ r] )r/ rJ N)rO r� r� r� r[ r^ rG rG rG rH r/ � r_ r/ c @ s" e Zd Z ddd�ZdS )r� r� Fc C s0 || _ || _|| _|| _|| _t� | _|| _d S rY )r� r� r� r r� r) r, r� )rC r r� r� r� r� r� rG rG rH rB � s z&ConfigurationSetInputEndpoint.__init__N)r� r� r� r� r� FrV rG rG rG rH r� � rX r� c @ s e Zd ZeZdZdgZdS )rh r( rJ N)rO r� r� r� r[ r\ r^ rG rG rG rH rh � s rh c @ rY )r� c C s$ d| _ d| _ttd�| _t� | _d S )Nr� ZAvailableService)r r r] rI r �ComputeCapabilityr rV rG rG rH rB � s zLocation.__init__NrV rG rG rG rH r� � rZ r� c @ r] )rk rJ N)rO r� r� r� r[ r^ rG rG rG rH rk � r_ rk c @ rY )ri c C � t td�| _d S �Nr0 )r] rI r rV rG rG rH rB � r� zComputeCapability.__init__NrV rG rG rG rH ri � rZ ri c @ rY )�VirtualMachinesRoleSizesc C rj rk )r] rI r5 rV rG rG rH rB � r� z!VirtualMachinesRoleSizes.__init__NrV rG rG rG rH rl � rZ rl c @ rY )r� c C s@ d| _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d S �Nr� r ) r� r" r^ r1 r� r� r r2 Zeular� rV rG rG rH rB � s zOSImage.__init__NrV rG rG rG rH r� � rZ r� c @ r] )rc rJ N)rO r� r� r� r[ r^ rG rG rG rH rc r_ rc c @ rY )�VMImagec C s< d| _ d| _d| _t� | _d| _d| _d| _d| _d| _ d S rU ) r r� r" r7 r6 r� r$ r r^ r� rV rG rG rH rB s zVMImage.__init__NrV rG rG rG rH rn rZ rn c @ r] )re rJ N)rO r� r� rn r[ r^ rG rG rG rH re r_ re c @ rY )� VirtualIPc C r[ rU )rp r8 r rV rG rG rH rB r\ zVirtualIP.__init__NrV rG rG rG rH ro rZ ro c @ r] )� VirtualIPsrJ N)rO r� r� ro r[ r^ rG rG rG rH rp ! r_ rp c @ s e Zd ZddgZdd� ZdS )rz r� �urlc C s d| _ d| _t� | _t� | _d S rU )rq r� �HostedServicePropertiesr- � Deploymentsr| rV rG rG rH rB * s zHostedService.__init__N)rO r� r� r^ rB rG rG rG rH rz ' s rz c @ r] )r� rJ N)rO r� r� rz r[ r^ rG rG rG rH r� 1 r_ r� c @ rY )rr c C s> d| _ d| _d| _t� | _d| _d| _d| _tddd�| _ d S )Nr� rH r� rI ) r� r^ r� rh r� rQ Z date_createdZdate_last_modifiedr` r� rV rG rG rH rB 8 s z HostedServiceProperties.__init__NrV rG rG rG rH rr 7 rZ rr c @ rY )r+ c C s� d| _ d| _d| _d| _t� | _d| _t� | _t� | _ t � | _ d| _ t � | _d| _t� | _d| _d| _t� | _d| _d| _tddd�| _t� | _d S )Nr� FrH r� rI ) r r� r, rQ rh r� rq r� �RoleInstanceListr~ � UpgradeStatusZupgrade_statusZupgrade_domain_countr> r@ Z sdk_versionr' Zinput_endpoint_list�lockedZrollback_allowedr5 r4 Z created_timeZlast_modified_timer` r� rp r} rV rG rG rH rB D s( zDeployment.__init__NrV rG rG rG rH r+ C rZ r+ c @ r] )rs rJ N)rO r� r� r+ r[ r^ rG rG rG rH rs [ r_ rs c @ rY )ru c C r[ rU )Z upgrade_typeZ current_upgrade_domain_stateZcurrent_upgrade_domainrV rG rG rH rB b r\ zUpgradeStatus.__init__NrV rG rG rG rH ru a rZ ru c @ rY )� RoleInstancec C sT d| _ d| _d| _d| _d| _d| _d| _d| _d| _t � | _ d| _ d| _ d| _ d S rm )r Z instance_namer Zinstance_upgrade_domainZinstance_fault_domainr Zinstance_state_detailsZinstance_error_coder �InstanceEndpointsr� r r+ r rV rG rG rH rB i s zRoleInstance.__init__NrV rG rG rG rH rw h rZ rw c @ r] )rt rJ N)rO r� r� rw r[ r^ rG rG rG rH rt y r_ rt c @ rY )�InstanceEndpointc C s" d| _ d| _d| _d| _d| _d S rU )r rq r� r� r� rV rG rG rH rB � s zInstanceEndpoint.__init__NrV rG rG rG rH ry rZ ry c @ r] )rx rJ N)rO r� r� ry r[ r^ rG rG rG rH rx � r_ rx c @ rY )r( c C r[ rU )r rq r� rV rG rG rH rB � r\ zInputEndpoint.__init__NrV rG rG rG rH r( � rZ r( c @ r] )r' rJ N)rO r� r� r( r[ r^ rG rG rG rH r' � r_ r' c @ rY )r? c C � d| _ d| _d S rU )r � os_versionrV rG rG rH rB � rd z Role.__init__NrV rG rG rG rH r? � rZ r? c @ r] )r> rJ N)rO r� r� r? r[ r^ rG rG rG rH r> � r_ r> c @ rY )r5 c C r[ rU )Z start_timeZend_timerQ rV rG rG rH rB � r\ z!PersistentVMDowntimeInfo.__init__NrV rG rG rG rH r5 � rZ c @ s e Zd Zddd�ZdS )r� Nc C s || _ d S rY )r3 r2 rG rG rH rB � rP z$AsynchronousOperationResult.__init__rY rV rG rG rG rH r� � rf r� c @ rY )r� c C sH d| _ t� | _d| _d| _d| _d| _d| _d| _d| _ d| _ d| _ d S rm ) r� � AttachedTor( r� Z is_corruptedr^ r/ r� r� r r2 r% rV rG rG rH rB � s z Disk.__init__NrV rG rG rG rH r� � rZ r� c @ r] )r� rJ N)rO r� r� r� r[ r^ rG rG rG rH r� � r_ r� c @ rY )r| c C r[ rU )r& r$ r rV rG rG rH rB � r\ zAttachedTo.__init__NrV rG rG rG rH r| � rZ r| c @ rY )�OperationErrorc C rz rU )�coder� rV rG rG rH rB � rd zOperationError.__init__NrV rG rG rG rH r} � rZ r} c @ rY )r1 c C s d| _ d| _d| _t� | _d S rU )r rQ Zhttp_status_coder} r� rV rG rG rH rB � s zOperation.__init__NrV rG rG rG rH r1 � rZ r1 c @ rY )�OperatingSystemc C s, d| _ t� | _d| _d| _d| _t� | _d S )Nr� Tr )�versionrh r� Z is_defaultZ is_active�familyZ family_labelrV rG rG rH rB � s zOperatingSystem.__init__NrV rG rG rG rH r � rZ r c @ rY )r7 c C s( d| _ d| _d| _d| _d| _d| _d S rm )r r� Zos_stater2 r� r/ rV rG rG rH rB � s z OSDiskConfiguration.__init__NrV rG rG rG rH r7 � rZ c @ r] )�OperatingSystemsrJ N)rO r� r� r r[ r^ rG rG rG rH r� � r_ r� c @ rY )�OperatingSystemFamilyc C s d| _ t� | _t� | _d S rU )r rh r� r� Zoperating_systemsrV rG rG rH rB � s z OperatingSystemFamily.__init__NrV rG rG rG rH r� � rZ r� c @ r] )�OperatingSystemFamiliesrJ N)rO r� r� r� r[ r^ rG rG rG rH r� � r_ r� c @ rY )� Subscriptionc C sX d| _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d| _ d| _ d| _ d| _ d S rm )r* Zsubscription_nameZsubscription_statusr( r) Zmax_core_countZmax_storage_accountsZmax_hosted_servicesZcurrent_core_countZcurrent_hosted_servicesZcurrent_storage_accountsZmax_virtual_network_sitesZmax_local_network_sitesZmax_dns_serversrV rG rG rH rB s zSubscription.__init__NrV rG rG rG rH r� rZ r� c @ rY )r/ c C s d| _ d S )NF)r� rV rG rG rH rB rP z AvailabilityResponse.__init__NrV rG rG rG rH r/ rZ r/ c @ rY )r� c C s d| _ d| _d| _d| _d S rU )Z#subscription_certificate_public_keyZ#subscription_certificate_thumbprintZ subscription_certificate_data�createdrV rG rG rH rB � z SubscriptionCertificate.__init__NrV rG rG rG rH r� rZ r� c @ r] )�SubscriptionCertificatesrJ N)rO r� r� r� r[ r^ rG rG rG rH r� # r_ r� c @ rY )r c C s. d| _ d| _d| _g | _i | _d| _d | _d S rU )r r r� r r r� Zprotocol_overriderV rG rG rH rB * s zAzureHTTPRequest.__init__NrV rG rG rG rH r ) rZ r c @ rY )�AzureHTTPResponsec C s || _ || _|| _|| _d S rY )rQ r� r r� )rC rQ r� r r� rG rG rH rB 5 r� zAzureHTTPResponse.__init__NrV rG rG rG rH r� 4 rZ r� c @ s e Zd ZdS )rh N)rO r� r� rG rG rG rH rh A s rh c s" e Zd ZdZd� fdd� Z� ZS )rX z� A list which carries with it the type that's expected to go in it. Used for deserializaion and construction of the lists Nc s, || _ |d u r |j| _n|| _t� �� d S rY )r[ rO r\ rA rB �rC r[ r\ rE rG rH rB K s z_ListOf.__init__rY �rO r� r� rK rB r� rG rG rE rH rX E s rX c � e Zd ZdZ� fdd�Z� ZS )r] z� A list of scalar types which carries with it the type that's expected to go in it along with its xml element name. Used for deserializaion and construction of the lists c s || _ || _t� �� d S rY )r[ r\ rA rB r� rE rG rH rB [ s zScalarListOf.__init__r� rG rG rE rH r] T s r] c r� )r` z� A dict which carries with it the xml element names for key,val. Used for deserializaion and construction of the lists c s || _ || _|| _t� �� d S rY )rb rc rd rA rB )rC rb rc rd rE rG rH rB g s z_DictOf.__init__r� rG rG rE rH r` a s r` c s$ e Zd Z� fdd�Zdd� Z� ZS )r! c s" t � �||||� || _|| _d S rY )rA rB r r )rC r r r r� r r rE rG rH rB r s zAzureNodeLocation.__init__c C s. d| j | j| j| jjd�| j�d�| j�f S )Nzb<AzureNodeLocation: id=%s, name=%s, country=%s, driver=%s services=%s virtualMachineRoleSizes=%s >�,)r r r r� r� r r rV rG rG rH �__repr__w s ��zAzureNodeLocation.__repr__)rO r� r� rB r� r� rG rG rE rH r! n s r! )xrK r� rL r� r� r� r� Zxml.domr r Zxml.sax.saxutilsr r� Zlibcloud.utils.py3r r r r rF r r Zlibcloud.utils.miscr Zlibcloud.common.azurer r Zlibcloud.common.typesr Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr Zlibcloud.compute.providersr �HTTPSConnectionrI r� r� r Z X_MS_VERSION�compiler� r� r r9 r� r� re rL r. r� r� r r r r r� r r rg r r) r� r/ r� rh r� rk ri rl r� rc rn re ro rp rz r� rr r+ rs ru rw rt ry rx r( r' r? r> r5 r� r� r� r| r} r1 r r7 r� r� r� r� r/ r� r� r r� rh r� rX r] rV r` r! rG rG rG rH �<module> s� �� ���� ��)��3��=��G��Q��[��e��o��y�� � �� � �� � �� "� �� -� � � �� L�������� � � � � ������ c
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings