Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/kubevirt.cpython-39.pyc
Ðазад
a q�h� � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddl m Z m Z dd l mZmZmZ dd l mZmZmZ d gZd Zd ZG dd � d ee�ZdS )z. kubevirt driver with support for nodes (vms) � N)�datetime)� LibcloudError)� KubernetesBasicAuthConnection)�KubernetesDriverMixin)�VALID_RESPONSE_CODES)�Provider� NodeState)� NodeDriver�NodeSize�Node)� NodeImage� NodeLocation� StorageVolume�KubeVirtNodeDriverz/api/v1/z/apis/kubevirt.io/v1alpha3/c @ s� e Zd ZejZdZdZeZ e j e j e j d�Zd9dd�Zd:dd�Zd d � Zd d � Zd d� Zdd� Zd;dd�Zd<dd�Zdd� Zd=dd�Zd>d!d"�Zd?d$d%�Zd@d&d'�Zd(d)� Z dAd,d-�Z d.d/� Z dBd0d1�Z d2d3� Z d4d5� Z!dCd7d8�Z"dS )Dr Zkubevirtzhttps://www.kubevirt.io)�pending�running�stoppedNc C s� g }|d ur|� |j� n| �� D ]}|� |j� q"g }g }|D ]b}td | d }| j�|�}|jdkrlq@|j}|d D ]&}|d d s�|� |� qz|� |� qzq@g } |D ]} | � | j| dd�� q�|D ]} | � | j| d d�� q�| S ) N� namespaces/z/virtualmachines�� �items�specr T)� is_stoppedF) �append�name�list_locations� KUBEVIRT_URL� connection�request�status�object�_to_node) �self�location� namespaces�nsZdormant�live�req�result�itemZvms�vm� 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/kubevirt.py� list_nodes9 s2 � z KubeVirtNodeDriver.list_nodesc sn � s�st d��| �� }� r.t� fdd�|�}�rDt�fdd�|�}z t|�W S tyh t d��Y n0 dS )zget a vm by name or idz,This method needs id or name to be specifiedc s | j � kS �N��id��xr. r* r+ �<lambda>^ � z-KubeVirtNodeDriver.get_node.<locals>.<lambda>c s | j � kS r- �r r0 r4 r* r+ r2 a r3 zNode does not existN)� ValueErrorr, �filter�next� StopIteration)r! r/ r �nodesZnode_genr* )r/ r r+ �get_nodeX s � � zKubeVirtNodeDriver.get_nodec C s� |j tju rdS |j}|jd }td | d | }dddii}ddi}z&| jj|d t� |�|d �}|j t v W S t y� � Y n0 d S ) NT� namespacer �/virtualmachines/r r � Content-Type� application/merge-patch+json�PATCH��method�data�headers) �stater �RUNNINGr �extrar r r �json�dumpsr r � Exception)r! �noder r; r& rB rC r' r* r* r+ � start_nodei s& �� � z KubeVirtNodeDriver.start_nodec C s� |j tju rdS |j}|jd }td | d | }ddi}ddd ii}z&| jj|d t� |�|d �}|j t v W S t y� � Y n0 d S ) NTr; r r< r= r> r r Fr? r@ ) rD r �STOPPEDr rF r r r rG rH r r rI )r! rJ r r; r& rC rB r' r* r* r+ � stop_node} s& �� � z KubeVirtNodeDriver.stop_nodec C sZ |j d }|j}d}z,| jjtd | d | |d�}|jtv W S tyT � Y n0 dS )z# Rebooting a node. r; �DELETEr z/virtualmachineinstances/�rA N)rF r r r r r r rI )r! rJ r; r rA r' r* r* r+ � reboot_node� s" ���� z KubeVirtNodeDriver.reboot_nodec C s` |j d }|j}| �|� z,| jjtd | d | dd�}|jtv W S tyZ � Y n0 dS )zK Terminating a VMI and deleting the VM resource backing it r; r r< rN rO N) rF r rM r r r r r rI )r! rJ r; r r' r* r* r+ � destroy_node� s ���� z KubeVirtNodeDriver.destroy_node� � r c & C s� h d�} |dur|j } nd} ddd|i|d�dd d|iig g dd �d d id i id�g |g d�d�d�d�} t|�d } | | d d d d d d d< |dk r�t|�} d| i| d d d d d< n,t|�d } | | d d d d d d d< d }|D �]�}|�d �}|�d d �}|�d!d"�|��}|d#7 }|�d$d%�}|| v�rNtd&| ��|d'k�r�z |d( }W n t�y� td)��Y n0 d(|i|d*�}|d+k�r8d,|v �r |d, }|| j| d-�v�r*d.|v�s�d/|v�r�d0}t|��|d. }|d/ }|�d1d2�}|�d3d4�}| j||||||d5� n d6}t|��d7|i|d8�}|d |id!|i}| d d d d d9 d: � |� | d d d d; � |� q�t |t ��r�|j }d(|id<d*�}d d id<d=�}| d d d d d9 d: � |� | d d d d; � |� |�r|d# } |d> } |d } n d?} d@} dA} | i d!| i} | i d!| i} | d d d dB � | � | d d d d d9 dC � | � dD}!t � | �}"tdE | dF }#z| jj|#|!|"dG� W n t�y� � Y n0 | �� }$|$D ]}%|%j |k�r�|% S �q�dS )Ha� Creating a VM with a containerDisk. :param name: A name to give the VM. The VM will be identified by this name and atm it cannot be changed after it is set. :type name: ``str`` :param image: Either a libcloud NodeImage or a string. In both cases it must point to a Docker image with an embedded disk. May be a URI like `kubevirt/cirros-registry-disk-demo`, kubevirt will automatically pull it from https://hub.docker.com/u/URI. For more info visit: https://kubevirt.io/user-guide/docs/latest/creating-virtual-machines/disks-and-volumes.html#containerdisk :type image: `str` :param location: The namespace where the VM will live. (default is 'default') :type location: ``str`` :param ex_memory: The RAM in MB to be allocated to the VM :type ex_memory: ``int`` :param ex_cpu: The ammount of cpu to be allocated in miliCPUs ie: 400 will mean 0.4 of a core, 1000 will mean 1 core and 3000 will mean 3 cores. :type ex_cpu: ``int`` :param ex_disks: A list containing disk dictionaries. Each dictionaries should have the following optional keys: -bus: can be "virtio", "sata", or "scsi" -device: can be "lun" or "disk" The following are required keys: -disk_type: atm only "persistentVolumeClaim" is supported -name: The name of the disk configuration -claim_name: the name of the Persistent Volume Claim If you wish a new Persistent Volume Claim can be created by providing the following: required: -size: the desired size (implied in GB) -storage_class_name: the name of the storage class to # NOQA be used for the creation of the Persistent Volume Claim. Make sure it allows for dymamic provisioning. optional: -access_mode: default is ReadWriteOnce -volume_mode: default is `Filesystem`, it can also be `Block` :type ex_disks: `list` of `dict`. For each `dict` the types for its keys are: -bus: `str` -device: `str` -disk_type: `str` -name: `str` -claim_name: `str` (for creating a claim:) -size: `int` -storage_class_name: `str` -volume_mode: `str` -access_mode: `str` :param ex_network: Only the pod type is supported, and in the configuration masquerade or bridge are the accepted values. The parameter must be a tupple or list with (network_type, interface, name) :type ex_network: `iterable` (tupple or list) [network_type, inteface, name] # NOQA network_type: `str` | only "pod" is accepted atm interface: `str` | "masquerade" or "bridge" name: `str` > �persistentVolumeClaimZ ephemeralZcloudInitConfigDrive� containerDiskZ dataVolumeZ configMapZ emptyDiskZcloudInitNoCloudZhostDiskN�defaultzkubevirt.io/v1alpha3ZVirtualMachinezkubevirt.io/vm)�labelsr FrW )�disks� interfacesZnetworkInterfaceMultiqueue�type� �requests)�devices�machine� resources)�domain�networksZ terminationGracePeriodSeconds�volumes)�metadatar )r �template�Z apiVersion�kindrc r �Mr rd r` r_ �memory� Zcores�cpu�mr � disk_type�bus�virtior zdisk{}rS �device�diskz,The possible values for this parameter are: rU �imagez,A container disk needs a containerized image)rU r rT Z claim_name�r; �size�storage_class_namezTdisk['size'] and disk['storage_class_name'] are both required to create a new claim.� volume_mode� Filesystem� access_mode� ReadWriteOnce)rs r r" �ex_storage_class_name�ex_volume_mode�ex_access_modea4 You must provide either a claim_name of an existing claim or if you want one to be created you must additionally provide size and the storage_class_name of the cluster, which allows dynamic provisioning, so a Persistent Volume Claim can be created. In the latter case please provide the desired size as well.� claimName�rT r r] rX rb z boot-disk)rp r � Z masqueradeZnetw1�podra rY �POSTr r< �rA rB )r �str�int�get�formatr5 �KeyError� ex_list_persistent_volume_claims� create_volumer � isinstancer rG rH r r r rI r, )&r! r rq r" Z ex_memoryZex_cpuZex_disksZ ex_networkZex_termination_grace_periodZ DISK_TYPESr; r) rh rj �irp rl rm Z disk_namero � volumes_dictr| �msgrs � storage_classru rw � disk_dictZ interfaceZ network_nameZ network_typeZ network_dictZinterface_dictrA rB r& r9 rJ r* r* r+ � create_node� s, Q�������� ����& ����� ��� � � � � ������ ���� ���� z KubeVirtNodeDriver.create_nodec sh | � � }|r(|j� tt� fdd�|��}t� }g }|D ],}|jj|v rHq6|�|jj� |�|j� q6|S )z� If location (namespace) is provided only the images in that location will be provided. Otherwise all of them. c s | d d � kS )NrF r; r* r0 rr r* r+ r2 � s ��z0KubeVirtNodeDriver.list_images.<locals>.<lambda>)r, r �listr6 �setrq �addr )r! r" r9 Zname_setZimagesrJ r* rr r+ � list_images� s � z KubeVirtNodeDriver.list_imagesc C s^ t d }g }| j�|�j}|d D ]6}|d d }|d d }|�t||d| jjd�� q"|S )z; By locations here it is meant namespaces. r# r rc r �uidr[ )r/ r Zcountry�driver)�ROOT_URLr r r r r r� )r! r& r# r' r( r �IDr* r* r+ r � s � z!KubeVirtNodeDriver.list_locationsc C sT d}|r|j }| �� }g }|D ]0}|s4|�|j� q ||jd kr |�|j� q |S )Nr[ r; )r r, r rs rF )r! r" r; r9 �sizesrJ r* r* r+ � list_sizes� s z KubeVirtNodeDriver.list_sizesr[ rv rx T�Recyclec C s� |r4|du rd} t | ��| j||||j||d�} | S | du sD| du rPd} t | ��ddd|idd t|�d id |d |gd |d|dg | | id�} td }d}t�| �}z| jj|||d� W n t y� � Y n0 | � � }|D ]}|j|kr�| S q�dS )uv :param size: The size in Gigabytes :type size: `int` :param volume_type: This is the type of volume to be created that is dependent on the underlying cloud where Kubernetes is deployed. K8s is supporting the following types: -gcePersistentDisk -awsElasticBlockStore -azureFile -azureDisk -csi -fc (Fibre Channel) -flexVolume -flocker -nfs -iSCSI -rbd (Ceph Block Device) -cephFS -cinder (OpenStack block storage) -glusterfs -vsphereVolume -quobyte Volumes -hostPath (Single node testing only – local storage is not supported in any way and WILL NOT WORK in a multi-node cluster) # NOQA -portworx Volumes -scaleIO Volumes -storageOS This parameter is a dict in the form {type: {key1:value1, key2:value2,...}}, where type is one of the above and key1, key2... are type specific keys and their corresponding values. eg: {nsf: {server: "172.0.0.0", path: "/tmp"}} {awsElasticBlockStore: {fsType: 'ext4', volumeID: "1234"}} :type volume_type: `str` :param volume_params: A dict with the key:value that the volume_type needs. This parameter is a dict in the form {key1:value1, key2:value2,...}, where type is one of the above and key1, key2... are type specific keys and their corresponding values. eg: for nsf volume_type {server: "172.0.0.0", path: "/tmp"} for awsElasticBlockStore volume_type {fsType: 'ext4', volumeID: "1234"} Nz'Please provide a namespace for the PVC.)rs r rt r; ru rw z�An ex_volume_type must be provided from the list of supported clouds, as well as the ex_volume_params necessesary for your volume type choice.�v1ZPersistentVolumer �capacity�storage�Gi� volumeMode� accessModesZ persistentVolumeReclaimPolicy�storageClassNameZ mountOptionsre �persistentvolumes/r� r� ) r5 �_create_volume_dynamicr r� r� rG rH r r rI � list_volumes)r! rs r r" ry rz r{ Z ex_dynamicZex_reclaim_policyZex_volume_typeZex_volume_paramsr� �vol�pvr& rA rB rb �volumer* r* r+ r� � sT 7�� ��� z KubeVirtNodeDriver.create_volumerV c C sn ddd|ig |dddiid�d�}|d d � |� |d urJ||d d < ntd ��t|�d |d d d d< d}td | d } t�|�} z| jj| || d�} W n ty� � Y n0 | j d d dk�r:t d�D ]d} td | d | } z| j�| �j } W n t�y � Y n0 | d d dk�r. �q:t � d� q�| � � } | D ]"}|jd d |k�rF| S �qFd S )ah Method to create a Persistent Volume Claim for storage, thus storage is required in the arguments. This method assumes dynamic provisioning of the Persistent Volume so the storage_class given should allow for it (by default it usually is), or already have unbounded Persistent Volumes created by an admin. :param name: The name of the pvc an arbitrary string of lower letters :type name: `str` :param size: An int of the ammount of gigabytes desired :type size: `int` :param namespace: The namespace where the claim will live :type namespace: `str` :param storage_class_name: If you want the pvc to be bound to a particular class of PVs specified here. :type storage_class_name: `str` :param access_mode: The desired access mode, ie "ReadOnlyMany" :type access_mode: `str` :param matchLabels: A dictionary with the labels, ie: {'release': 'stable,} :type matchLabels: `dict` with keys `str` and values `str` r� ZPersistentVolumeClaimr r\ r� r[ )r� r� r_ re r r� Nr� z_The storage class name must be provided of astorage class which allows for dynamic provisioningr� r_ r� r �/persistentvolumeclaimsr� r �phase�Bound� �/persistentvolumeclaims/�pvc)r r5 r� r� rG rH r r rI r �range�time�sleepr� rF )r! rs r rt ru r; rw r� rA r& rB r' �_rb r� r* r* r+ r� L sT ����� �� z)KubeVirtNodeDriver._create_volume_dynamicc C sZ |j d rdS |j d }|j}|jd }|j d }|j d d }| j||||||d�}|S ) z� This method is for unbound volumes that were statically made. It will bind them to a pvc so they can be used by a kubernetes resource. �is_boundNrt z-pvcru � access_modesr )rs r rt ru r; rw )rF rs r r� ) r! r� r; r� rs r ru rw r� r* r* r+ � _bind_volume� s �z KubeVirtNodeDriver._bind_volumec C s� d}|j d rh|j d d }|j d d }td | d | }z| jj||d�}W n tyf � Y n0 |j}td | }z| jj||d�}|jW S ty� � Y n0 d S ) NrN r� r� r r; r r� rO r� )rF r� r r rI r r )r! r� rA r� r; r& r' r� r* r* r+ �destroy_volume� s( �� z!KubeVirtNodeDriver.destroy_volumerp rn c C s� |j d s0| �||j d �}|du r0td| d��|j d d }|du rL|}n|}|j d d }| �|� |j d |kr�d} t| ��|j} td | d | } |d |id|i} d |i|d �} z| j�| �j }W n t y� � Y n0 |d d d d d d }|d d d d }|� | � |� | � ddi}ddd|dd|iid�iii}zN| jj| dt � |�|d�}d|j v �r�|j d � |� n |g|j d< |tv W S t �y� � Y n0 dS )z: params: bus, name , device (disk or lun) r� r; NzPSelected Volume (PV) could not be bound (to a PVC), please select another volume)r� r� r z0The PVC and the VM must be in the same namespacer r< rm r| r} r rd r` r] rX rb r= r> �rb r` r? r@ �pvcs)rF r� r rM r5 r r r r r rI r rG rH r )r! rJ r� ro Zex_busZex_namer| r r; r� r) r& r� r� r' rX rb rC rB r* r* r+ � attach_volume� sr � �� �� ���� � z KubeVirtNodeDriver.attach_volumec C s| | � |� |jd d }|j}|jd }td | d | }ddi}z| j�|�j}W n tyj � Y n0 |d d d d d d } |d d d d } d} | D ]2}d|v r�|d d |kr�|d } | �|� q�q�| s�d} t | ��| D ] } | d | kr�| �| � �qq�dd d| d d | iid�iii}z4| jj|dt � |�|d�}|jd �|� |t v W S t�yv � Y n0 dS )z� Detaches a volume from a node but the node must be given since a PVC can have more than one VMI's pointing to it r� r r; r r< r= r> r rd r` r] rX rb NrT r| z0The given volume is not attached to the given VMr� r? r@ r� ) rM rF r r r r r rI �remover5 rG rH r )r! r� Zex_noder| r r; r& rC r' rX rb Z to_deleter� rp rB r* r* r+ � detach_volume sf � �� ���� � z KubeVirtNodeDriver.detach_volumec C sN t d | d }z| j�|�j}W n ty6 � Y n0 dd� |d D �}|S )Nr r� c S s g | ]}|d d �qS �rc r r* ��.0r( r* r* r+ � <listcomp>T r3 zGKubeVirtNodeDriver.ex_list_persistent_volume_claims.<locals>.<listcomp>r )r� r r r rI )r! r; Zpvc_reqr' r� r* r* r+ r� L s � z3KubeVirtNodeDriver.ex_list_persistent_volume_claimsc C sB d}z| j �|�j}W n ty* � Y n0 dd� |d D �}|S )Nz&/apis/storage.k8s.io/v1/storageclassesc S s g | ]}|d d �qS r� r* r� r* r* r+ r� _ r3 z>KubeVirtNodeDriver.ex_list_storage_classes.<locals>.<listcomp>r )r r r rI )r! Zsc_reqr' Zscsr* r* r+ �ex_list_storage_classesW s z*KubeVirtNodeDriver.ex_list_storage_classesc C s\ g }t d }z| j�|�j}W n ty2 � Y n0 |d D �]}|d d dvrTq<|d d }|d d d }t|�d ��}d i i}|d d |d< |d d dk|d< |d d |d< |d d |d< |d �r*|d d d |d d< |d d d |d d< |d d d |d d< |d d }n |d d }t|||| jj|d�} |� | � q<|S )z9 Location is a namespace of the cluster. z/persistentvolumes/r r r� > r� Z Availablerc r� r r� r� r� r� r� rt r� r� r� r� r� ru ZclaimRefr r; )r/ r rs r� rF ) r� r r r rI r� �rstripr r� r ) r! rb Zpv_recr' r( r� rs rF r r� r* r* r+ r� c s> � � z KubeVirtNodeDriver.list_volumesFc C sT |d d }|d d }| j j}d|d d i}g |d< d|d d d d d v r�d |d d d d d d v r�|d d d d d d d }t|�d ��}nd }d|d d d d d v �rd|d d d d d d v �r |d d d d d d d }t|�d��}nd }d|i} t|||d d d || d�} ||d < ||d< d} |d d d d D ]:} | �� D ]*\} }t|�tu �rpd|v �rp|d } �qp�qdt|| |�}d|d d d v �r�|d d d d D ]&} d| v �r�|d � | d d � �q�|�r,t j }d}d}t ||||||| ||d� S t d |d d }| j �|�j}d}|d D ]<}d|v �rZd |d v �rZ|d d d d |k�rZ|}�qZ|du �s�d |d v�r�t j}d}d}t ||||||| ||d� S d|d d i|d < |d d D ]>}|d d!k�r�t||d |�}d"|d# v �r.t jnt j}�q�|d d$ D ]�}|d d!k�rDd |d d v �r�|d d d }t|�d ��}nd }d|d d v �r�|d d d }t|�d��}nd }||d < ||d< d|i} t|||d d d || d�} �qDd}t�|d d% d&�}d'|d v �r4d(d)� |d d' D �}ng }t ||||||| |||d*� S )+zy This will conver a VM resource to a node with state "Stopped" It can be started with self.start rc r� r r; r� Zlimitsr rd r` r_ rh rg r rj r\ rk Zcpus)r/ r �ramrp � bandwidthZpricer� rF Z undefinedrb rq rT r| N) r/ r rD � public_ips� private_ipsr� rs rq rF r z/podsr ZownerReferencesZcontainerStatusesr r Zcomputer rD � containersZcreationTimestampz%Y-%m-%dT%H:%M:%SZZpodIPsc S s g | ] }|d �qS )�ipr* )r� r� r* r* r+ r� � r3 z/KubeVirtNodeDriver._to_node.<locals>.<listcomp>) r/ r rD r� r� r� rs rq rF � created_at)r r� r� r� r r rZ �dictr r r rL r r� r r �PENDINGrE r �strptime)r! r) r r� r r� rF rh rj � extra_sizers Z image_namer� �k�vrq rD r� r� r& r' r �pdZ cont_status� containerr� r* r* r+ r � s$ ������������������� �� �� � � ���� ��zKubeVirtNodeDriver._to_node)N)NN)NrR rS NNr )N)N)Nr[ rv rx Tr� NN)rv rV rx )rV )rp rn N)rV )F)#�__name__� __module__� __qualname__r ZKUBEVIRTrZ r Zwebsiter Z connectionClsr r� rE rL ZNODE_STATE_MAPr, r: rK rM rP rQ r� r� r r� r� r� r� r� r� r� r� r� r� r r* r* r* r+ r - sX � � y � l � T � C< ')�__doc__rG r� r Zlibcloud.common.typesr Zlibcloud.common.kubernetesr r r Zlibcloud.compute.typesr r Zlibcloud.compute.baser r r r r r �__all__r� r r r* r* r* r+ �<module> s �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка