File manager - Edit - /usr/lib/python3/dist-packages/cloudinit/sources/helpers/__pycache__/openstack.cpython-310.pyc
Back
o �Ad�e � @ s: d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZm Z m Z m Z m Z d dl mZ d dlmZ e�e�Zddd� d fd e ji fd d d� d fd �ZdZdZdZdZdZdZdZ dZ dZ dZ eeeee e e e fZ dZ!G dd� de"�Z#G dd � d �Z$G d d � d e j%d �Z&G d d!� d!e&�Z'G d"d#� d#e&�Z(d&d$d%�Z)dS )'� N)�log)�net�sources�subp� url_helper�util)�BrokenMetadata)�ec2�network_configc C � | S �N� ��xr r �E/usr/lib/python3/dist-packages/cloudinit/sources/helpers/openstack.py�<lambda> � r � �meta_js�authorized_keysc C r r r r r r r r r )zetc/network/interfaceszmeta.jszroot/.ssh/authorized_keys))zlocal-hostname�hostnameF)� instance-id�uuidT�latestz 2012-08-10z 2013-04-04z 2013-10-17z 2015-10-15z 2016-06-30z 2016-10-06z 2017-02-22z 2018-08-27) N�bgpovs�bridge� cascading�dvs�ethernet�hw_veb�hyperv�ovs�phy�tap� vhostuser�vifc @ s e Zd ZdS )� NonReadableN)�__name__� __module__� __qualname__r r r r r& Q s r& c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) � SourceMixinc C s> | j sd S | j �di �}|�� D ] \}}||kr | S qd S )Nzblock-device-mapping)� ec2_metadata�get�items)�self�name�bdm�ent_name�devicer r r �_ec2_name_to_deviceV s �z SourceMixin._ec2_name_to_devicec C s$ d}| j dkr d}t�| j�|��S )N� public_keys� � public-keys)�versionr �normalize_pubkey_data�metadatar, )r. r/ r r r �get_public_ssh_keys_ s z SourceMixin.get_public_ssh_keysc C sV d }z d| }|dkrd| }t �|�}|r |d }W |S W |S tjy* Y |S w )NzLABEL=%s�swapzTYPE=%sr )r �find_devs_withr �ProcessExecutionError)r. r/ r2 �criteria� dev_entriesr r r �_os_name_to_devicee s ���z SourceMixin._os_name_to_devicec C sV |sd S |� d�s d| }tj�|�r|S | �tj�|��}|r)t�d||� |S d S )N�/z/dev/%sz Remapped device name %s => %s)� startswith�os�path�exists� _remap_device�basename�LOG�debug)r. r2 �remappedr r r �_validate_device_namer s z!SourceMixin._validate_device_namec C s� |sd S |g}|dkr|� dd� |dkr|�d� d }t�d|� |D ]}| �|�}| �|�}|r4 nq$|sPt�d|� |D ]}| �|�}| �|�}|rO nq?|sTd S t�d||� |S )N�rootr �amiz(Using ec2 style lookup to find device %sz.Using openstack style lookup to find device %szMapped %s to device %s)�insert�appendrH rI r3 rK r@ )r. r/ �namesr2 �nr r r �device_name_to_device� s6 � �z!SourceMixin.device_name_to_deviceN)r' r( r) r3 r: r@ rK rR r r r r r* U s r* c @ sh e Zd Zdd� Zejdd� �Zejddd��Zejdd � �Zejd d � �Z d d � Z ddd�Z dd� Z dS )� BaseReaderc C s || _ d S r )� base_path�r. rT r r r �__init__� s zBaseReader.__init__c G � d S r r �r. �base�add_onsr r r � _path_join� � zBaseReader._path_joinFc C rW r r �r. rD �decoder r r � _path_read� r\ zBaseReader._path_readc C rW r r �r. r r r �_fetch_available_versions� r\ z$BaseReader._fetch_available_versionsc C rW r r r` r r r �_read_ec2_metadata� r\ z BaseReader._read_ec2_metadatac C s� z| � � }W n ty" } zt�d| j|� g }W Y d }~nd }~ww dd� ttt��D �}t}|D ] }||vr9q2|} t�d||� |S )Nz4Unable to read openstack versions from %s due to: %sc S s g | ]}|�qS r r )�.0�vr r r � <listcomp>� s z4BaseReader._find_working_version.<locals>.<listcomp>z Selected version '%s' from %s) ra � ExceptionrH rI rT �reversed�list� OS_VERSIONS� OS_LATEST)r. �versions_available�e� supported�selected_version�potential_versionr r r �_find_working_version� s0 ��� �z BaseReader._find_working_versionc C s^ |� dd��d�}|�d�}dd� |D �}|s td| ��| j| jdg|�R � }| j||d�S ) N� content_pathr rA c S s g | ]}t |�r|�qS r )�len)rc �pr r r re � s z1BaseReader._read_content_path.<locals>.<listcomp>z!Item %s has no valid content path� openstack�r^ )r, �lstrip�splitr r[ rT r_ )r. �itemr^ rD � path_pieces� valid_piecesr r r �_read_content_path� s z BaseReader._read_content_pathc s� t jtjtttfd�� � �fdd�}ddd�}|��� �}|�� D ]o\}\}}}�� �j |�}d}d}z�� |�}W n# t y] } z|sLt �d || � nt �d || � W Y d} ~ nd} ~ ww d }|rj|sjtd | ��|r�|r�z||�}W n ty� } z td || f �| �d} ~ ww |r�|||< q!|d } d| v r�| d } z t�| �| d< W n ttfy� } ztd| �| �d} ~ ww i } | �dg �} | D ])}d|vr�q�|d }z ��|�| |< W q� ty� } z td|| f �| �d} ~ ww | |d< | �dd�}|�r z �j|d d�}||d< W n t �y } ztd| �| �d} ~ ww z | d d |d< W n t�y3 Y nw ��� |d< tD ] \}}}|�rO|| v�rOtd| ��|| v �r[| �|�| |< �q<|S )z�Reads a version 2 formatted location. Return a dict with metadata, userdata, ec2-metadata, dsmode, network_config, files and version (2). If not a valid location, raise a NonReadable exception. )� root_typesc s� i }�� d| d�dtjf|d< �� d| d�ddd� f|d < �� d| d �d� f|d < �� d| d �d� f|d < �� d| d�d� f|d< |S )Nrt zmeta_data.jsonTr9 � user_dataFc S r r r r r r r r � r z7BaseReader.read_v2.<locals>.datafiles.<locals>.<lambda>�userdatazvendor_data.json� vendordatazvendor_data2.json� vendordata2znetwork_data.json� networkdata)r[ r � load_json)r7 �files��load_json_anytyper. r r � datafiles� s, � � � � �z%BaseReader.read_v2.<locals>.datafilesr � )r~ r7 NFz*Failed reading optional path %s due to: %sz+Failed reading mandatory path %s due to: %sTzMissing mandatory path: %s� Failed to process path %s: %sr9 � random_seedz.Badly formatted metadata random_seed entry: %sr� rD z#Failed to read provided file %s: %sr ru z(Failed to read network configuration: %s�meta�dsmodez ec2-metadatazNo '%s' entry in metadata)� functools�partialr r� �dictrh �strrp r- r[ rT r_ �IOErrorrH rI r& rf r �base64� b64decode� ValueError� TypeErrorr, r{ �KeyErrorrb � KEY_COPIES)r. r� �results�datar/ rD �required� translator�foundrl r9 r� r� �metadata_filesrx �net_item�content� target_key� source_key� is_requiredr r� r �read_v2� s� �!� ���� ��������� ���� ���� � �zBaseReader.read_v2N�F) r' r( r) rV �abc�abstractmethodr[ r_ ra rb rp r{ r� r r r r rS � s rS )� metaclassc sF e Zd Z� fdd�Zdd� Zddd�Zdd � Zd d � Zd d � Z� Z S )�ConfigDriveReaderc s t t| ��|� d | _d S r )�superr� rV � _versionsrU �� __class__r r rV f s zConfigDriveReader.__init__c G s |gt |� }tjj|� S r )rh rC rD �join)r. rY rZ � componentsr r r r[ j s z ConfigDriveReader._path_joinFc C s t j||d�S )Nru )r � load_filer] r r r r_ n s z ConfigDriveReader._path_readc s@ | j d u r | �| jd�� � fdd�t�� �D �}t|�| _ | j S )Nrt c s$ g | ]}t j�t j�� ��r|�qS r )rC rD �isdirr� �rc �d�rD r r re t s ��z?ConfigDriveReader._fetch_available_versions.<locals>.<listcomp>)r� r[ rT rC �listdir�sorted)r. r� r r� r ra q s � z+ConfigDriveReader._fetch_available_versionsc C s` | � | jddd�}tj�|�si S z t�| �|��W S ty/ } z t d||f �|�d }~ww )Nr r zmeta-data.jsonr� ) r[ rT rC rD rE r r� r_ rf r )r. rD rl r r r rb | s � ����z$ConfigDriveReader._read_ec2_metadatac C s� i }t �� D ]}| �| j|�}tj�|�r|||< qt|�dkr'td| j ��i }t � � D ]O\}\}}}||v ru|| }z| � |�}W n t yV } zt d| �| �d} ~ ww z||�||< W q- t yt } z t d|| f �| �d} ~ ww t�|�||< q-|d } |d } | �d| �} | r�| �� } d d � | D �|d< d | v r�| d |d < d |d �} d| v r�| d | d< | �dd�| d< i | d< | S )z�Reads a version 1 formatted location. Return a dict with metadata, userdata, dsmode, files and version (1). If not a valid path, raise a NonReadable exception. r z%s: no files foundzFailed to read: %sNr� r r r6 c S s" g | ] }t |�r|�d �s|�qS )�#)rr rB )rc �liner r r re � s ���z-ConfigDriveReader.read_v1.<locals>.<listcomp>r r5 )r7 r9 r� z user-datar r~ r� )�FILES_V1�keysr[ rT rC rD rE rr r& r- r_ r� r rf �copy�deepcopyr, � splitlines)r. r� r/ rD �md�keyr� �default�contentsrl �keydatar �linesr� r r r �read_v1� s^ � �� ���� � � zConfigDriveReader.read_v1r� ) r' r( r) rV r[ r_ ra rb r� � __classcell__r r r� r r� e s r� c s@ e Zd Zd� fdd� Zdd� Zddd �Zd d � Zd d � Z� ZS )�MetadataReaderN� c s4 t t| ��|� || _t|�| _t|�| _d | _d S r ) r� r� rV � ssl_details�float�timeout�int�retriesr� )r. �base_urlr� r� r� r� r r rV � s zMetadataReader.__init__c C sb | j d ur| j S g }| �| jd�}| j|dd�}|�� D ]}|�� }|s%q |�|� q || _ | j S )Nrt Tru )r� r[ rT r_ r� �striprO )r. r� � version_pathr� r� r r r ra � s z(MetadataReader._fetch_available_versionsFc C s6 dd� }t j|| j| j| j|d�}|r|j�� S |jS )Nc S s8 zt |j�}|dkr W dS W dS ttfy Y dS w )Ni� FT)r� �coder� r� )� _request_args�causer� r r r �should_retry_cb� s ���z2MetadataReader._path_read.<locals>.should_retry_cb)r� r� r� � exception_cb)r �readurlr� r� r� r� r^ )r. rD r^ r� �responser r r r_ � s � zMetadataReader._path_readc G s t j|g|�R � S r )r � combine_urlrX r r r r[ s zMetadataReader._path_joinc C s t j| j| j| jd�S )N)r� r� r� )r �get_instance_metadatar� r� r� r` r r r rb s �z!MetadataReader._read_ec2_metadata)Nr� r� r� ) r' r( r) rV ra r_ r[ rb r� r r r� r r� � s r� c s� | du rdS g d�g d�d��| � dg �}| � dg �}| � dg �}g }i �d}d }g }|D �]��g } t�fd d ���� D ��} d �v rI�d | d < d} �� d �r]�� d ��� } | ��d < | � d �| �d �d d�} �fdd�|D �D ]�} t�fdd �| �� D ��}| d dkr�|�ddi� nH| d dkr�|�ddi� n:| d dv r�|�d| d i� n*| d dv r�|�d| � d�d �� n| d d v r�| �d d i� |�d | � d�d �� | d d!v r�| �d d"i� | d d#kr�d"|d#< | d d$kr�d"|d$< | �|� qt| �d%| i� �d d&v �rXi }| �r| |d'< ��� D ]\}}|d(k�r&�q|�d)��r3|�||i� �q|| }|d*7 }|�| d+d,t��d( �f� | �||d-�� || d < nZ�d d.v �r�d/�d0 �d1 f }| �|�d1 �d2 d3�� |�| d0d,�d0 f� |�| d d4�d1 �d0 f� | ��d2 |d5�� n�d t v�r�t � d6�d � | �d7| d8�� |�| � | �| d < q-d9d� |D �}|�s�|�rE|du �r�t � � }��� D ] \}}|� d ��r�q�|� d:�|v �r�||d: |d < �q�|D ]"}|� d'�}|�std;| ��||v�rtd<| ��|| |d < �q�|D ]'\} }� }t|ttf��r9� �fd=d�|D �| |< �q � �| d | |< �q t �� }|�re|D ]} | d |v �rc|| d | d'< d>| d< �qN|D ]} | } | �dd?i� |�| � �qgd*|d@�S )Aa) Return a dictionary of network_config by parsing provided OpenStack ConfigDrive NetworkData json format OpenStack network_data.json provides a 3 element dictionary - "links" (links are network devices, physical or virtual) - "networks" (networks are ip network configurations for one or more links) - services (non-ip services, like dns) networks and links are combined via network items referencing specific links via a 'link_id' which maps to a links 'id' field. To convert this format to network_config yaml, we first iterate over the links and then walk the network list to determine if any of the networks utilize the current link; if so we generate a subnet entry for the device We also need to map network_data.json fields to network_config fields. For example, the network_data links 'id' field is equivalent to network_config 'name' field for devices. We apply more of this mapping to the various link types that we encounter. There are additional fields that are populated in the network_data.json from OpenStack that are not relevant to network_config yaml, so we enumerate a dictionary of valid keys for network_yaml and apply filtering to drop these superflous keys from the network_config yaml. N)r/ �type� mac_address�subnets�params�mtu) r� �address�netmask� broadcast�metric�gateway� pointopoint�scope�dns_nameservers� dns_search�routes)�physical�subnet�links�networks�serviceszbond%dr c 3 �( � | ]\}}|� d v r||fV qdS )r� Nr �rc �krd �� valid_keysr r � <genexpr>P � � �z#convert_net_json.<locals>.<genexpr>r/ �ethernet_mac_address�idr� )r/ �macr� r� c s g | ] }|d � d kr|�qS )�linkr� r )rc rQ )r� r r re f s z$convert_net_json.<locals>.<listcomp>c 3 r� )r� Nr r� r� r r r� g r� � ipv4_dhcp�dhcp4� ipv6_dhcp�dhcp6)� ipv6_slaaczipv6_dhcpv6-stateless�ipv6_dhcpv6-stateful)�ipv4�staticr� � ip_address)r� r� )�ipv6�static6z accept-raFr )r� r� Tr� r� r� )�bondr� � bond_linksr r5 �bond_interfacesz%s)r� r/ )�vlanz%s.%s� vlan_link�vlan_id�vlan_mac_address)r/ r r� z%%s.%s)r� r/ z9Unknown network_data link type (%s); treating as physicalr� )r� r� c S s& g | ]}|� d �dkrd|vr|�qS )r� r� r/ )r, r� r r r re � s r� z#No mac_address or name entry for %sz"Unable to find a system nic for %sc s g | ] }� �| d �qS )r/ r )rc �target)�fmt� link_id_infor r re � s �� infiniband� nameserver)r7 �config)r, r� r- �lower�updaterO rB r� r� �KNOWN_PHYSICAL_TYPESrH �warningr �get_interfaces_by_macr� � isinstancerh �tuple�get_ib_hwaddrs_by_interface) � network_json� known_macsr� r� r� � link_updates� bond_name_fmt� bond_numberr r� �cfg� link_mac_addr�curinfo�networkr� r� r� rd � link_namer/ � need_names�_link_id�infor� r� r� �targets�ib_known_hwaddrs�servicer )r r� r r� r �convert_net_json s � � � � �� �� � �� ���� � � �� r& )NN)*r� r� r� r� rC � cloudinitr �loggingr r r r r �cloudinit.sourcesr �cloudinit.sources.helpersr � getLoggerr' rH r� r� r� rj � OS_FOLSOM� OS_GRIZZLY� OS_HAVANA� OS_LIBERTY� OS_NEWTON_ONE� OS_NEWTON_TWO�OS_OCATA�OS_ROCKYri r r� r& r* �ABCMetarS r� r� r& r r r r �<module> sR �� L Eo:
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings