Google
Edit File: DataSourceOpenStack.cpython-39.opt-1.pyc
a '�Dgg( � @ s d dl Z d dlZd dlmZmZmZmZ d dlmZm Z d dl m Z d dl m Z d dlmZ d dlmZ e �e�ZdZd eiZd Zd ZeegZd Zd Z dZ eZ e e ee g7 Z G dd� dej ej �Z!G dd� de!�Z"ddd�Z#e"ej$ffe!ej$ej%ffgZ&dd� Z'dS )� N)�dmi�sources� url_helper�util)� EventScope� EventType)�NoDHCPLeaseError)�EphemeralDHCPv4)�DataSourceOracle)� openstackziid-dsopenstackz instance-idzOpenStack NovazOpenStack ComputeZOpenTelekomCloudz SAP CCloud VMZ HUAWEICLOUDc s� e Zd ZdZejZdZej e j e j e j e jhiZ� fdd�Zdd� Zdd� Zd d � Zed d � �Zd d� Zdd� Zdd� Z� ZS )�DataSourceOpenStackZ OpenStackFc sH t t| ��|||� d | _t�| j�| _d | _i | _ t j | _ t j | _ d S �N)�superr �__init__�metadata_addressr Zfetch_ssl_details�paths� ssl_details�version�filesr �UNSET� ec2_metadata� network_json)�self�sys_cfg�distror �� __class__� �I/usr/lib/python3.9/site-packages/cloudinit/sources/DataSourceOpenStack.pyr < s z DataSourceOpenStack.__init__c C s" t j�| �}d|| j| jf }|S )Nz%s [%s,ver=%s])r � DataSource�__str__�dsmoder )r �rootZmstrr r r r E s zDataSourceOpenStack.__str__c C s dj | jjd�dg}| j�d|�}dd� |D �}t|�t|�kr\t�dtt|�t|� �� t |�rj|}nt� d� |}g }i }|D ]"}t � |d �}|� |� |||< q�| �� }t�� } t j||j|jd d �\} } | r�t�d || � nt�d |tt�� | �� |�| �| _t| �S )Nz"http://[fe80::a9fe:a9fe%25{iface}])Zifacezhttp://169.254.169.254Z metadata_urlsc S s g | ]}t �|�r|�qS r )r Zis_resolvable_url)�.0�xr r r � <listcomp>R � zADataSourceOpenStack.wait_for_metadata_service.<locals>.<listcomp>z,Removed the following from metadata urls: %sz+Empty metadata url list! using default listr F)�urlsZmax_wait�timeoutZconnect_synchronouslyzUsing metadata source: '%s'z2Giving up on OpenStack md from %s after %s seconds)�formatr �fallback_interface�ds_cfg�get�set�LOG�debug�list�len�warningr Z combine_url�append�get_url_params�time� monotonicZ wait_for_urlZmax_wait_seconds�timeout_seconds�intr �bool) r Z DEF_MD_URLSr' ZfilteredZmd_urlsZurl2base�urlZmd_url� url_paramsZ start_timeZ avail_urlZ _responser r r �wait_for_metadata_serviceJ sN ��� � � z-DataSourceOpenStack.wait_for_metadata_servicec C s t �| �� �S r )r Z instance_id_matches_system_uuidZget_instance_id)r r r r r �check_instance_idy s z%DataSourceOpenStack.check_instance_idc C sn | j tjkr| j S t�| j�dd��r2d| _ | j S | jtjkrLt� d� dS t� d� t j | jdd�| _ | j S )z@Return a network config dict for rendering ENI or netplan files.Zapply_network_configTNz<Unexpected call to network_config when network_json is None.z(network config provided via network_json)Z known_macs) �_network_configr r r Zis_falser+ r, r r. r2 r/ r Zconvert_net_json)r r r r �network_config} s � �z"DataSourceOpenStack.network_configc C s� | j r�z<t| j| jj�� | �� }W d � n1 s60 Y W q� ttjfy~ } z t� t t |�� W Y d}~dS d}~0 0 nFz | �� }W n8 tjy� } z t� t t |�� W Y d}~dS d}~0 0 | � |� d�g�| _| jtjk� r�dS |� di �}t�|tg�}|| _|� d�| _|� d�| _|� d�| _|d | _| j�|� d i �� |� d �}zt�|�| _W n8 t�y� } z t � d |� d| _W Y d}~n d}~0 0 |� d �}zt�|�| _ W n8 t�y� } z t � d |� d| _ W Y d}~n d}~0 0 dS )a Crawl metadata, parse and persist that data for this instance. @return: True when metadata discovered indicates OpenStack datasource. False when unable to contact metadata service or when metadata format is invalid or disabled. NFr! �metadataz ec2-metadataZ networkdataZuserdatar r Z vendordataz"Invalid content in vendor-data: %sZ vendordata2z#Invalid content in vendor-data2: %sT) �perform_dhcp_setupr r r* �_crawl_metadatar r �InvalidMetaDataExceptionr Zlogexcr. �strZ_determine_dsmoder, r! ZDSMODE_DISABLEDZ mergemanydict�DEFAULT_METADATAr@ r r Z userdata_rawr r �updateZconvert_vendordataZvendordata_raw� ValueErrorr2 Zvendordata2_raw)r �results�eZmdZvdZvd2r r r � _get_data� sL �* z DataSourceOpenStack._get_datac C s� z| � � st�d��W n: tyP } z"t�djt|�d���W Y d}~n d}~0 0 | �� }z t| j| j |j |j d�}W nv t j y� } zt�t|���W Y d}~nLd}~0 t jtfy� } z&dj| jd�}t�|�|�W Y d}~n d}~0 0 |S )z�Crawl metadata service when available. @returns: Dictionary with all metadata discovered for this datasource. @raise: InvalidMetaDataException on unreadable or broken metadata. z No active metadata service foundz,IOError contacting metadata service: {error})�errorN)r �retriesr( z Broken metadata address {addr})�addr)r< r rC �IOErrorr) rD r4 �read_metadata_servicer r Z num_retriesr7 r Z NonReadableZBrokenMetadata)r rI r; �result�msgr r r rB � s6 ���� "�"z#DataSourceOpenStack._crawl_metadatac C sp d| j �d�v }t�� s dS t�d�}|tv r2dS t�d�tv rDdS |rTt� � rTdS t� d��d�t krldS dS ) z<Return True when a potential OpenStack platform is detected.ZOracleZdatasource_listTzsystem-product-namezchassis-asset-tag� � product_nameF) r r, r Zis_x86r Z read_dmi_data�VALID_DMI_PRODUCT_NAMES�VALID_DMI_ASSET_TAGS�oracleZ_is_platform_viableZ get_proc_env�DMI_PRODUCT_NOVA)r Z accept_oraclerS r r r � ds_detect� s z DataSourceOpenStack.ds_detect)�__name__� __module__� __qualname__Zdsnamer r r> rA r ZNETWORKr ZBOOT_NEW_INSTANCEZBOOTZ BOOT_LEGACYZHOTPLUGZsupported_update_eventsr r r< r= �propertyr? rJ rB rX � __classcell__r r r r r * s& �� / 5%r c @ s e Zd ZdZdZdS )�DataSourceOpenStackLocalau Run in init-local using a dhcp discovery prior to metadata crawl. In init-local, no network is available. This subclass sets up minimal networking with dhclient on a viable nic so that it can talk to the metadata service. If the metadata service provides network configuration then render the network configuration for that instance based on metadata. TN)rY rZ r[ �__doc__rA r r r r r^ s r^ � c C s t j| |||d�}|�� S )N)r r( rL )r ZMetadataReaderZread_v2)Zbase_urlr r( rL �readerr r r rO s �rO c C s t �| t�S r )r Zlist_from_depends� datasources)Zdependsr r r �get_datasource_list s rc )Nr` r` )(Zloggingr5 Z cloudinitr r r r Zcloudinit.eventr r Zcloudinit.net.dhcpr Zcloudinit.net.ephemeralr Zcloudinit.sourcesr rV Zcloudinit.sources.helpersr Z getLoggerrY r. Z DEFAULT_IIDrE rW ZDMI_PRODUCT_COMPUTErT ZDMI_ASSET_TAG_OPENTELEKOMZDMI_ASSET_TAG_SAPCCLOUDZDMI_ASSET_TAG_HUAWEICLOUDrU Z SourceMixinr r r^ rO ZDEP_FILESYSTEMZ DEP_NETWORKrb rc r r r r �<module> s> �� Z �