Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/compute/drivers/__pycache__/libvirt_driver.cpython-39.pyc
Ðазад
a q�hO9 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl m Z d dl mZ d dlmZmZ d dlmZ d dlmZ d d lmZ d d l mZ zd dlZd ZW n ey� d ZY n0 G d d� de�ZdS )� )�with_statementN)�join)� defaultdict)�ET)� NodeDriver�Node)� NodeState)�Provider)�is_public_subnet)� ensure_stringTFc @ s e Zd ZdZejZdZdZe j e j e j e j e j e j e j e j d�Zd=dd�Zdd � Zd d � Zd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd>d!d"�Z d#d$� Z d%d&� Z d'd(� Z d)d*� Z d+d,� Z!d-d.� Z"d/d0� Z#d1d2� Z$d3d4� Z%d5d6� Z&d7d8� Z'd9d:� Z(d;d<� Z)dS )?�LibvirtNodeDriverzv Libvirt (http://libvirt.org/) node driver. To enable debug mode, set LIBVIR_DEBUG environment variable. ZLibvirtzhttp://libvirt.org/)r � � � � � � � Nc C s� t s td��|| _|| _|| _|durnd| jv rn|du rH|du rHtd��tjtjg| jdg}t� ||d�| _ n t� |�| _ |du r�| j � � | _dS )aJ :param uri: Hypervisor URI (e.g. vbox:///session, qemu:///system, etc.). :type uri: ``str`` :param key: the username for a remote libvirtd server :type key: ``str`` :param secret: the password for a remote libvirtd server :type key: ``str`` z0Libvirt driver requires 'libvirt' Python packageNz+tcpz]The remote Libvirt instance requires authentication, please set 'key' and 'secret' parametersr ) � have_libvirt� RuntimeError�_uri�_key�_secret�libvirt�VIR_CRED_AUTHNAME�VIR_CRED_PASSPHRASE�_cred_callbackZopenAuth� connection�openZgetInfo)�self�uri�key�secret�auth� 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/libvirt_driver.py�__init__? s � zLibvirtNodeDriver.__init__c C s@ |D ]6}|d t jkr"| j|d< q|d t jkr| j|d< qdS )a� Callback for the authentication scheme, which will provide username and password for the login. Reference: ( http://bit.ly/1U5yyQg ) :param cred: The credentials requested and the return :type cred: ``list`` :param user_data: Custom data provided to the authentication routine :type user_data: ``list`` :rtype: ``int`` r r )r r r r r )r �cred� user_dataZ credentialr$ r$ r% r _ s z LibvirtNodeDriver._cred_callbackc C s | j �� }| j|d�}|S )N)�domains)r ZlistAllDomains� _to_nodes�r r) �nodesr$ r$ r% � list_nodess s z LibvirtNodeDriver.list_nodesc C s | j |d�}|jdd�dkS )N��noder )�flags)�_get_domain_for_nodeZreboot�r r/ �domainr$ r$ r% � reboot_nodex s z LibvirtNodeDriver.reboot_nodec C s | j |d�}|�� dkS �Nr. r )r1 �destroyr2 r$ r$ r% � destroy_node| s z LibvirtNodeDriver.destroy_nodec C s | j |d�}|�� dkS r5 )r1 �creater2 r$ r$ r% � start_node� s z LibvirtNodeDriver.start_nodec C s | j |d�}|�� dkS r5 )r1 �shutdownr2 r$ r$ r% � stop_node� s zLibvirtNodeDriver.stop_nodec C s | j |d�S )z� Start a stopped node. :param node: Node which should be used :type node: :class:`Node` :rtype: ``bool`` r. )r9 �r r/ r$ r$ r% � ex_start_node� s z LibvirtNodeDriver.ex_start_nodec C s | j |d�S )z� Shutdown a running node. Note: Usually this will result in sending an ACPI event to the node. :param node: Node which should be used :type node: :class:`Node` :rtype: ``bool`` r. )r; r< r$ r$ r% �ex_shutdown_node� s z"LibvirtNodeDriver.ex_shutdown_nodec C s | j |d�}|�� dkS )z� Suspend a running node. :param node: Node which should be used :type node: :class:`Node` :rtype: ``bool`` r. r )r1 Zsuspendr2 r$ r$ r% �ex_suspend_node� s z!LibvirtNodeDriver.ex_suspend_nodec C s | j |d�}|�� dkS )z� Resume a suspended node. :param node: Node which should be used :type node: :class:`Node` :rtype: ``bool`` r. r )r1 �resumer2 r$ r$ r% �ex_resume_node� s z LibvirtNodeDriver.ex_resume_nodec C s | j |d�}| j|d�}|S )z� Retrieve Node object for a domain with a provided uuid. :param uuid: Uuid of the domain. :type uuid: ``str`` )�uuid�r3 )�_get_domain_for_uuid�_to_node)r rB r3 r/ r$ r$ r% �ex_get_node_by_uuid� s z%LibvirtNodeDriver.ex_get_node_by_uuidc C s | j |d�}| j|d�}|S )z� Retrieve Node object for a domain with a provided name. :param name: Name of the domain. :type name: ``str`` )�namerC )�_get_domain_for_namerE )r rG r3 r/ r$ r$ r% �ex_get_node_by_name� s z%LibvirtNodeDriver.ex_get_node_by_namer c s� t j�|�rt j�|�s td��| j|d�}| j�� }|j|dd�}t j |d�}|r^|d }nd}dt t � � �|f } t || �} t| d��(� � fd d �} |�| d � W d � n1 s�0 Y z |�� W n ty� Y n0 | S ) a� Take a screenshot of a monitoring of a running instance. :param node: Node to take the screenshot of. :type node: :class:`libcloud.compute.base.Node` :param directory: Path where the screenshot will be saved. :type directory: ``str`` :param screen: ID of the monitor to take the screenshot of. :type screen: ``int`` :return: Full path where the screenshot has been saved. :rtype: ``str`` z$Invalid value for directory argumentr. r )�stream�screen)�typez.pngzscreenshot-%s%s�wbc s � � |� d S )N)�write)rJ �buf�opaque��fpr$ r% rN � s z8LibvirtNodeDriver.ex_take_node_screenshot.<locals>.writeN)�os�path�exists�isdir� ValueErrorr1 r Z newStreamZ screenshot� mimetypes�guess_all_extensions�int�time�pjoinr ZrecvAll�finish� Exception) r r/ � directoryrK r3 rJ Z mime_type� extensions� extensionrG � file_pathrN r$ rQ r% �ex_take_node_screenshot� s& * z)LibvirtNodeDriver.ex_take_node_screenshotc C s | j �� }|S )zN Return a system hostname on which the hypervisor is running. )r Z getHostname)r �hostnamer$ r$ r% �ex_get_hypervisor_hostname s z,LibvirtNodeDriver.ex_get_hypervisor_hostnamec C sL | j �� }t�|�}g d�}i }|D ]"}|�|�}| j|d�}|||< q$|S )zS Retrieve hypervisor system information. :rtype: ``dict`` )Zbios�system� processorZ memory_device)�element)r Z getSysinfor �XML�find� _get_entries)r �xml�etree� attributesZsysinfo� attributerh �entriesr$ r$ r% �ex_get_hypervisor_sysinfo s z+LibvirtNodeDriver.ex_get_hypervisor_sysinfoc s � fdd�|D �}|S )Nc s g | ]}� j |d ��qS )rC )rE )�.0r3 �r r$ r% � <listcomp> � z/LibvirtNodeDriver._to_nodes.<locals>.<listcomp>r$ r+ r$ rs r% r* s zLibvirtNodeDriver._to_nodesc C s� |� � \}}}}}| j�|tj�}g g }}| �|�} | D ]"} t| �rR|�| � q:|�| � q:|�� |� � | j � � |d ||d�} t |� � |�� |||| | d�} |�� | _| S )Ni )rB Zos_type�typesZ used_memory� vcpu_count� used_cpu_time)�idrG �state� public_ips� private_ipsZdriver�extra)�info�NODE_STATE_MAP�getr �UNKNOWN� _get_ip_addresses_for_domainr �appendZ UUIDStringZOSTyper ZgetTyper ZIDrG �_uuid) r r3 rz Zmax_memZmemoryrw rx r{ r| � ip_addresses� ip_addressr} r/ r$ r$ r% rE s& �� zLibvirtNodeDriver._to_nodec C s� g }t �� dkr|S d| jvr"|S | j|d�}i }z8ddg}tj|tjtjd�}|�� \}}| j|d�}W nb t y� } zJ| j dkr�d d g}tj|tjtjd�}|�� \}}| j |d �}W Y d } ~ n d } ~ 0 0 |D ] } | |v r�|| } |� | � q�|S ) a2 Retrieve IP addresses for the provided domain. Note: This functionality is currently only supported on Linux and only works if this code is run on the same machine as the VMs run on. :return: IP addresses for the provided domain. :rtype: ``list`` �Linuxz///rC �arpz-an)�stdout�stderr)� arp_outputr �ipZneigh)� ip_outputN) �platformrf r � _get_mac_addresses_for_domain� subprocess�Popen�PIPE� communicate�_parse_ip_table_arp�OSError�errno�_parse_ip_table_neigh�extend) r r3 �resultZ mac_addresses� arp_table�cmd�childr� �_�e� mac_addressr� r$ r$ r% r� 9 s6 � � " z.LibvirtNodeDriver._get_ip_addresses_for_domainc C sB |� � }t�|�}|�d�}g }|D ]}|�d�}|�|� q$|S )zR Parses network interface MAC addresses from the provided domain. z&devices/interface[@type='network']/mac�address)ZXMLDescr ri �findallr� r� )r r3 rl rm Zelemsr� �elemr� r$ r$ r% r� f s z/LibvirtNodeDriver._get_mac_addresses_for_domainc C s | j �|j�}|S )zE Return libvirt domain object for the provided node. )r �lookupByUUIDStringrB r2 r$ r$ r% r1 u s z&LibvirtNodeDriver._get_domain_for_nodec C s | j �|�}|S )zE Return libvirt domain object for the provided uuid. )r r� )r rB r3 r$ r$ r% rD | s z&LibvirtNodeDriver._get_domain_for_uuidc C s | j �|�}|S )zE Return libvirt domain object for the provided name. )r Z lookupByName)r rG r3 r$ r$ r% rH � s z&LibvirtNodeDriver._get_domain_for_namec C s4 |� d�}i }|D ] }|�d�}|j}|||< q|S )zE Parse entries dictionary. :rtype: ``dict`` �entryrG )r� r� �text)r rh �elementsr� rG �valuer$ r$ r% rk � s z LibvirtNodeDriver._get_entriesc C s t �d�}| �||�S )z� Sets up the regexp for parsing out IP addresses from the 'arp -an' command and pass it along to the parser function. :return: Dictionary from the parsing funtion :rtype: ``dict`` z.*?\((.*?)\) at (.*?)\s+��re�compile�_parse_mac_addr_table)r r� Z arp_regexr$ r$ r% r� � s z%LibvirtNodeDriver._parse_ip_table_arpc C s t �d�}| �||�S )z� Sets up the regexp for parsing out IP addresses from the 'ip neighbor' command and pass it along to the parser function. :return: Dictionary from the parsing function :rtype: ``dict`` z(.*?)\s+.*lladdr\s+(.*?)\s+r� )r r� Zip_regexr$ r$ r% r� � s z'LibvirtNodeDriver._parse_ip_table_neighc C sZ t |��d�}tt�}|D ]:}|�|�}|s.q|�� }|d }|d } || �|� q|S )z� Parse the command output and return a dictionary which maps mac address to an IP address. :return: Dictionary which maps mac address to IP address. :rtype: ``dict`` � r r )r �splitr �list�match�groupsr� ) r Z cmd_outputZ mac_regex�linesr� �liner� r� r� r� r$ r$ r% r� � s z'LibvirtNodeDriver._parse_mac_addr_table)NN)r )*�__name__� __module__� __qualname__�__doc__r ZLIBVIRTrL rG Zwebsiter Z TERMINATEDZRUNNINGZPENDINGr� r r& r r- r4 r7 r9 r; r= r> r? rA rF rI rc re rq r* rE r� r� r1 rD rH rk r� r� r� r$ r$ r$ r% r ) sP � .- r ) � __future__r r� rS r[ r� r� rX �os.pathr r\ � collectionsr Zlibcloud.utils.py3r Zlibcloud.compute.baser r r Zlibcloud.compute.typesr Zlibcloud.utils.networkingr r r r � ImportErrorr r$ r$ r$ r% �<module> s(
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка