Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/azure.cpython-39.pyc
Ðазад
a q�hK� � @ sh d Z ddlZddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddlmZ ddlmZ ddlmZ dd lmZ dd lmZmZmZmZ dd lmZmZ dd l m Z dd l m Z ddlm Z ddlm!Z! ddlm"Z" ddlm#Z# ddlm$Z% ddl&m'Z' e!j(Z(ej)dk �r8e*Z+dd� Z,ne-Z,e-Z+dZ.dZ/e�0d�Z1ddd d dd d d d!�d"d#d$d dd%d&d d!�d'd(d)d dd*d+d&d!�d,d-d.d dd/d0d+d!�d1d2d3d dd4d5d0d!�d6d7d3d dd8d+d&d!�d9d:d;d dd<d0d+d!�d=d>d?d dd@d5d0d!�dAdBd?d ddCd5d0d!�dDdEdFd ddGd5d5d!�dHdId?d ddJd5d0d!�dKdLdFd ddMd5d5d!�dNdOd)d ddPd&d d!�dQdRd.d ddSd+d&d!�dTdUd3d ddVd0d+d!�dWdXd;d ddYd5d0d!�dZd[d3d dd\d+d&d!�d]d^d;d dd_d0d+d!�d`dad?d ddbd5d0d!�dcdddFd ddedfd5d!�dg�Z2dhdidjdkdldmdndodpdqdrdsdtdudvdwdxdydz�Z3G d{d|� d|e�Z4d}d~� Z5G dd�� d�e6�Z7G d�d�� d�e6�Z8G d�d�� d�e8�Z9G d�dr� dre8�Z:G d�d�� d�e8�Z;G d�d�� d�e8�Z<G d�d�� d�e8�Z=G d�d�� d�e8�Z>G d�d�� d�e8�Z?G d�d�� d�e9�Z@G d�d�� d�e8�ZAG d�d�� d�e8�ZBG d�d�� d�e9�ZCG d�d�� d�e8�ZDG d�d�� d�e9�ZEG d�d�� d�e8�ZFG d�d�� d�e8�ZGG d�d�� d�e9�ZHG d�d�� d�e8�ZIG d�d�� d�e9�ZJG d�d�� d�e8�ZKG d�d�� d�e9�ZLG d�d�� d�e8�ZMG d�d�� d�e8�ZNG d�d�� d�e8�ZOG d�d�� d�e9�ZPG d�d�� d�e8�ZQG d�d�� d�e9�ZRG d�d�� d�e8�ZSG d�d�� d�e9�ZTG d�d�� d�e8e'�ZUG d�d�� d�e9e'�ZVG d�d�� d�e8�ZWG d�d�� d�e8�ZXG d�dÄ d�e9�ZYG d�dń d�e8�ZZG d�dDŽ d�e8�Z[G d�dɄ d�e9�Z\G d�d˄ d�e8�Z]G d�d̈́ d�e9�Z^G d�dτ d�e8�Z_G d�dф d�e9�Z`G d�dӄ d�e8�ZaG d�dՄ d�e9�ZbG d�dv� dve8�ZcG d�d d�e8�ZdG d�dڄ d�e8�ZeG d�d܄ d�e9�ZfG d�dބ d�e8�ZgG d�d� d�e8�ZhG d�d� d�e8�ZiG d�d� d�e8�ZjG d�dx� dxe8�ZkG d�d� d�e9�ZlG d�d� d�e8�ZmG d�d� d�e9�ZnG d�d� d�e8�ZoG d�d� d�e8�ZpG d�d� d�e8�ZqG d�d� d�e9�ZrG d�d�� d�e6�ZsG d�d�� d�e6�ZtG d�d�� d�e-�ZuG d�d�� d�ev�ZwG d�d�� d�ev�ZxG d�d�� d�ey�ZzG �d �d� �de�Z{dS ( zs Driver for Microsoft Azure Virtual Machines service. http://azure.microsoft.com/en-us/services/virtual-machines/ � N)�datetime)�minidom)�escape)�ET)� AzureServiceManagementConnection)�AzureRedirectException)�Provider)�Node� NodeDriver� NodeLocation�NodeSize)� NodeImage� StorageVolume)� NodeState)� LibcloudError)� _real_unicode)�httplib)�urlparse)� ensure_string)�urlquote)� ReprMixin)� c C s t | t�r| �d�S t| �S �N�utf-8)� isinstance�unicode�encode�str)�value� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/azure.py�_str6 s r! zmanagement.core.windows.netz 2013-08-01z0Win|SQL|SharePoint|Visual|Dynamics|DynGP|BizTalkZ ExtraSmallzExtra Small Instancei � z0.0211� ZShared)�id�name�ram�disk� bandwidth�price�max_data_disks�coresZSmallzSmall Instancei z0.0633� ZMediumzMedium Instancei z0.1266� ZLargezLarge Instancei z0.2531� Z ExtraLargezExtra Large Instancei 8 z0.5062� �A5zMemory Intensive Instancez0.2637�A6z A6 Instancei p z0.5273�A7z A7 Instancei � z1.0545�A8z A8 Instancez2.0774�A9z A9 Instancei � z4.7137�A10z A10 Instancez1.2233�A11z A11 Instancez2.1934Z Standard_D1zD1 Faster Compute Instancez0.0992Z Standard_D2zD2 Faster Compute Instancez0.1983Z Standard_D3zD3 Faster Compute Instancez0.3965Z Standard_D4zD4 Faster Compute Instancez0.793Z Standard_D11zD11 Faster Compute Instancez0.251Z Standard_D12zD12 Faster Compute Instancez0.502Z Standard_D13zD13 Faster Compute Instancez0.9038Z Standard_D14zD14 Faster Compute Instancez1.6261� )ZA0�A1�A2ZA3ZA4r0 r1 r2 r3 r4 r5 r6 ZD1ZD2ZD3ZD4ZD11ZD12ZD13ZD14Z IncludeAPIsZ MessageIdz Content-MD5z Last-Modifiedz Cache-ControlZAccountAdminLiveEmailIdZServiceAdminLiveEmailIdZSubscriptionIDZFQDNZ PrivateID�OSVirtualHardDisk�LogicalDiskSizeInGBZLogicalSizeInGB�OS�PersistentVMDowntimeInfoZCopyId�OSDiskConfigurationZIsDnsProgrammed)Z include_apisZ message_idZ content_md5� last_modified� cache_control�account_admin_live_email_id�service_admin_live_email_id�subscription_id�fqdn� private_id�os_virtual_hard_disk�logical_disk_size_in_gb�logical_size_in_gb�os�persistent_vm_downtime_infoZcopy_id�os_disk_configuration�is_dns_programmedc s e Zd ZeZdZdZejZ e Z dZ ddgiZ e�dddg�Zejejejejejejejejejejejejejejejejejejd�Zd�� fd d � Zd d � Zd�dd�Zdd� Z dd� Z d�dd�Z d�dd�Z d�dd �Z d�d d �Z!d d � Z"d�d!d"�Z#d#d$� Z$d�d%d&�Z%d�d'd(�Z&d�d)d*�Z'd+d,� Z(d-d.� Z)d/d0� Z*d1d2� Z+d3d4� Z,d5d6� Z-d7d8� Z.d9d:� Z/d;d<� Z0d=d>� Z1d�d?d@�Z2dAdB� Z3dCdD� Z4dEdF� Z5dGdH� Z6dIdJ� Z7dKdL� Z8d�dMdN�Z9d�dOdP�Z:dQdR� Z;dSdT� Z<dUdV� Z=d�dWdX�Z>d�dYdZ�Z?d[d\� Z@d]d^� ZAd_d`� ZBdadb� ZCdcdd� ZDdedf� ZEdgdh� ZFdidj� ZGdkdl� ZHdmdn� ZIdodp� ZJdqdr� ZKdsdt� ZLdudv� ZMdwdx� ZNdydz� ZOd{d|� ZPd}d~� ZQdd�� 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_group)ZRoleStateUnknownZ CreatingVMZ StartingVMZ ProvisioningZ CreatingRoleZ StartingRoleZ ReadyRoleZBusyRoleZ StoppingRoleZ StoppingVMZ DeletingVMZ StoppedVMZRestartingRoleZ CyclingRoleZFailedStartingRoleZFailedStartingVMZUnresponsiveRoleZStoppedDeallocatedNc s@ || _ || _|�dd�| _tt| �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_redirectsT�secureN)rC �key_file�getrR �superrM �__init__)�selfrC rT �kwargs�� __class__r r rW S 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)rX �sizes�_�valuesZ node_sizer r r � list_sizesb s zAzureNodeDriver.list_sizesc sh �� ��� t�}�� ��� t�}�fdd�|D �}|��fdd�|D �� � durd� fdd�|D �}|S )zR Lists all images :rtype: ``list`` of :class:`NodeImage` c s g | ]}� � |��qS r )� _to_image)�.0�i�rX r r � <listcomp>} � z/AzureNodeDriver.list_images.<locals>.<listcomp>c 3 s | ]}� � |�V qd S �N)� _vm_to_image)rg �jri r r � <genexpr>~ rk z.AzureNodeDriver.list_images.<locals>.<genexpr>Nc s g | ]}� |j d v r|�qS ��location)�extra)rg �imagerp r r rj � s �)� _perform_get�_get_image_path�Images�_get_vmimage_path�VMImages�extend)rX rq �dataZcustom_image_dataZimagesr )rq rX r � list_imagesp s � �zAzureNodeDriver.list_imagesc s( � � d� j d t�}� fdd�|D �S )zX Lists all locations :rtype: ``list`` of :class:`NodeLocation` �/z /locationsc s g | ]}� � |��qS r )� _to_location)rg �lri r r rj � rk z2AzureNodeDriver.list_locations.<locals>.<listcomp>)rt rC � Locations�rX rz r ri r �list_locations� s �z AzureNodeDriver.list_locationsc s� �� ��� �d d�}��|d� ��|t�}d�t|j�dkrf|jd jdurfdd� |jd jD ��z � ��fdd�|jd jD �W S t y� g Y S 0 dS )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 s g | ] }|j �qS r )�address)rg �vipr r r rj � rk z.AzureNodeDriver.list_nodes.<locals>.<listcomp>c s g | ]}�� |� ���qS r )�_to_node)rg �n��ex_cloud_service_namerX Zvipsr r rj � s �) rt �_get_hosted_service_path�raise_for_response�_parse_response� HostedService�len� deployments� virtual_ips�role_instance_list� IndexError)rX r� �responserz r r� r � list_nodes� s& �� � � zAzureNodeDriver.list_nodesc C s� |du r |j dur |j �d�}|s*td��|s2d}| j||d�j}zL| �| �||�d t|j� d d�}| � |d � | � |�r�W d S W d S W n t y� Y d S 0 dS ) 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`` Nr� z"ex_cloud_service_name is required.� Production�� service_name�deployment_slotz/roleinstances/z ?comp=reboot� �� TF) rr rU � ValueError�_get_deploymentr% � _perform_post� _get_deployment_path_using_namer! r$ r� � _parse_response_for_async_op� Exception)rX �noder� �ex_deployment_slot�_deployment_namer� r r r � reboot_node� sB ������� 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)rg �v�r� rX r r rj � rk z0AzureNodeDriver.list_volumes.<locals>.<listcomp>)rt �_get_disk_path�Disks)rX r� rz Zvolumesr r� r � list_volumes� s z AzureNodeDriver.list_volumesFr� � azureuserc # K s� | � | �} | j}t|t�s"td��t|t�s4td��| j|d�}| du rPt� }n| }d|_| rj| j | d�} t � |j t j�r�t||| d�}d|_|r�|r�d}nLt�d d �}| j||d �}|jD ]*}d d � |jD �}||v r�t�d d �}q�q�tdd|dddd�}n�|�r |�rd}nlt�d d �}| j||d �}|jD ]J}g }|jdu�r^|jD ]}||jg7 }�qJ||v �r0t�d d �}�q^�q0tdd|dddd�}t|| |d| �}|jj�|� | j |d�}|du �r|}t j dd|� � t j d�}| j |d��r| j!||j"|j#d� |�r|�r�|�s|}d}d}|j$�%dd��r8|j }n4d| } d||t&�'d �f } d | | f } t(|j | �}| �)| �*|�t+�,||||||d |dd|j | |� �} | �-| d � | �.| � n�| j||d �j/} d}d}|j$�%dd��r�|j }n4d| } d||t&�'d �f } d | | f } t(|j | �}| �0|| �}!t+�1|||d |dd||j � }"| �)|!|"�} | �-| d � | �.| � t2||t3j4g g | j5j6d |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())r� N�NetworkConfiguration)rz )� computer_name�admin_password�admin_user_nameZ3389i� i�� r� c S s g | ] }|j �qS r )� public_port)rg �epr r r rj rk 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� rq rQ �vm_imagez http://%s.blob.core.windows.netz %s-%s-%s.vhdz%Y-%m-%dz %s/vhds/%s�PersistentVMRoler� r� �r$ r% �state� public_ipsZ private_ips�driverrr )7Z_get_and_check_authrO r r 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_endpointsr] ra �_get_cloud_service_location�sub�lower�UNICODE�_is_storage_service_unique�_create_storage_accountrP rQ rr rU �time�strftimer: r� r� �AzureXmlSerializer�!virtual_machine_deployment_to_xmlr� �"_ex_complete_async_azure_operationr% �_get_role_path�add_role_to_xmlr r �PENDING� connectionr� )#rX r% �sizers r� Zex_storage_service_nameZex_new_deploymentr� Zex_deployment_nameZex_admin_user_idZex_custom_dataZex_virtual_network_nameZex_network_config�authrY rO Z node_list�network_configZmachine_configr� � endpointsZ instancesZports�endpointr� Z_storage_locationZ vm_image_idZ disk_configZblob_url� disk_name� media_linkr� r� �path�bodyr r r rN s\ N �� � � �� � ��� ��� �� �� ��� � ��zAzureNodeDriver.create_nodec C s� t |t�std��|du r0|jdur0|j�d�}|s<td��| j||d�}|j}t|j�}|dkrt| � |||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.Nr� z.Unable to get ex_cloud_service_name from Node.r� r# z ?comp=mediaT) r r r� rr rU r� r% r� r� r� r$ r� �_perform_delete)rX r� r� r� Z _deploymentr� Z_server_deployment_countr� r r r � destroy_node2 s2 � �� z AzureNodeDriver.destroy_nodec C s | � | �� t�S rl )rt r� �HostedServicesri r r r �ex_list_cloud_servicesj s �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_creater� r� � create_hosted_service_to_xmlr� r� )rX r% rq � description�extended_propertiesr� r r r �ex_create_cloud_servicep s �� z'AzureNodeDriver.ex_create_cloud_servicec C s | � | �|��}| �|d� dS )z� Delete an azure cloud service. :param name: Name of the cloud service to destroy. :type name: ``str`` :rtype: ``bool`` r� T)� _perform_cloud_service_deleter� r� �rX r% r� r r r �ex_destroy_cloud_service� 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� )rg r� r r r rj � s ��z=AzureNodeDriver.ex_add_instance_endpoints.<locals>.<listcomp>r� )rr ry �ex_set_instance_endpoints)rX r� r� r� Z all_endpoints�resultr r r �ex_add_instance_endpoints� s � �z)AzureNodeDriver.ex_add_instance_endpointsc C s� |j d }|j}t� }d|_|D ] }tf i |��}|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' } r� r� r� Nr� r� )rr r% r� r� r� r� r] ra r� � _perform_putr� r� r� r� ) rX r� r� r� r� Z vm_role_namer� r� Z new_endpointr� r� r r r r� � s< ����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� rq �affinity_groupr� r� T)� _perform_storage_service_create�_get_storage_service_pathr� � create_storage_service_to_xmlr� r� )rX r% rq r� r� r� r� r r r �ex_create_storage_service� s �� z)AzureNodeDriver.ex_create_storage_servicec C s | � | �|��}| �|d� dS )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`` r� T)� _perform_storage_service_deleter� r� r� r r r �ex_destroy_storage_service s � z*AzureNodeDriver.ex_destroy_storage_servicec C s t d��d S )Nz6You cannot create snapshots of Azure VMs at this time.��NotImplementedErrorri r r r �create_volume_snapshot2 s �z&AzureNodeDriver.create_volume_snapshotc C s t d��d S )Nz,attach_volume is not supported at this time.r ri r r r � attach_volume8 s �z AzureNodeDriver.attach_volumec C s t d��d S )Nz,create_volume is not supported at this time.r ri r r r � create_volume> s �z AzureNodeDriver.create_volumec C s t d��d S )Nz,detach_volume is not supported at this time.r ri r r r � detach_volumeD s �z AzureNodeDriver.detach_volumec C s t d��d S )Nz-destroy_volume is not supported at this time.r ri r r r �destroy_volumeJ s �z AzureNodeDriver.destroy_volumec C sJ 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�rX r� rz �requestr� r r r r� T s z-AzureNodeDriver._perform_cloud_service_createc C sD t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}|S �N�DELETE� r r r r r� r r r r r �rX r� r r� r r r r� ` s z-AzureNodeDriver._perform_cloud_service_deletec C sJ t � }d|_t|_||_||_| �|�\|_|_| �|�|_ | � |�}|S r r r r r r r� k s z/AzureNodeDriver._perform_storage_service_createc C sD t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}|S r r r r r r r� w s z/AzureNodeDriver._perform_storage_service_deletec C s� d}d}|pg }|j durbt|j �dkr6|j d jg}|j D ]$}|jdkrP|j}|jdkr<|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_sizer� r� )r� r� r� r% r� r � role_name�NODE_STATE_MAPrU �instance_statusr �UNKNOWN� ip_addressr� r� r r )rX rz r� r� r r r� r� r r r r� � s: ���zAzureNodeDriver._to_nodec C sr |j }d|j v rd}d|j v r"d}d|j v r0d}d|j v r>d}d|j v rLd}|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$ )rX rz r# Z vm_role_sizesr r r r} � 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� rr )r r� r� r� r r r r^ � s ��z AzureNodeDriver._to_node_sizec C s4 t |j|j| jj|j|j|j|j|j |j dd�d�S )NF)rI �categoryr� rq r� r� r� �r$ r% r� rr ) r r% r� r� r� rI r* r� rq r� r� r� r r r rf � s ��zAzureNodeDriver._to_imagec C s8 t |j|j| jj|jj|j|j|jj |j |j dd�d�S )NT)rI r* rq r� r� �deployment_namer� r+ ) r r% r� r� r� rK rI r* rq r� r� r, r� r r r rm � s ��z AzureNodeDriver._vm_to_imagec C s� |j |j|j|j|jd�}t|jdd �}t|jdd �}t|jdd �}|d urT||d< |d urd||d< |d urt||d< |r�|d ur�||jkr�t|j |j t |j �| j j |d�S n t|j |j t |j �| j j |d�S d S )N)r� rI rq r� �source_image_namer �hosted_service_namer, )r$ r% r� r� rr )r� rI rq r� r- �getattr� attached_tor$ r r% �intrG r� r� )rX r� r� rr r r. r, r r r r� � sN �����zAzureNodeDriver._to_volumec K s< |d }|d }| � | �||�d �}| �|d� | �|t�S )Nr� r� r� )rt � _get_deployment_path_using_slotr� r� � Deployment)rX rY Z _service_nameZ_deployment_slotr� r r r r� - s �� z AzureNodeDriver._get_deploymentc C sj |s t d��| �d| �|� t�}|jj}|jj}|d urN|dkrN| �d|�S |d urb| �d|�S d S d S )N�service_name is required.z%s?embed-detail=Falser� TF)r� rt r� r� �hosted_service_propertiesr� rq rP )rX r� �resZ_affinity_groupZ_cloud_service_locationr r r r� = s �� z+AzureNodeDriver._get_cloud_service_locationc C s< |s t d��| �d| �� t|�df t�}| �|d� |jS )Nr4 z %s/operations/isavailable/%s%sr� r� )r� rt r� r! �AvailabilityResponser� r� )rX r� Z_check_availabilityr r r r� R s �� z*AzureNodeDriver._is_storage_service_uniquec K s� |d du rR| � | �� t�|d |d | �|d �|d d dd ��}| �|d� nD| � | �� t�|d |d | �|d �d |d dd ��}| �|d� | �|d� d S )NrQ Tr� rq r� Zcreate_storage_account)r� r� r� �#create_storage_service_input_to_xmlr� r� r� )rX rY r� r r r r� c s> �� �� �z'AzureNodeDriver._create_storage_accountc C s | � d| j d t|� t�S )Nr| z /operations/)rt rC r! � Operation�rX � request_idr r r �_get_operation_status� s �z%AzureNodeDriver._get_operation_statusc C sX t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}|d urT| � ||�S |S )N�GET) r r r r r� r r r r r r� )rX r� � response_typer r� r r r rt � s z AzureNodeDriver._perform_getc C sT t � }d|_t|_||_t| �|��|_| �|�\|_|_ | � |�|_ | � |�}|S r � r r r r r� r �_get_request_bodyr� r r r r r �rX r� r� r> r r� r r r r� � s z AzureNodeDriver._perform_postc C sT t � }d|_t|_||_t| �|��|_| �|�\|_|_ | � |�|_ | � |�}|S )N�PUTr? rA r r r r� � s z AzureNodeDriver._perform_putc C sP t � }d|_t|_||_| �|�\|_|_| �|�|_| � |�}| � |d� d S )Nr r� ) r r r r r� r r r r r r� r r r r r� � s z AzureNodeDriver._perform_deletec C s� z | j j|j|j|j|jd�W S ty` } z*t�|j�}|j |_ | � |�W Y d }~S d }~0 t y� } z|�W Y d }~n d }~0 0 d S )N)�actionrz r r ) r� r r� r� r r r r rq �netlocr r r� )rX r �e� parsed_urlr r r r � s � z AzureNodeDriver._perform_requestc C s� d|j v r^|j �d�\|_ }}|r^|�d�}|D ],}d|v r0|�d�\}}}|j�||f� q0t|j d�|_ |jr�| j d7 _ |jD ].\}}|dur�| j d|t|d�df 7 _ q�|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%s=%s%s���)r� � partition�splitr ra � url_quote)rX r rc Z query_stringZ query_paramsr r% r r r r r � s( � z)AzureNodeDriver._update_request_uri_queryc C sT |j dv r tt|j��|jd< |j dvrN|jD ]}d|�� kr. qNq.d|jd< |jS )z8 Add additional headers for management. )rB r ZMERGEr zContent-Length)r= �HEADz content-typezapplication/xmlz Content-Type)r r r� r� r r� )rX r �keyr r r 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)rX r� rP r r r r� 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)rX r� rP Zrespbody�doc� return_objr� r r r rQ s z2AzureNodeDriver._parse_response_body_from_xml_textc s � fdd�� � |�D �S )Nc s g | ]}|j � kr|�qS r )Z parentNode)rg Z childNode�r� r r rj # s �z4AzureNodeDriver._get_child_nodes.<locals>.<listcomp>)ZgetElementsByTagName)rX r� Ztag_namer rY r rS " s z AzureNodeDriver._get_child_nodesc C sR t t|��}|�� D �]6\}}t|t�rDt||| �||j|j�� qt|t �rrt||| � ||j| � |�|j�� qt|t �r�t||| � || � |�|j|j|j�� qt|t�r�t||| �|||j�� qt|t �r�t||| �|| � |��� qt|t��r*| �||d�}|d u�r | �|�}t|||� q| �|||�}|d urt|||� qd S �Nr� )�dict�varsr] 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_childr[ � _fill_dict� _Base64String�_fill_data_minidom�_decode_base64_to_text)rX r� rX �membersr% r r r r rU & st �� �� �� � �� z+AzureNodeDriver._fill_data_to_return_objectc s �� ||�}� �fdd�|D �S )Nc s g | ]}�� |� ��qS r )�"_parse_response_body_from_xml_node�rg � xmlelement�� element_typerX r r rj h s �z1AzureNodeDriver._fill_list_of.<locals>.<listcomp>�rS )rX �xmldocru ra � xmlelementsr rt r r_ f s �z AzureNodeDriver._fill_list_ofc C s |� }| � ||� |S rR )rU )rX r� rP rX r r r rq m s z2AzureNodeDriver._parse_response_body_from_xml_nodec s8 �� ||�}|r4�� |d |�}� �fdd�|D �S d S )Nr c s g | ]}�� |� ��qS r )�_get_node_valuerr rt r r rj � s �z8AzureNodeDriver._fill_scalar_list_of.<locals>.<listcomp>rv )rX rw ru �parent_xml_element_namera rx r rt r rc v s � �z$AzureNodeDriver._fill_scalar_list_ofc C s: |j j}|tu r| �|�S |tu r.|�� dkS ||�S d S )N�false)� firstChild� nodeValuer � _to_datetime�boolr� )rX rs Z data_typer r r r ry � s z AzureNodeDriver._get_node_valuec C s| t �|�}|dur|S |�d�r,|�dd�S |�d�rB|�dd�}dD ]}|�|�rF|�dd�}qFd �d d � |�d�D ��S ) zB Converts a Python name into a serializable name. NZx_ms_rc �-Z_idZID)Zcontent_r? Zif_r@ z-_r� c s s | ]}|� � V qd S rl )� capitalize)rg r% r r r ro � rk z:AzureNodeDriver._get_serialization_name.<locals>.<genexpr>)�_KNOWN_SERIALIZATION_XFORMSrU � startswith�replace�endswith�joinrL )rX � element_nameZknownr% r r r rd � s z'AzureNodeDriver._get_serialization_namec C sr i }| � ||�}|rn| � |d |�}|D ]D}| � ||�} | � ||�} | r(| r(| d jj} | d jj} | || < q(|S �Nr )rS r| r} ) rX rw rz rg rh ri rX rx �pair�keysrd rO r r r r rf � s � z AzureNodeDriver._fill_dict_ofc C s4 | � || �|��}|sdS |� }| �|d |� |S )zT Converts a child of the current dom element to the specified type. Nr )rS rd rU )rX rw r� rP rx rX r r r rk � s �z$AzureNodeDriver._fill_instance_childc C s@ | � ||�}|r<i }|d jD ]}|jr |jj||j< q |S d S r� )rS � childNodesr| r} ZnodeName)rX rw r� rx rX �childr r r rl � s zAzureNodeDriver._fill_dictc C s( t |t�r|�d�}t�|�}|�d�S r )r � _unicode_typer �base64� b64encode�decode)rX rz �encodedr r r r� � s z AzureNodeDriver._encode_base64c C s t |t�r|�d�}t�|�S r )r r� r r� � b64decoder� r r r �_decode_base64_to_bytes� s z'AzureNodeDriver._decode_base64_to_bytesc C s | � |�}|�d�S r )r� r� )rX rz Z decoded_bytesr r r ro � s z&AzureNodeDriver._decode_base64_to_textc C s� | � || �|��}|r |d js$d S |d jj}|d u r<|S t|t�rP| �|�S t|�t u rh|� � dkS t|�t u r|t |�S t|�|�S d S )Nr r{ ) rS rd r� r| r} r r r~ �typer r� r r )rX rw r� Z data_memberrx r r r r rn � s � z"AzureNodeDriver._fill_data_minidomc C s t �|d�S )Nz%Y-%m-%dT%H:%M:%S.%f)r �strptime)rX Zstrtimer r r r~ � s z AzureNodeDriver._to_datetimec C sb |d u r dS t |t�r | �|�}t |t�r.|S t |t�rB|�d�S t|�}t |t�r^|�d�S |S )Nrk r )r rj �_convert_class_to_xml�bytesr� r r )rX � request_bodyr r r r@ � s z!AzureNodeDriver._get_request_bodyTc C s, t �� }| �||�}tt j|ddd��}|S )Nr �xml)�encodingr )r �Element�_construct_element_treer �tostring)rX �sourceZ xml_prefix�rootrW r� r r r r� s �z%AzureNodeDriver._convert_class_to_xmlc C s� |d u rt �� S t|t�r8|D ]}|�| �||�� q n�t|t�r�|jj}|�t �|�� t |�� � D ]`\}}|d urft|t�s�t|t�r�|�| �||�� qft �| � |��}t t |��|_|�|� qf|�t �|�� |S rl )r r� r �listra r� rj r[ rT r\ r] rd � xml_escaper �text)rX r� �etreer � class_namer% Zeler r r r� s* � � z'AzureNodeDriver._construct_element_treec C sB |d u r d S t � }|jr>|j�� D ]\}}|�� dkr"||_q"|S )Nzx-ms-request-id)�AsynchronousOperationResultr r] r� r; )rX r� r� r% r r r r r� 4 s z,AzureNodeDriver._parse_response_for_async_opc C s$ dt |�dg}d�|�}| �||�S )N�services/hostedservices/z /deploymentsr� �r! r� � _get_path)rX r� r, � components�resourcer r r r� @ s � z/AzureNodeDriver._get_deployment_path_using_namec C s. d| j d | }|d ur*|dt|� 7 }|S )Nr| )rC r! )rX r� r% r� r r r r� J s zAzureNodeDriver._get_pathc C s | � d|�S )Nzservices/images�r� �rX Z image_namer r r ru P s z AzureNodeDriver._get_image_pathc C s | � d|�S )Nzservices/vmimagesr� r� r r r rw S s z!AzureNodeDriver._get_vmimage_pathc C s | � d|�S )Nzservices/hostedservicesr� �rX r� r r r r� V s z(AzureNodeDriver._get_hosted_service_pathc C s | � dt|� |�S )Nz*services/hostedservices/%s/deploymentslots)r� r! )rX r� �slotr r r r2 Y s ��z/AzureNodeDriver._get_deployment_path_using_slotc C s | � d|�S )Nzservices/disksr� )rX r� r r r r� a s z AzureNodeDriver._get_disk_pathc C s( dt |�d|dg}d�|�}| �||�S )Nr� z /deployments/z/rolesr� r� )rX r� r, r r� r� r r r r� d s � z AzureNodeDriver._get_role_pathc C s | � d|�S )Nzservices/storageservicesr� r� r r r r� o s z)AzureNodeDriver._get_storage_service_pathc C s� | � |�}| �|j�}d}d}d}|jdkr^||k r^| �|�}|jdkrJq^||7 }t�|� q"|jdkr|td| | jjd��d S ) Ni, r � Z InProgressZ SucceededZFailedz2Message: Async request for operation %s has failed�r� ) r� r< r; rV r� �sleepr r� r� )rX r� Zoperation_typer; Zoperation_status�timeout�waittime�intervalr r r r� 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� )rV �errorr� r )rX r� Zvalid_responserd �messager r r r� � s z"AzureNodeDriver.raise_for_response)NN)N)NN)N) NFr� Nr� NNNN)Nr� )NN)r� )r� )NNN)NN)N)N)N)N)T)N)N)N)N)N)N)N)N)NrN )erT � __module__� __qualname__r Z connectionClsr% Zwebsiter ZAZUREr� � AZURE_COMPUTE_INSTANCE_TYPESr\ Z _blob_url�features� collections� namedtuplerP r r! r� ZRUNNINGZSTOPPEDZ REBOOTINGZ TERMINATEDr rW re r{ r� r� r� r� rN r� r� r� r� r� r� r� r r r r r r r� r� r� r� r� r} r^ rf rm r� r� r� r� r� r< rt r� r� r� r r r r� rQ rS rU r_ rq rc ry rd rf rk rl r� r� ro rn r~ r@ r� r� r� r� r� ru rw r� r2 r� r� r� r� r� � __classcell__r r rZ r rM 0 s� �� % � 6 � 4 � 8 � $ � � : � ) ( 1 ( @ � � rM c C s | � � S rl )r� )r� r r r �_lower� s r� c @ s� e Zd Zedd� �Zedd� �Zedd� �Zedd� �ZedHd d ��ZedId 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"edJd@dA��Z#edKdBdC��Z$edLdDdE��Z%edFdG� �Z&d S )Mr� 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� rq �geo_replication_enabledr� r r r r8 � s ��z6AzureXmlSerializer.create_storage_service_input_to_xmlc C s& t �dd| fd|tjfd|tfg|�S )NZUpdateStorageServiceInputr� r� r� �r� r� rM r� r� )r� r� r� r� r r r �#update_storage_service_input_to_xml� s ��z6AzureXmlSerializer.update_storage_service_input_to_xmlc C s t �dd| fg�S )NZRegenerateKeysZKeyType�r� r� )Zkey_typer r r �regenerate_keys_to_xml� s �z)AzureXmlSerializer.regenerate_keys_to_xmlc C s t �dd| tjfd|fg|�S )NZUpdateHostedServicer� r� �r� r� rM r� )r� r� r� r r r � update_hosted_service_to_xml� s ��z/AzureXmlSerializer.update_hosted_service_to_xmlNc C sP |r*t �dd| fd|fd|fd|fg|�S t �dd| fd|fd|fd|fg|�S )NZCreateHostedServicer� r� r� r� r� r� r� r r r 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� r r r 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� r r r �create_deployment_to_xml s ��z+AzureXmlSerializer.create_deployment_to_xmlc C s t �dd| fd|fg�S )NZSwapr� ZSourceDeploymentr� )� productionZsource_deploymentr r r �swap_deployment_to_xml s ��z)AzureXmlSerializer.swap_deployment_to_xmlc C s t �dd| fg�S )NZUpdateDeploymentStatus�Statusr� )rV r r r � update_deployment_status_to_xml' s �z2AzureXmlSerializer.update_deployment_status_to_xmlc C s" t �dd| fd|tfd|fg|�S )NZChangeConfigurationr� r� �Moder� )r� r� �moder� r r r �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� r r r �upgrade_deployment_to_xml= s ��z,AzureXmlSerializer.upgrade_deployment_to_xmlc C s t �dd| fd|tfg�S )NZRollbackUpdateOrUpgrader� r� r� )r� r� r r r �rollback_upgrade_to_xmlR s ��z*AzureXmlSerializer.rollback_upgrade_to_xmlc C s t �dd| fg�S )NZWalkUpgradeDomainZ UpgradeDomainr� )Zupgrade_domainr r r �walk_upgrade_domain_to_xml\ s �z-AzureXmlSerializer.walk_upgrade_domain_to_xmlc C s t �dd| fd|fd|fg�S )NZCertificateFileZDataZCertificateFormat�Passwordr� )rz Zcertificate_formatrO r r r �certificate_file_to_xmlc s ��z*AzureXmlSerializer.certificate_file_to_xmlc C s( t �dd| fd|tjfd|fd|fg�S )NZCreateAffinityGroupr� r� r� r� r� )r% r� r� rq r r r � create_affinity_group_to_xmln s ��z/AzureXmlSerializer.create_affinity_group_to_xmlc C s t �dd| tjfd|fg�S )NZUpdateAffinityGroupr� r� r� )r� r� r r r � update_affinity_group_to_xmlz s ��z/AzureXmlSerializer.update_affinity_group_to_xmlc C s t �dd| fd|fd|fg�S )N�SubscriptionCertificateZ SubscriptionCertificatePublicKeyZ!SubscriptionCertificateThumbprintZSubscriptionCertificateDatar� )Z public_key� thumbprintrz r r r � subscription_certificate_to_xml� s ��z2AzureXmlSerializer.subscription_certificate_to_xmlc C s$ t �dd| fd|fd|fd|fg�S )N�OSImager� � MediaLinkr� r< r� )r� r� r% rI r r r �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�Lunr; r� ZSourceMediaLinkr� )� host_caching� disk_labelr� �lunrG r� Zsource_media_linkr r r � 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� r< r� )�has_operating_systemr� r� r% rI r r r � disk_to_xml� s ��z AzureXmlSerializer.disk_to_xmlc C s2 t �d�} d| _t�d| �}tt j|dd��}|S )N� OperationTypeZRestartRoleOperationr �r� �r r� r� r� � doc_from_xmlr r� �r� rW r� r r r � restart_role_operation_to_xml� s �z0AzureXmlSerializer.restart_role_operation_to_xmlc C s2 t �d�} d| _t�d| �}tt j|dd��}|S )Nr� ZShutdownRoleOperationr r� r� r� r r r � shutdown_role_operation_to_xml� s �z1AzureXmlSerializer.shutdown_role_operation_to_xmlc C s2 t �d�} d| _t�d| �}tt j|dd��}|S )Nr� ZStartRoleOperationr r� r� r� r r r �start_role_operation_to_xml� s �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 u�r$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 u�r�t �d�}|� |� | jD ]Z}t �d�}|� |� |� t �d|jfg�� t �d|jfg|� t �d|jfg|� �qJt �d| jfg|� |S )N�ConfigurationSetTypeZ ComputerNameZ AdminPasswordZResetPasswordOnFirstLogonZEnableAutomaticUpdatesZTimeZone� DomainJoin� Credentials�DomainZUsernamer� 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� Zappemndra � credentials�domain�usernamerO � join_domain�machine_object_ou�stored_certificate_settingsr� �store_location� store_namer� r� )r� r� r �credsZ cert_settings�certZ cert_settingr r r � windows_configuration_to_xml� s� � � ���� ��� � ���� ��� ���� � � � �z/AzureXmlSerializer.windows_configuration_to_xmlc C sh t �d| jfg|� t �d| jfg|� t �d| jfg|� t �d| jfg|� t �d| jtfg|� | jd u�rDt � d�}t � d�}t � d�}|� |� |� |� |� |� | jj D ]@}t � d �}|� |� t �d |j fg|� t �d |jfg|� q�| jjD ]B}t � d �}|� |� t �d |j fg|� t �d |jfg|� �q | jd u�rdt �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� ra � public_keys� fingerprintr� � key_pairs� custom_data)r� r� r ZpkeysZkpairsrO �pkeyZkpairr r r �linux_configuration_to_xmlM sj � � � ���� � � �z-AzureXmlSerializer.linux_configuration_to_xmlc C sl t �d| jfg|� t�d�}|�|� | jD �]}t�d�}|�|� t �d|jfg|� t �d|jfg|� t �d|j fg|� t �d|j fg|� |j j s�|j j s�|j j �rt�d�}|�|� t �d |j j fg|� t �d|j j fg|� t �d |j j fg|� t �d |j fg|� t �d |jtfg|� q.t�d �}|�|� | jD ]}t �d |fg|� �qN|S )Nr �InputEndpoints� InputEndpointZLoadBalancedEndpointSetNameZ LocalPortr� ZPort�LoadBalancerProber �ProtocolZEnableDirectServerReturnZ SubnetNames� SubnetName)r� r r� r r� ra r� r� r� r% r� �load_balancer_prober� r� r� r� � subnet_names)r� r� r� r� Zinput_endpointr* r+ r% r r r � network_configuration_to_xml� s� � ��� � � ��� � � � ���� �z/AzureXmlSerializer.network_configuration_to_xmlc C s6 t �d|fg| � t �d|fg| � t�d�} | �| � |d ur�t�d�} | �| � t|t�rlt �|| � nt|t�r�t � || � |d ur�t�d�} | �| � t � || � | d ur�t �d| fg| � |d u�rxt�d�} | �| � |D ]�} t�d�}| �|� t �d| j fg|� t �d | j fg|� t �d | j fg|� t �d | jfg|� t �d | jfg|� t �d | jfg|� q�|d u�r�t�d�} | �| � t �d|j fg| � t �d |j fg| � t �d |j fg| � t �d |jfg| � t �d|jfg| � |d u�rt �d|fg| � |d u�r2t �d|fg| � | S )NZRoleNameZRoleType�ConfigurationSetsr� ZAvailabilitySetNameZDataVirtualHardDisksr� r� r� r� r� r; r� r: ZSourceImageNameZ VMImageName�RoleSize)r� r r r� ra r r� r r� r$ r, r� r� r� r� rG r� r- )�availability_set_name�data_virtual_hard_disks�network_configuration_setrF � vm_image_namer � role_size� role_type�system_configuration_setr� Z config_setsZ config_setZvhdsZhdZvhdr r r � role_to_xml� s� � � �� � � � � � � � � � � � � z AzureXmlSerializer.role_to_xmlc C s< t �d�} t �|||||| |||| � } ttj| dd��} | S �Nr� r r� �r� r� r6 r r r� ) r r5 rF r4 r1 r/ r0 r2 r3 rW r� r� r r r r� P s � z"AzureXmlSerializer.add_role_to_xmlc C s< t �d�}t �|||||| ||d |� ttj|dd��} | S r7 r8 ) r rF r4 r1 r/ r0 r2 r3 rW r� r r r �update_role_to_xmlj s � z%AzureXmlSerializer.update_role_to_xmlc C s� t �dg�}t �d| fg|� |d urht�d�}|�|� t|t�rRt �||� nt|t�rht � ||� t �d|fg|� t �d|fg|� t � d|�}t tj |dd��}|S ) N)r� �CaptureRoleOperationZPostCaptureActionZProvisioningConfigurationZTargetImageLabelZTargetImageNamer: r r� ) r� r r r� ra r r� r r� r$ r� r r� )Zpost_capture_actionZtarget_image_nameZtarget_image_labelZprovisioning_configurationr� Zprovisioning_configrW r� r r r �capture_role_to_xml� 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 ur�| �t �d| fg�� ttj| dd ��}|S ) Nr3 r� ZDeploymentSlotr� �RoleList�RoleZVirtualNetworkNamer r� ) r� r� r r r� ra r6 r r� )r, r� r� r r5 rF r4 r1 r/ r0 r3 Zvirtual_network_namer2 rW � role_listZroler� r r r r� � s> � � ��z4AzureXmlSerializer.virtual_machine_deployment_to_xmlc C s� | D ]�}|d }|d }t |�dkr.|d }nd}|dur|durTt|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� ra )rz r� �elementr% �val� converterr� �entryr r r 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� �setra )�document_element_nameZ inner_xmlr� r r r r� � s z AzureXmlSerializer.doc_from_xmlc C sD t �| �}t �||� |d ur.|�t �|�� ttj|dd��}|S )Nr r� )r� r� r ra �(extended_properties_dict_to_xml_fragmentr r r� )rD rz r� rW r� r r r r� s ��z AzureXmlSerializer.doc_from_datac C s� | d ur�t | �dkr�t�d�}| �� D ]X\}}t�d�}t�d�}t|�|_t�d�}t|�|_|�|� |�|� |�|� q&|S d S )Nr ZExtendedProperties�ExtendedPropertyr� �Value)r� r r� r] r! r� ra )r� r� rO r@ Zextended_propertyr% r r r r rE % s z;AzureXmlSerializer.extended_properties_dict_to_xml_fragment)NN)N)N)N)N)'rT r� r� � staticmethodr8 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, r6 r� r9 r; r� r r� r� rE r r r r r� � s� � � n > P r ' 2 r� c @ s e Zd ZdZdS )rj ze This is the base of data class. It is only used to check whether it is instance or not. N)rT r� r� �__doc__r r r r rj ? s rj c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zdd � ZdS ) �WindowsAzureDataTypedListNc C s t | j| j�| _d S rl )r] r` ra r] ri r r r rW M s z"WindowsAzureDataTypedList.__init__c C s t | j�S rl )�iterr] ri r r r �__iter__P s z"WindowsAzureDataTypedList.__iter__c C s t | j�S rl )r� r] ri r r r �__len__S s z!WindowsAzureDataTypedList.__len__c C s | j | S rl )r] )rX �indexr r r � __getitem__V s z%WindowsAzureDataTypedList.__getitem__) rT r� r� r` ra rW rL rM rO r r r r rJ H s rJ c @ s e Zd Zddd�ZdS )r: Nc C s( || _ || _|| _|| _|| _d| _d S rZ )r- r� r� r� r� rI )rX r- r� r� r� r� r r r rW \ s zOSVirtualHardDisk.__init__)NNNNN�rT r� r� rW r r r r r: Z s �c @ s e Zd Zddd�ZdS )r� Nc C s0 d| _ || _|| _|| _|| _t� | _|| _d S )NZ LinuxProvisioningConfiguration)r� r r r r r� r r" )rX r r r r r" r r r rW h s �z LinuxConfigurationSet.__init__)NNNNNrP r r r r r� f s �r� c @ s e Zd Zddd�ZdS )r� Nc C s> d| _ || _|| _|| _|| _|| _|| _t� | _t � | _ d S )NZ WindowsProvisioningConfiguration) r� r� r� r r r r� r r� r r )rX r� r� r r r r� r r r rW z s z WindowsConfigurationSet.__init__)NNNNNNrP r r r r r� x s �r� c @ s e Zd Zdd� ZdS )r c C s t � | _d| _d| _d S rZ )r r r r ri r r r rW � s zDomainJoin.__init__NrP r r r r r � s r c @ s e Zd Zdd� ZdS )r c C s d| _ d| _d| _d S rZ )r r rO ri r r r rW � s zCredentials.__init__NrP r r r r r � s 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 rl )r� r r )rX r� r r r r r rW � s zCertificateSetting.__init__N)r� r� r� )rT r� r� rI rW r r r r r � s r c @ s e Zd ZeZdgZdS )r r] N)rT r� r� r r` �_repr_attributesr r r r r � s �r c @ s e Zd Zdd� ZdS )r� c C s t � | _t� | _d S rl )r r r r! ri r r r rW � s z SSH.__init__NrP r r r r r� � s r� c @ s e Zd Zddd�ZdS )r r� c C s || _ || _d S rl �r r� �rX r r� r r r rW � s zPublicKey.__init__N)r� r� rP r r r r r � s r c @ s e Zd ZeZdgZdS )r r] N)rT r� r� r r` rQ r r r r r � s �r c @ s e Zd Zddd�ZdS )� AzureKeyPairr� c C s || _ || _d S rl rR rS r r r rW � s zAzureKeyPair.__init__N)r� r� rP r r r r rT � s rT c @ s e Zd ZeZdgZdS )r r] N)rT r� r� rT r` rQ r r r r r � s �r c @ s e Zd Zdd� ZdS )r' c C s d| _ d| _d| _d S rZ )r� r� r� ri r r r rW � s zLoadBalancerProbe.__init__NrP r r r r r' � s r' c @ s e Zd Zdd� ZdS )r� c C s$ d| _ d| _t� | _ttd�| _d S )Nr� r) )r� r4 � ConfigurationSetInputEndpointsr� rb r r+ ri r r r rW � s zConfigurationSet.__init__NrP r r r r r� � s r� c @ s e Zd ZeZdgZdS )r- r] N)rT r� r� r� r` rQ r r r r r- � s �r- c @ s e Zd Zddd�ZdS )r� r� Fc C s0 || _ || _|| _|| _|| _t� | _|| _d S rl )r� r� r� r% r� r' r* r� )rX r% r� r� r� r� r� r r r rW � s z&ConfigurationSetInputEndpoint.__init__N)r� r� r� r� r� FrP r r r r r� � s �r� c @ s e Zd ZeZdZdgZdS )rU r& r] N)rT r� r� r� r` ra rQ r r r r rU s �rU c @ s e Zd Zdd� ZdS )r� c C s$ d| _ d| _ttd�| _t� | _d S )Nr� ZAvailableService)r% r& rb r r$ �ComputeCapabilityr' ri r r r rW s zLocation.__init__NrP r r r r r� s r� c @ s e Zd ZeZdgZdS )r r] N)rT r� r� r� r` rQ r r r r r s �r c @ s e Zd Zdd� ZdS )rV c C s t td�| _d S �Nr. )rb r r( ri r r r rW & s zComputeCapability.__init__NrP r r r r rV $ s rV c @ s e Zd Zdd� ZdS )�VirtualMachinesRoleSizesc C s t td�| _d S rW )rb r r3 ri r r r rW , s z!VirtualMachinesRoleSizes.__init__NrP r r r r rX * s rX c @ s e Zd Zdd� ZdS )r� c C s@ d| _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d S �Nr� r ) r� r* rq rH r� r� r% rI Zeular� ri r r r rW 2 s zOSImage.__init__NrP r r r r r� 0 s r� c @ s e Zd ZeZdgZdS )rv r] N)rT r� r� r� r` rQ r r r r rv ? s �rv c @ s e Zd Zdd� ZdS )�VMImagec C s< d| _ d| _d| _t� | _d| _d| _d| _d| _d| _ d S rZ ) r% r� r* r> rK r� r, r rq r� ri r r r rW I s zVMImage.__init__NrP r r r r rZ G s rZ c @ s e Zd ZeZdgZdS )rx r] N)rT r� r� rZ r` rQ r r r r rx U s �rx c @ s e Zd Zdd� ZdS )� VirtualIPc C s d| _ d| _d| _d S rZ )r� rL r% ri r r r rW _ s zVirtualIP.__init__NrP r r r r r[ ] s r[ c @ s e Zd ZeZdgZdS )� VirtualIPsr] N)rT r� r� r[ r` rQ r r r r r\ e s �r\ c @ s e Zd ZddgZdd� ZdS )r� r� �urlc C s d| _ d| _t� | _t� | _d S rZ )r] r� �HostedServicePropertiesr5 � Deploymentsr� ri r r r rW s s zHostedService.__init__N)rT r� r� rQ rW r r r r r� m s �r� c @ s e Zd ZeZdgZdS )r� r] N)rT r� r� r� r` rQ r r r r r� z s �r� c @ s e Zd Zdd� ZdS )r^ c C s> d| _ d| _d| _t� | _d| _d| _d| _tddd�| _ d S )Nr� rF r� rG ) r� rq r� rm r� rV Z date_createdZdate_last_modifiedre r� ri r r r rW � s �z HostedServiceProperties.__init__NrP r r r r r^ � s r^ c @ s e Zd Zdd� ZdS )r3 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� FrF r� rG ) r% r� rE rV rm r� r] r� �RoleInstanceListr� � UpgradeStatusZupgrade_statusZupgrade_domain_countr< r> Z sdk_versionr% Zinput_endpoint_list�lockedZrollback_allowedr= rJ Z created_timeZlast_modified_timere r� r\ r� ri r r r rW � s0 �zDeployment.__init__NrP r r r r r3 � s r3 c @ s e Zd ZeZdgZdS )r_ r] N)rT r� r� r3 r` rQ r r r r r_ � s �r_ c @ s e Zd Zdd� ZdS )ra c C s d| _ d| _d| _d S rZ )Z upgrade_typeZ current_upgrade_domain_stateZcurrent_upgrade_domainri r r r rW � s zUpgradeStatus.__init__NrP r r r r ra � s ra c @ s e Zd Zdd� ZdS )� RoleInstancec C sT d| _ d| _d| _d| _d| _d| _d| _d| _d| _t � | _ d| _ d| _ d| _ d S rY )r Z instance_namer Zinstance_upgrade_domainZinstance_fault_domainr Zinstance_state_detailsZinstance_error_coder" �InstanceEndpointsr� r rD r ri r r r rW � s zRoleInstance.__init__NrP r r r r rc � s rc c @ s e Zd ZeZdgZdS )r` r] N)rT r� r� rc r` rQ r r r r r` � s �r` c @ s e Zd Zdd� ZdS )�InstanceEndpointc C s" d| _ d| _d| _d| _d| _d S rZ )r% r� r� r� r� ri r r r rW � s zInstanceEndpoint.__init__NrP r r r r re � s re c @ s e Zd ZeZdgZdS )rd r] N)rT r� r� re r` rQ r r r r rd � s �rd c @ s e Zd Zdd� ZdS )r& c C s d| _ d| _d| _d S rZ )r r� r� ri r r r rW � s zInputEndpoint.__init__NrP r r r r r& � s r& c @ s e Zd ZeZdgZdS )r% r] N)rT r� r� r& r` rQ r r r r r% � s �r% c @ s e Zd Zdd� ZdS )r= c C s d| _ d| _d S rZ )r � os_versionri r r r rW � s z Role.__init__NrP r r r r r= � s r= c @ s e Zd ZeZdgZdS )r< r] N)rT r� r� r= r` rQ r r r r r< s �r< c @ s e Zd Zdd� ZdS )r= c C s d| _ d| _d| _d S rZ )� start_timeZend_timerV ri r r r rW s z!PersistentVMDowntimeInfo.__init__NrP r r r r r= s c @ s e Zd Zddd�ZdS )r� Nc C s || _ d S rl )r; r: r r r rW s z$AsynchronousOperationResult.__init__)NrP r r r r r� s r� c @ s e Zd Zdd� ZdS )r� c C sH d| _ t� | _d| _d| _d| _d| _d| _d| _d| _ d| _ d| _ d S rY ) r� � AttachedTor0 r� Z is_corruptedrq rG r� r� r% rI r- ri r r r rW s z Disk.__init__NrP r r r r r� s r� c @ s e Zd ZeZdgZdS )r� r] N)rT r� r� r� r` rQ r r r r r� ) s �r� c @ s e Zd Zdd� ZdS )rh c C s d| _ d| _d| _d S rZ )r. r, r ri r r r rW 3 s zAttachedTo.__init__NrP r r r r rh 1 s rh c @ s e Zd Zdd� ZdS )�OperationErrorc C s d| _ d| _d S rZ )�coder� ri r r r rW ; s zOperationError.__init__NrP r r r r ri 9 s ri c @ s e Zd Zdd� ZdS )r9 c C s d| _ d| _d| _t� | _d S rZ )r$ rV Zhttp_status_coderi r� ri r r r rW B s zOperation.__init__NrP r r r r r9 @ s r9 c @ s e Zd Zdd� ZdS )�OperatingSystemc C s, d| _ t� | _d| _d| _d| _t� | _d S )Nr� Tr )�versionrm r� � is_defaultZ is_active�familyZ family_labelri r r r rW K s zOperatingSystem.__init__NrP r r r r rk I s rk c @ s e Zd Zdd� ZdS )r> c C s( d| _ d| _d| _d| _d| _d| _d S rY )r% r� Zos_staterI r� rG ri r r r rW V s z OSDiskConfiguration.__init__NrP r r r r r> T s c @ s e Zd ZeZdgZdS )�OperatingSystemsr] N)rT r� r� rk r` rQ r r r r ro _ s �ro c @ s e Zd Zdd� ZdS )�OperatingSystemFamilyc C s d| _ t� | _t� | _d S rZ )r% rm r� ro Zoperating_systemsri r r r rW i s z OperatingSystemFamily.__init__NrP r r r r rp g s rp c @ s e Zd ZeZdgZdS )�OperatingSystemFamiliesr] N)rT r� r� rp r` rQ r r r r rq o s �rq c @ s e Zd Zdd� ZdS )� Subscriptionc C sX d| _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d| _ d| _ d| _ d| _ d S rY )rC Zsubscription_nameZsubscription_statusrA rB Zmax_core_countZmax_storage_accountsZmax_hosted_servicesZcurrent_core_countZcurrent_hosted_servicesZcurrent_storage_accountsZmax_virtual_network_sitesZmax_local_network_sitesZmax_dns_serversri r r r rW y s zSubscription.__init__NrP r r r r rr w s rr c @ s e Zd Zdd� ZdS )r7 c C s d| _ d S )NF)r� ri r r r rW � s z AvailabilityResponse.__init__NrP r r r r r7 � s r7 c @ s e Zd Zdd� ZdS )r� c C s d| _ d| _d| _d| _d S rZ )Z#subscription_certificate_public_keyZ#subscription_certificate_thumbprintZ subscription_certificate_data�createdri r r r rW � s z SubscriptionCertificate.__init__NrP r r r r r� � s r� c @ s e Zd ZeZdgZdS )�SubscriptionCertificatesr] N)rT r� r� r� r` rQ r r r r rt � s �rt c @ s e Zd Zdd� ZdS )r c C s. d| _ d| _d| _g | _i | _d| _d | _d S rZ )r r r� r r r� Zprotocol_overrideri r r r rW � s zAzureHTTPRequest.__init__NrP r r r r r � s r c @ s e Zd Zdd� ZdS )�AzureHTTPResponsec C s || _ || _|| _|| _d S rl )rV r� r r� )rX rV r� r r� r r r rW � s zAzureHTTPResponse.__init__NrP r r r r ru � s ru c @ s e Zd ZdS )rm N)rT r� r� r r r r rm � s rm c s" e Zd ZdZd� fdd� Z� ZS )r] 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 s0 || _ |d u r|j| _n|| _tt| ��� d S rl )r` rT ra rV r] rW �rX r` ra rZ r r rW � s z_ListOf.__init__)N�rT r� r� rI rW r� r r rZ r r] � s r] c s e Zd ZdZ� fdd�Z� ZS )rb 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 || _ || _tt| ��� d S rl )r` ra rV rb rW rv rZ r r rW � s zScalarListOf.__init__rw r r rZ r rb � s rb c s e Zd ZdZ� fdd�Z� ZS )re z� A dict which carries with it the xml element names for key,val. Used for deserializaion and construction of the lists c s$ || _ || _|| _tt| ��� d S rl )rg rh ri rV re rW )rX rg rh ri rZ r r rW � s z_DictOf.__init__rw r r rZ r re � s re c s$ e Zd Z� fdd�Zdd� Z� ZS )r) c s& t t| ��||||� || _|| _d S rl )rV r) rW r$ r% )rX r$ r% r# r� r$ r% rZ r r rW � 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% ri r r r �__repr__� s ���zAzureNodeLocation.__repr__)rT r� r� rW ry r� r r rZ r r) � s r) )|rI r� r� r� r� �sysr_ r� r Zxml.domr Zxml.sax.saxutilsr r� Zlibcloud.utils.py3r Zlibcloud.common.azurer r Zlibcloud.compute.providersr Zlibcloud.compute.baser r r r r r Zlibcloud.compute.typesr Zlibcloud.common.typesr r r r r r rM Zlibcloud.utils.miscr �HTTPSConnection� version_infor r� r! r r Z X_MS_VERSION�compiler� r� r� rM r� �objectr� rj rJ r: r� r� r r r r r� r r rT r r' r� r- r� rU r� r rV rX r� rv rZ rx r[ r\ r� r� r^ r3 r_ ra rc r` re rd r& r% r= r< r= r� r� r� rh ri r9 rk r> ro rp rq rr r7 r� rt r ru rm r� r] rb r[ re r) r r r r �<module> s� �� � � � � � � � � � � � � � � � � � � �� � M� v (
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка