| Server IP : 23.254.227.96 / Your IP : 216.73.216.7 Web Server : Apache/2.4.62 (Unix) OpenSSL/1.1.1k System : Linux hwsrv-1277026.hostwindsdns.com 4.18.0-477.13.1.el8_8.x86_64 #1 SMP Tue May 30 14:53:41 EDT 2023 x86_64 User : viralblo ( 1001) PHP Version : 8.1.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3.6/site-packages/cloudinit/sources/__pycache__/ |
Upload File : |
3
�� b9 � @ sz d Z ddlZddlZddlZddlmZ ddlZddlmZ ddl m
Z
ddl m Z ddl
mZ ddl
mZmZmZ eje�Zd Zd
Zd d d
d d d
d�Zed�dd�ZG dd� de
�ZG dd� de �Z G dd� de�Z dd� Z e ed�dd �Z G d d � d ej!�Z"e#d�d d �Z$ed!fe e#ed"�d#d$�Z%e"ej&ffgZ'd%d&� Z(ed'k�rvddl)Z)d(Z*e)j+e*d)�Z,e,j-� e.ej/e%� �� dS )*a� Datasource for LXD, reads /dev/lxd/sock representaton of instance data.
Notes:
* This datasource replaces previous NoCloud datasource for LXD.
* Older LXD images may not have updates for cloud-init so NoCloud may
still be detected on those images.
* Detect LXD datasource when /dev/lxd/sock is an active socket file.
* Info on dev-lxd API: https://linuxcontainers.org/lxd/docs/master/dev-lxd
* TODO( Hotplug support using websockets API 1.0/events )
� N)�JSONDecodeError)� HTTPAdapter)�HTTPConnection)�HTTPConnectionPool)�log)�sources�subp�utilz
/dev/lxd/sockz1.0z user-dataznetwork-configz vendor-data)zcloud-init.user-datazcloud-init.network-configzcloud-init.vendor-datazuser.user-datazuser.network-configzuser.vendor-data)�returnc C s� dddddd�gd�gd�} t jd �r�yt j d g�\}}W n. t jk
rh } ztjd
|� | S d }~X nX |j� d kr�tj� d
d }|dkr�d| d d d< n*|dkr�d| d d d< nd| d d d< | S )zCReturn network config V1 dict representing instance network config.� ZphysicalZeth0Zdhcp�auto)�typeZcontrol)r
�nameZsubnets)�version�configzsystemd-detect-virtzHUnable to run systemd-detect-virt: %s. Rendering default network config.NZkvm�uname� Zppc64leZenp0s5r r r Zs390xZenc9Zenp5s0)r ZwhichZProcessExecutionError�LOG�warning�stripr Z system_info)Z
network_v1Z virt_type�_�errZarch� r �#/usr/lib/python3.6/DataSourceLXD.py� generate_fallback_network_config4 s(
r c s$ e Zd Z� fdd�Zdd� Z� ZS )�SocketHTTPConnectionc s t � jd� || _d S )N� localhost)�super�__init__� socket_path)�selfr )� __class__r r r V s z SocketHTTPConnection.__init__c C s$ t j t jt j�| _| jj| j� d S )N)�socketZAF_UNIXZ SOCK_STREAMZsock�connectr )r r r r r# Z s z SocketHTTPConnection.connect)�__name__�
__module__� __qualname__r r# �
__classcell__r r )r! r r U s r c s$ e Zd Z� fdd�Zdd� Z� ZS )�SocketConnectionPoolc s || _ t� jd� d S )Nr )r r r )r r )r! r r r ` s z SocketConnectionPool.__init__c C s
t | j�S )N)r r )r r r r � _new_connd s z SocketConnectionPool._new_conn)r$ r% r& r r) r' r r )r! r r( _ s r( c @ s e Zd Zddd�ZdS )�LXDSocketAdapterNc C s t t�S )N)r( �LXD_SOCKET_PATH)r �urlZproxiesr r r �get_connectioni s z LXDSocketAdapter.get_connection)N)r$ r% r& r- r r r r r* h s r* c C s� d| kr | S | d }d}t |t�s4tj|d| � | S tt| j� ��dkrZtj|d| � | S |jd�dkrxtj|d| � n&td|kd |kf�s�tj|d
| � | S tj|d | � |S ) aM If network-config contains top level 'network' key, then remove it.
Some providers of network configuration may provide a top level
'network' key (LP: #1798117) even though it is not necessary.
Be friendly and remove it if it really seems so.
Return the original value if no change or the updated value if changed.Znetworkz.Top level network key in network-config %s: %szwas not a dictr zhad multiple top level keysr Zdisabledzwas config/disabledr z!but missing 'config' or 'version'z#fixed by removing shifting network.) �
isinstance�dictr �debug�len�list�keys�get�all)ZcfgZ network_valZbmsgr r r �_maybe_remove_top_networkm s"
r6 )�
metadata_typer
c C s� t |t�r|S |dkri S ytj|�}W n8 tk
r` } z tjdj| |d��|�W Y dd}~X nX |dkr~tjdj| |d���|S )a6 Convert raw instance data from str, bytes, YAML to dict
:param metadata_type: string, one of as: meta-data, vendor-data, user-data
network-config
:param metadata_value: str, bytes or dict representing or instance-data.
:raises: InvalidMetaDataError on invalid instance-data content.
NzAInvalid {md_type}. Expected str, bytes or dict but found: {value})Zmd_type�valuez:Invalid {md_type} format. Expected YAML but found: {value})r. r/ r � load_yaml�AttributeErrorr �InvalidMetaDataException�format)r7 Zmetadata_valueZparsed_metadata�excr r r �_raw_instance_data_to_dict� s
r> c @ sj e Zd ZdZejZejZdZe d�dd�Z
e d�d d
�Z e d�d d �Z
e d�d
d�Zeed�dd��ZdS )�
DataSourceLXDZLXD�
merged_cfg�user.meta-data�user.vendor-data�user.user-data)r
c C s t � S )z@Check platform environment to report if this datasource may run.)�is_platform_viable)r r r r �_is_platform_viable� s z!DataSourceLXD._is_platform_viablec C s� | j � stjd� dS tjtjdtd�| _td| jjd��| _ | jjdi �}|jdi �}|rftd|�}t
| j t �s�tj tj
| j �|g�| _ d| jkr�| jd | _d | jkr�ttd | jd ��| _d
| jkr�| jd
| _d S ) z=Crawl LXD socket API instance data and return True on successz+Not an LXD datasource: No LXD socket found.FzCrawl of metadata service)Zlogfunc�msg�funcz meta-datar zuser.meta-dataz user-dataznetwork-configz vendor-dataT)rE r r0 r Zlog_time�
read_metadata�_crawled_metadatar> r4 �metadatar. r/ Z
mergemanydictr9 Z userdata_rawr6 �_network_configZvendordata_raw)r r Z
user_metadatar r r � _get_data� s4
zDataSourceLXD._get_datac C s dj ttd�S )z.Return subplatform details for this datasourcez"LXD socket API v. {ver} ({socket}))Zverr" )r< �LXD_SOCKET_API_VERSIONr+ )r r r r �_get_subplatform� s z DataSourceLXD._get_subplatformc C s@ t dd�}|jdi �}t|t�s*tj|�}|jd�| jjd�kS )z%Return True if instance_id unchanged.T)�
metadata_onlyz meta-dataz instance-id)rH r4 r. r/ r r9 rJ )r Zsys_cfg�response�mdr r r �check_instance_id� s
z DataSourceLXD.check_instance_idc C s6 | j tjkr0| jjd�r(| jjd�| _ nt� | _ | j S )z�Network config read from LXD socket config/user.network-config.
If none is present, then we generate fallback configuration.
znetwork-config)rK r �UNSETrI r4 r )r r r r �network_config� s
z DataSourceLXD.network_configN)r@ rA rB rC )r$ r% r& Zdsnamer rS rK rI Zsensitive_metadata_keys�boolrE rL �strrN rR �propertyr/ rT r r r r r? � s $r? c C s" t jjt�r tjt jt�j�S dS )z=Return True when this platform appears to have an LXD socket.F)�os�path�existsr+ �stat�S_ISSOCK�lstat�st_moder r r r rD � s rD F)� api_versionrO r
c C s� i }d}|d | d }t j� ���}|j|t� � dj|d�}|j|�}tjd|j|� |j sxt
j dj|j||j d���|j |d< |r�|S | i |d d �}|d
}|j|�}tjd|j|� |j s�t
j dj|j||j d���y |j
� } W n< tk
�r$ }
z t
j d j||j d ��|
�W Y d
d
}
~
X nX x�t| �D ]�} dj| d�} |j| �}tjd|j| � |j �r�| jd�d }
|j |d
|
< |
tk�r�t|
|k�r�|j |t|
< ntjd|
|
jddd�� ntjd| |j|j � �q0W W d
Q R X |S )a� Fetch metadata from the /dev/lxd/socket routes.
Perform a number of HTTP GETs on known routes on the devlxd socket API.
Minimally all containers must respond to http://lxd/1.0/meta-data when
the LXD configuration setting `security.devlxd` is true.
When `security.devlxd` is false, no /dev/lxd/socket file exists. This
datasource will return False from `is_platform_viable` in that case.
Perform a GET of <LXD_SOCKET_API_VERSION>/config` and walk all `user.*`
configuration keys, storing all keys and values under a dict key
LXD_SOCKET_API_VERSION: config {...}.
In the presence of the following optional user config keys,
create top level aliases:
- user.user-data -> user-data
- user.vendor-data -> vendor-data
- user.network-config -> network-config
:return:
A dict with the following mandatory key: meta-data.
Optional keys: user-data, vendor-data, network-config, network_mode
Below <LXD_SOCKET_API_VERSION> is a dict representation of all raw
configuration keys and values provided to the container surfaced by
the socket under the /1.0/config/ route.
z
http://lxd�/z{route}meta-data)�routez[GET] [HTTP:%d] %sz3Invalid HTTP response [{code}] from {route}: {resp})�codera �respz meta-data)Z_metadata_api_versionr z meta-datar zSUnable to determine cloud-init config from {route}. Expected JSON but found: {resp})ra rc Nzhttp://lxd{route}r z,Ignoring LXD config %s in favor of %s value.�userz
cloud-initzSkipping %s on [HTTP:%d]:%s���)�requestsZSessionZmountr* r< r4 r r0 Z status_code�okr r; �textZjsonr �sorted�
rpartition�CONFIG_KEY_ALIASESr �replace)r_ rO rQ Zlxd_urlZ version_urlZsessionZmd_routerP Z
config_urlZ
config_routesr= Z config_router, Zcfg_keyr r r rH sp
rH c C s t j| t�S )N)r Zlist_from_depends� datasources)Zdependsr r r �get_datasource_list} s rn �__main__z*Query LXD metadata and emit a JSON object.)� description)0�__doc__rX r" r[ Z json.decoderr rf Zrequests.adaptersr Z$requests.packages.urllib3.connectionr Z(requests.packages.urllib3.connectionpoolr Z cloudinitr Zloggingr r r Z getLoggerr$ r r+ rM rk r/ r r r( r* r6 rV r> Z
DataSourcer? rU rD rH ZDEP_FILESYSTEMrm rn �argparserp �ArgumentParser�parser�
parse_args�printZ
json_dumpsr r r r �<module>
sJ
!
T
u