| Server IP : 3.96.16.70 / Your IP : 216.73.216.15 Web Server : Apache System : Linux ip-172-31-26-103.ca-central-1.compute.internal 6.1.163-186.299.amzn2023.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Feb 24 16:35:42 UTC 2026 x86_64 User : ec2-user ( 1000) PHP Version : 8.4.18 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3.9/site-packages/cloudinit/sources/__pycache__/ |
Upload File : |
a
ꬊh�5 � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZm Z m
Z
m Z m Z m
Z
ddlZddlmZ ddlmZ ddlmZ ddlmZ dd lmZmZmZ e�e �Z d
Z d Z d d
dd d
dd�Z e!d�dd�Z"G dd� de�Z#G dd� de�Z$G dd� de�Z%e&e!d�dd�Z'G d d � d ej(�Z)e*d�d d �Z+e d fe&e*e!d!�d"d#�Z,e)ej-ffgZ.d$d%� Z/e d&k�r�ddl0Z0d'Z1e0j2e1d(�Z3e3�4� e5e�6e,� �� 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)�Any�Dict�List�Optional�Tuple�Union�cast)� HTTPAdapter)�HTTPConnection)�HTTPConnectionPool)�log)�sources�subp�utilz
/dev/lxd/sockz1.0� user-data�network-config� vendor-data)�cloud-init.user-datazcloud-init.network-config�cloud-init.vendor-data�user.user-datazuser.network-config�user.vendor-data��returnc
C s� dddddd�gd�gd�} t �d �r�zt � d g�\}}W n6 t jyp } z t�d
|� | W Y d }~S d }~0 0 |�� d v r�t�� 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 �name�subnets)�version�configzsystemd-detect-virtzHUnable to run systemd-detect-virt: %s. Rendering default network config.N)ZkvmZqemu�uname� Zppc64leZenp0s5r r r Zs390xZenc9Zenp5s0)r ZwhichZProcessExecutionError�LOG�warning�stripr Z system_info)Z
network_v1Z virt_type�_�errZarch� r( �C/usr/lib/python3.9/site-packages/cloudinit/sources/DataSourceLXD.py� generate_fallback_network_config5 s0
���
� r* c s$ e Zd Z� fdd�Zdd� Z� ZS )�SocketHTTPConnectionc s t � �d� || _d S �NZ localhost)�super�__init__� socket_path��selfr/ �� __class__r( r) r. Z s z SocketHTTPConnection.__init__c C s$ t � t jt j�| _| j�| j� d S �N)�socketZAF_UNIXZ SOCK_STREAMZsock�connectr/ �r1 r( r( r) r6 ^ s z SocketHTTPConnection.connect)�__name__�
__module__� __qualname__r. r6 �
__classcell__r( r( r2 r) r+ Y s r+ c s$ e Zd Z� fdd�Zdd� Z� ZS )�SocketConnectionPoolc s || _ t� �d� d S r, )r/ r- r. r0 r2 r( r) r. d s z SocketConnectionPool.__init__c C s
t | j�S r4 )r+ r/ r7 r( r( r) � _new_connh s z SocketConnectionPool._new_conn)r8 r9 r: r. r= r; r( r( r2 r) r< c s r< c @ s e Zd Zddd�ZdS )�LXDSocketAdapterNc C s t t�S r4 )r< �LXD_SOCKET_PATH)r1 �urlZproxiesr( r( r) �get_connectionm s z LXDSocketAdapter.get_connection)N)r8 r9 r: rA r( r( r( r) r> l s r> )�
metadata_typer c
C s� t |t�r|S |du ri S zt�|�}W n: tyb } z"t�dj| |d��|�W Y d}~n
d}~0 0 |du r�t�dj| |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})�
isinstance�dictr � load_yaml�AttributeErrorr �InvalidMetaDataException�format)rB Zmetadata_valueZparsed_metadata�excr( r( r) �_raw_instance_data_to_dictq s*
�����rK c @ s� e Zd ZU dZejZejZejj d Z e
e df e d< e
d�dd�Ze
d�dd �Ze d�d
d �Ze d�d d
�Zeed�dd��ZdS )�
DataSourceLXDZLXD)�user.meta-datar r r r .�sensitive_metadata_keysr c C s t � S )z@Check platform environment to report if this datasource may run.)�is_platform_viabler7 r( r( r) �_is_platform_viable� s z!DataSourceLXD._is_platform_viablec C s� | � � st�d� dS tjtjdtd�| _td| j�d��| _ | j�di �}|�di �}|rftd|�}t
| j t �s�t� t�
| j �|g�| _ d| jv r�| jd | _d | jv r�td | jd �| _d
| jv r�| 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�func� meta-datar rM r r r T)rP r# �debugr Zlog_time�
read_metadata�_crawled_metadatarK �get�metadatarD rE Z
mergemanydictrF Z userdata_raw�_network_configZvendordata_raw)r1 r Z
user_metadatar( r( r) � _get_data� s<
� � � �
�
zDataSourceLXD._get_datac C s dj ttd�S )z.Return subplatform details for this datasourcez"LXD socket API v. {ver} ({socket}))Zverr5 )rI �LXD_SOCKET_API_VERSIONr? r7 r( r( r) �_get_subplatform� s �z DataSourceLXD._get_subplatformc C s@ t dd�}|�di �}t|t�s*t�|�}|�d�| j�d�kS )z%Return True if instance_id unchanged.T)�
metadata_onlyrS z instance-id)rU rW rD rE r rF rX )r1 Zsys_cfg�response�mdr( r( r) �check_instance_id� s
z DataSourceLXD.check_instance_idc C s6 | j tjkr0| j�d�r(| j�d�| _ nt� | _ | j S )z�Network config read from LXD socket config/user.network-config.
If none is present, then we generate fallback configuration.
r )rY r �UNSETrV rW r* r7 r( r( r) �network_config� s �z DataSourceLXD.network_configN)r8 r9 r: Zdsnamer ra rY rV �
DataSourcerN r �str�__annotations__�boolrP rZ r\ r` �propertyrE rb r( r( r( r) rL � s
��
"rL c C s" t j�t�r t�t �t�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) rO � s rO F)� api_versionr] r c C s
i }d}|d | d }t �� ���}|�|t� � dj|d�}|�|�}t�d|j|� |j sxt
� dj|j||j d���|j |d< |r�|W d � S | i |d d
�}|d }|�|�}t�d|j|� |j s�t
� dj|j||j d���z |�
� } W n> t�y4 }
z$t
� d j||j d
��|
�W Y d }
~
n
d }
~
0 0 t| �D ]�} dj| d�} |�| �}t�d|j| � |j �r�| �d�d }
|j |d |
< |
tv �r�t|
|v�r�|j |t|
< nt�d|
|
�ddd�� nt�d| |j|j � �q>W d � n1 �s�0 Y |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})�coderq �resprS N)Z_metadata_api_versionr rS r zSUnable to determine cloud-init config from {route}. Expected JSON but found: {resp})rq rs zhttp://lxd{route}���z,Ignoring LXD config %s in favor of %s value.�userz
cloud-initr zSkipping %s on [HTTP:%d]:%s)�requestsZSessionZmountr> rI rW r# rT Z status_code�okr rH �textZjsonr �sorted�
rpartition�CONFIG_KEY_ALIASESr$ �replace)ro r] r_ Zlxd_urlZ version_urlZsessionZmd_router^ Z
config_urlZ
config_routesrJ Z config_router@ Zcfg_keyr( r( r) rU � s�
��
�
�� ���
��(rU c C s t �| t�S r4 )r Zlist_from_depends� datasources)Zdependsr( r( r) �get_datasource_liste s r~ �__main__z*Query LXD metadata and emit a JSON object.)� description)7�__doc__rh r5 rk Z json.decoderr �typingr r r r r r r rv Zrequests.adaptersr
Z$requests.packages.urllib3.connectionr Z(requests.packages.urllib3.connectionpoolr Z cloudinitr
Zloggingr r r Z getLoggerr8 r# r? r[ r{ rE r* r+ r< r> rd rK rc rL rf rO rU ZDEP_FILESYSTEMr} r~ �argparser� �ArgumentParser�parser�
parse_args�printZ
json_dumpsr( r( r( r) �<module> sT $
�
$
T�� w
�