File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/__pycache__/aliyun.cpython-310.pyc
Back
o ;j>k � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlZddlZddlZddlmZmZmZmZ ddlmZ zddlZdZW n ey_ dZY nw e� e �Z dd d d d d dddddddd� Z dZ dZ!dZ"dd� Z#dd � Z$d d � Z%d d � Z&dYd!d"�Z'dZd#d$�Z(dYd%d&�Z)dYd'd(�Z*dYd)d*�Z+dYd+d,�Z,dYd-d.�Z-dYd/d0�Z.dYd1d2�Z/dYd3d4�Z0d5d6� Z1d7d8� Z2d9d:� Z3d;d<� Z4dYd=d>�Z5d[d?d@�Z6dYdAdB�Z7dCdD� Z8dEdF� Z9dGdH� Z:dYdIdJ�Z;dKdL� Z<dYdMdN�Z=dZdOdP�Z>dYdQdR�Z?dSdT� Z@dYdUdV�ZAdYdWdX�ZBdS )\ag AliYun ECS Cloud Module ======================= .. versionadded:: 2014.7.0 The Aliyun cloud module is used to control access to the aliyun ECS. http://www.aliyun.com/ Use of this module requires the ``id`` and ``key`` parameter to be set. Set up the cloud configuration at ``/etc/salt/cloud.providers`` or ``/etc/salt/cloud.providers.d/aliyun.conf``: .. code-block:: yaml my-aliyun-config: # aliyun Access Key ID id: wFGEwgregeqw3435gDger # aliyun Access Key Secret key: GDE43t43REGTrkilg43934t34qT43t4dgegerGEgg location: cn-qingdao driver: aliyun :depends: requests � N)�sha1)�SaltCloudExecutionFailure�SaltCloudExecutionTimeout�SaltCloudNotFound�SaltCloudSystemExit)�to_bytesTFzAliYun HangZhou RegionzAliYun BeiJing RegionzAliYun HongKong RegionzAliYun QingDao RegionzAliYun ShangHai RegionzAliYun ShenZheng RegionzAliYun DongJing RegionzAliYun XinJiaPo RegionzAliYun XiNi RegionzEU FalaKeFu RegionzME DiBai RegionzUS FuJiNiYa RegionzUS GuiGu Region) � cn-hangzhouz cn-beijingz cn-hongkongz cn-qingdaoz cn-shanghaiz cn-shenzhenzap-northeast-1zap-southeast-1zap-southeast-2z eu-central-1z me-east-1z us-east-1z us-west-1r z 2014-05-26�aliyunc C s t � du rdS t� du rdS tS )z) Check for aliyun configurations F)�get_configured_provider�get_dependencies�__virtualname__� r r �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud/clouds/aliyun.py� __virtual__S s r c C s" zt �� W S ty t Y S w �N)Z__active_provider_name__�value�AttributeErrorr r r r �_get_active_provider_name` s �r c C s t �tt� ptd�S )z/ Return the first configured instance. )�id�key)�configZis_provider_configured�__opts__r r r r r r r g s �r c C s t �tdti�S )z* Warn if dependencies aren't met. �requests)r Zcheck_driver_dependenciesr � HAS_REQUESTSr r r r r p s r c C �j | dkrt d��ddi}t|d�}i }|d d D ]}i ||d < |D ]}t|| �||d |< q#q|S ) zb Return a dict of all available VM locations on the cloud provider with relevant data �actionzfThe avail_locations function must be called with -f or --function, or with the --list-locations option�ActionZDescribeRegions��paramsZRegionsZRegion�RegionId�r �query�str)�callr �items�retZregion�itemr r r �avail_locationsw s � �r' c C s� |dkrt d��t| t�si } t� }|�dt�}d| v r | d }d|dd�}t|d�}i }|d d D ]}i ||d < |D ]}t|| �||d |< q=q3|S ) z> Return a list of the images that are on the provider r z`The avail_images function must be called with -f or --function, or with the --list-images option�location�DescribeImagesZ100�r r ZPageSizer �Images�Image�ImageId)r � isinstance�dictr �get�DEFAULT_LOCATIONr! r" ) �kwargsr# �providerr( r r$ r% �imager& r r r � avail_images� s, � � �r5 c C r ) zC Return a list of the image sizes that are on the provider r z^The avail_sizes function must be called with -f or --function, or with the --list-sizes optionr ZDescribeInstanceTypesr Z InstanceTypes� InstanceType�InstanceTypeIdr )r# r r$ r% r4 r& r r r � avail_sizes� s � �r8 c C s" t �dtjd| p t� t tdd��S )z� Return the aliyun region to use, in this order: - CLI parameter - VM parameter - Cloud profile setting r( F)�default� search_global)r r0 r �get_cloud_config_valuer r1 ��vm_r r r � get_location� s ��r> c C s\ i }dt � d�}t|�}|d d D ]}i ||d < |D ]}t|| �||d |< q q|S )z; List all availability zones in the current region Z DescribeZones�r r ZZonesZZoneZZoneId)r> r! r" )r# r% r r$ �zoner& r r r �list_availability_zones� s �rA c C s� | dkrt d��i }t� }d|d�}t|�}t�d|d |� d|v s)|d dkr+|S |d d D ]}i ||d < |D ] }|| ||d |< q;q1|S ) z� Return a list of the VMs that are on the provider. Only a list of VM names, and their state, is returned. This is the minimum amount of information needed to check for existing VMs. r zAThe list_nodes_min function must be called with -f or --function.�DescribeInstanceStatusr? �$Total %s instance found in Region %s� TotalCount�Coder �InstanceStatuses�InstanceStatus� InstanceId)r r> r! �log�debug)r# r% r( r �nodes�noder& r r r �list_nodes_min� s& �� �rM c C sf | dkrt d��t� }i }|D ]!}|| }|d |d |d |d |d t|d �d �||d < q|S ) �; Return a list of the VMs that are on the provider r �=The list_nodes function must be called with -f or --function.r �name� public_ips� private_ips�size�state)r rP rQ rR rS rT )r �list_nodes_fullr" )r# rK r% � instanceIdrL r r r � list_nodes s � �rW c C s� | dkrt d��i }t� }d|dd�}t|d�}t�d|d |� d |v s+|d d kr-|S |d d }|d d krKd|d< t|d�}|�|d d � |D ]~}|�dd�}d|d�}t|d�}d |v rjt�d|� qM|d } |d | |d d|d d�|| < |D ]J} || } | dur�t| �} | dkr�|| d || d < | d kr�d || vr�|| d || d < | d kr�|| d! d } | r�| || d < | || | < q�qMt � p�d"} d#| v r�| � d#�}|d } d$t d%< t d& || t � |S )'rN r zBThe list_nodes_full function must be called with -f or --function.rB �50r* r rC rD rE r rF rG �2 �2Z PageNumberrH � ZDescribeInstanceAttribute�r rH z"Query instance:%s attribute failed� InstanceNamer- ZTODOZStatus)r rP r4 rS rT N�PublicIpAddressZ IpAddressrQ ZInnerIpAddressrR Z VpcAttributesZPrivateIpAddressr �:TZupdate_cachedirzcloud.cache_node_list) r r> r! rI rJ �updater0 �warningr" r �splitr � __utils__)r# r% r( r �resultZresult_instancestatusrL rV r$ rP r& r Zvpc_ipsr3 �compsr r r rU " sl �� � � rU c C s t jj�td�td | �S )zO Return a list of the VMs that are on the provider, with select fields �functionzquery.selection)�salt�utils�cloud�list_nodes_selectrU r �r# r r r rj j s �rj c C sv | dkrt d��dt� dd�}t|�}d|v ri S i }|d d D ]}i ||d < |D ] }|| ||d |< q+q!|S ) z) Return a list of security group r rO ZDescribeSecurityGroupsrX r* rE ZSecurityGroupsZ SecurityGroup�SecurityGroupId)r r> r! )r# r rd r% Zsgr& r r r �list_securitygroupu s$ �� �rm c C �T t � }ttjd| tdd��}|std��|r"t|�|v r"|| d S td|� d���)z( Return the image object to use r4 F�r: z No image specified for this VM.r- zThe specified image, '�', could not be found.)r5 r" r r; r r )r= ZimagesZvm_imager r r � get_image� s � rq c C sP t � }tjd| tdd�}|std��|r t|�|v r || d S td|� d���)z# Return the security group � securitygroupFro z*No securitygroup ID specified for this VM.rl z The specified security group, 'rp )rm r r; r r r" )r= Zsgsrr r r r �get_securitygroup� s � �rs c C rn )z6 Return the VM's size. Used by create_node(). rS Fro z No size specified for this VM.r7 zThe specified size, 'rp )r8 r" r r; r r )r= ZsizesZvm_sizer r r �get_size� s � rt c C rn )z" Return the VM's location r( Fro z"No location specified for this VM.r zThe specified location, 'rp )r' r" r r; r r )r= Z locationsZ vm_locationr r r �__get_location� s � �ru c C �> |dkrt d��t�d| � t| �d }d|d�}t|�}|S )zk Start a node CLI Examples: .. code-block:: bash salt-cloud -a start myinstance r �3The stop action must be called with -a or --action.zStarting node %srH � StartInstancer\ �r rI �info� _get_noder! )rP r# rV r rd r r r �start� � r| c C sH |dkrt d��t�d| � t| �d }d|t|��� d�}t|�}|S )z� Stop a node CLI Examples: .. code-block:: bash salt-cloud -a stop myinstance salt-cloud -a stop myinstance force=True r rw zStopping node %srH � StopInstance)r rH Z ForceStop)r rI rz r{ r" �lowerr! )rP �forcer# rV r rd r r r �stop� s �r� c C rv )zm Reboot a node CLI Examples: .. code-block:: bash salt-cloud -a reboot myinstance r rw zRebooting node %srH ZRebootInstancer\ ry )rP r# Z instance_idr rd r r r �reboot r} r� c C s� t | t�si } d| �dd�| �dt�| �dd�| �dd�| �dd�d�}g d �}|D ]}|| v r9|�|| | i� q*t|�}|d S ) zK Convenience function to make the rest api call for node creation. ZCreateInstance�size_idr[ � region_id�image_id�securitygroup_idrP )r r6 r r- rl r] )r] �InternetChargeType�InternetMaxBandwidthIn�InternetMaxBandwidthOut�HostName�Password�SystemDisk.Category� VSwitchIdrH )r. r/ r0 r1 r` r! )r2 r �optionalr& rd r r r � create_node$ s � �r� c C s� z| d rt jtt� p d| d | d�du rW dS W n ty" Y nw td ddd�| d �td d | g d ��td td d� t�d| d � | d t | �t | �t | �t | �d�}d| v rd| d |d< d| v rn| d |d< d| v rzt | d �|d< d| v r�t | d �|d< d| v r�| d |d < d | v r�| d |d < d | v r�| d |d < d!| v r�| d! |d"< td dd#d$�| d �td d%|t|��td td d� zt|�}W n! ty� } ztjd&| d t |�tjd'� W Y d(}~dS d(}~ww t�d)� d*|d+�}t|� d,d-� }z tjjj|| d ft jd.| td/d0�t jd1| td2d0�d3�}W n7 t t f�yZ } z(z!zt | d � W n t �yA Y nw W t t |���W t t |���t t |���d(}~ww |d4 �rg|d4 d5 }n|d6 �rs|d6 d5 }nt�d7� dS t� d8|� || d9< td: | t�}|�!|� t�d;| d � t� d<| d t"�#|�� td dd=d>�| d �td d?| g d ��td td d� |S )@z- Create a single VM from a data dict �profiler r< F�cloud.fire_event�eventzstarting createzsalt/cloud/{}/creatingrP zcloud.filter_eventZcreating)rP r� r3 Zdriver�sock_dir� transport��argsr� r� zCreating Cloud VM %s)rP r� r� r� r� Z vswitch_idr� Zinternet_chargetyper� Zinternet_maxbandwidthinr� Zinternet_maxbandwidthoutZinternet_maxbandwidthOutr� �hostnamer� �passwordr� Z instance_namer] Zsystemdisk_categoryr� zrequesting instancezsalt/cloud/{}/requestingZ requestingzqError creating %s on Aliyun ECS The following exception was thrown when trying to run the initial deployment: %s)Zexc_info_on_loglevelN� rx r\ c S s, t | dd�}|s dS |�dd �d ur|S d S )Nr rk Fr^ )� show_instancer0 )�vm_name�datar r r �__query_node_data� s �z!create.<locals>.__query_node_dataZwait_for_ip_timeoutiX )r9 Zwait_for_ip_interval� )Z update_args�timeout�intervalrQ r rR z$No available ip:cant connect to saltzVM %s is now runningZssh_hostzcloud.bootstrapzCreated Cloud VM '%s'z '%s' VM creation details: %szcreated instancezsalt/cloud/{}/created�created)$r Zis_profile_configuredr r r rc �formatrI rz rt rq ru rs r" �listr� � Exception�error�logging�DEBUG�time�sleepr! rg rh ri Z wait_for_ipr; r r �destroyr rJ r` �pprint�pformat)r= r2 r% �excr r� r� Zssh_ipr r r �createK s� ���� � �� � � � �� �� � �� ��� �� r� c C s� dd� }t t| �� �dd� d�}d}|D ]\}}|d||� d ||� 7 }qd ||d d � � }t�t|d �|t�}t�|� � �� � } | S ) z+ Generate aliyun request signature c S sx t | t�s| S | }tjjd u r| �� �d�}n | �tjj��d�}tj� |d�}|� dd�}|� dd�}|� dd�}|S ) N�utf8r[ �+z%20�*z%2Az%7E�~) r. r" �sys�stdin�encoding�decode�encode�urllib�parse�quote�replace)�line�s�resr r r �percent_encode� s z*_compute_signature.<locals>.percent_encodec S s | d S )Nr r )r$ r r r �<lambda>� s z$_compute_signature.<locals>.<lambda>)r r[ �&�=zGET&%2F&� N) �sortedr� r$ �hmac�newr r �base64� encodestring�digest�strip) � parameters�access_key_secretr� ZsortedParametersZcanonicalizedQueryString�k�vZ stringToSign�h� signaturer r r �_compute_signature� s r� c C s� d}t jdt� tdd�}t jdt� tdd�}t�dt�� �}dt|dd tt � � �|d �}| r3|� | � t ||�}||d < t j||d d d�}|jdkrTtd�|j|j���t�|j� |j}tjj�|�} d| v rstt�| �di ����| S )z0 Make a web call to aliyun ECS REST API z$https://ecs-cn-hangzhou.aliyuncs.comr Fro r z%Y-%m-%dT%H:%M:%SZZJSONz1.0z HMAC-SHA1)ZFormat�VersionZ AccessKeyIdZSignatureVersionZSignatureMethodZSignatureNonceZ TimeStampZ SignatureT�x )r Zverifyr� �� zGAn error occurred while querying aliyun ECS. HTTP Code: {} Error: '{}'rE �Message) r r; r r r� �strftime�gmtime�DEFAULT_ALIYUN_API_VERSIONr" �uuidZuuid1r` r� r r0 Z status_coder r� �textrI rJ �urlrg rh �json�loadsr� r� ) r �pathZ access_key_idr� � timestampr� r� �request�contentrd r r r r! � s@ � � � � r! c C s8 t jj�t�d| t�| tt jj�t jj�t| ���}|S )z- Return the script deployment object �script) rg rh ri Z os_scriptr r; r Zsalt_config_to_yamlZ minion_config)r= Z deploy_scriptr r r r� . s ��r� c C sl |dkrt d��i }d| d�}t|d�}|d d D ]}i ||d < |D ]}t|| �||d |< q$q|S ) z� Show the disk details of the instance CLI Examples: .. code-block:: bash salt-cloud -a show_disk aliyun myinstance r z9The show_disks action must be called with -a or --action.ZDescribeInstanceDisksr\ r ZDisksZDiskZDiskIdr )rP r# r% r r$ Zdiskr& r r r � show_disk= s � �r� c C s� |dkrt d��t| t�si } i }dt� d�}d| v r!| d |d< t|d�}|d }|d D ]}i ||d < |D ]}t|| �||d |< q8q.|S ) a* Get monitor data of the instance. If instance name is missing, will show all the instance monitor data on the region. CLI Examples: .. code-block:: bash salt-cloud -f list_monitor_data aliyun salt-cloud -f list_monitor_data aliyun name=AY14051311071990225bd rf z;The list_monitor_data must be called with -f or --function.ZGetMonitorDatar? rP rH r Z MonitorDataZInstanceMonitorData)r r. r/ r> r! r" )r2 r# r% r r$ Z monitorDatar� r& r r r �list_monitor_dataX s$ � �r� c C s |dkrt d��t| �S )z/ Show the details from aliyun instance r z<The show_instance action must be called with -a or --action.)r r{ )rP r# r r r r� } s �r� c C sd d}|dkr*zt � | W S ty% |d8 }t�d| |� t�d� Y nw |dkstd| � d���)N� r r� z<Failed to get the data for node '%s'. Remaining attempts: %sg �?zThe specified instance z not found)rU �KeyErrorrI rJ r� r� r )rP �attemptsr r r r{ � s ��� r{ c C s� |dkrt d��t| t�si } t� }d| v r| d }d|| d d�}i }t|d�}d|v s3|d d s7td ��t�d |d |� |d d D ]}i ||d < |D ]}t|| �||d |< qPqF|S )z, Show the details from aliyun image rf z=The show_images function must be called with -f or --functionr( r) r4 )r r r- r rE r+ r, z'The specified image could not be found.z!Total %s image found in Region %srD r- ) r r. r/ r> r! r rI rJ r" )r2 r# r( r r% r$ r4 r& r r r � show_image� s0 � � �r� c C s� |dkrt d��td ddd| � d�d| itd td d � t| �d }d |d�}t|� d|d�}t|�}td ddd| � d�d| itd td d � |S )z� Destroy a node. CLI Example: .. code-block:: bash salt-cloud -a destroy myinstance salt-cloud -d myinstance rf zEThe destroy action must be called with -d, --destroy, -a or --action.r� r� zdestroying instancez salt/cloud/z /destroyingrP r� r� r� rH r~ r\ ZDeleteInstancezdestroyed instancez /destroyed)r rc r r{ r! )rP r# rV Z stop_paramsr rL r r r r� � s4 � � � r� r )NN)FN)C�__doc__r� r� r� r� r� r� � urllib.parser� r� �hashlibr Z salt.configr Zsalt.utils.cloudrg Zsalt.utils.dataZsalt.utils.jsonZsalt.exceptionsr r r r Zsalt.utils.stringutilsr r r � ImportError� getLogger�__name__rI ZALIYUN_LOCATIONSr1 r� r r r r r r' r5 r8 r> rA rM rW rU rj rm rq rs rt ru r| r� r� r� r� r� r! r� r� r� r� r{ r� r� r r r r �<module> s� � � # H ' "3 % (
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings