/usr/lib/python3/dist-packages/cloudinit/sources/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/sources/__pycache__/DataSourceLXD.cpython-310.pyc (13798B)
o
thD @ sH d Z ddlZddlZddlZddlZddlZddlmZmZ ddl m
Z
ddl m Z m
Z
mZmZmZmZmZ ddlZddlmZ ddlmZ ddlmZ dd lmZm Z m Z m Z m Z dd
l m!Z! e"e#Z$d Z%d Z&d
Z'dddddddZ(de)fddZ* d9deee) de
e)e f fddZ+G dd deZ,G dd deZ-G d d d eZ.d e)de/fd d Z0G d!d" d"e j1Z2 #d:d$ej3d%e)d&e4fd'd(Z5 #d:d$ej3d%e)d&e4dej6fd)d*Z7G d+d, d,eZ8G d-d. d.Z9e&e8j:fd/e)d0e8de/fd1d2Z;e2e j
e#d5kr"ddl?Z?d6Z@e?jAe@d7ZBeBC eDeEe;e8j:d8 dS dS );a Datasource for LXD, reads /dev/lxd/sock representation 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://documentation.ubuntu.com/lxd/en/latest/dev-lxd/
N)Flagauto)JSONDecodeError)AnyDictListOptionalTupleUnioncast) HTTPAdapter)HTTPConnection)HTTPConnectionPool)
atomic_helpersourcessubp
url_helperutil)find_fallback_nicz
/dev/lxd/sockz1.0z
http://lxd user-datanetwork-config vendor-data)cloud-init.user-datazcloud-init.network-configcloud-init.vendor-datauser.user-datazuser.network-configuser.vendor-datareturnc
C s d} t drIz
t dg\}}W n t jy, } ztd| | W Y d }~S d }~ww | dv rIt d d }|dkrAdS |d krGd
S d S | S ) Neth0zsystemd-detect-virtzHUnable to run systemd-detect-virt: %s. Rendering default network config.)kvmqemuuname ppc64leenp0s5s390xenc9enp5s0)r whichProcessExecutionErrorLOGwarningstripr system_info) default_name virt_type_errarch r2 A/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceLXD.py _get_fallback_interface_name/ s(
r4 nicsc C sF t }|r td| n t }td| dd|dddgdgd S )
zCReturn network config V1 dict representing instance network config.zCLXD datasource generating network from discovered active device: %szVLXD datasource generating network from systemd-detect-virt platform default device: %s physicaldhcpr )typecontrol)r9 namesubnets)versionconfig)r r) debugr4 )r5 primary_nicr2 r2 r3 generate_network_configI s$
rA c $ e Zd Z fddZdd Z ZS )SocketHTTPConnectionc s t d || _d | _d S N localhost)super__init__ socket_pathsockselfrH __class__r2 r3 rG p s
z SocketHTTPConnection.__init__c C s$ t t jt j| _| j| j d S N)socketAF_UNIX SOCK_STREAMrI connectrH rK r2 r2 r3 rR u s z SocketHTTPConnection.connect)__name__
__module__ __qualname__rG rR
__classcell__r2 r2 rL r3 rC o s rC c rB )SocketConnectionPoolc s || _ t d d S rD )rH rF rG rJ rL r2 r3 rG { s z SocketConnectionPool.__init__c C s
t | jS rN )rC rH rS r2 r2 r3 _new_conn s
z SocketConnectionPool._new_conn)rT rU rV rG rY rW r2 r2 rL r3 rX z s rX c @ s" e Zd ZdddZ dddZdS )LXDSocketAdapterNc C s t tS rN )rX LXD_SOCKET_PATH)rK urlproxiesr2 r2 r3 get_connection s z LXDSocketAdapter.get_connectionc C s | |j|S rN )r^ r\ )rK requestverifyr] certr2 r2 r3 get_connection_with_tls_context s z0LXDSocketAdapter.get_connection_with_tls_contextrN )NN)rT rU rV r^ rb r2 r2 r2 r3 rZ s
rZ
metadata_typec
C sx t |tr|S |du r
i S zt|}W n ty+ } z tdj| |d|d}~ww |du r:tdj| |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})md_typevaluez:Invalid {md_type} format. Expected YAML but found: {value})
isinstancedictr load_yamlAttributeErrorr InvalidMetaDataExceptionformat)rc metadata_valueparsed_metadataexcr2 r2 r3 _raw_instance_data_to_dict s.
ro c s e Zd ZU dZejZeee f e
d< ejZ e eee f e
d< ej
jd Zee df e
d< dZded d
f fd d Zed efd
dZd efddZd e fddZd e fddZed efddZ Z S )
DataSourceLXDLXD_network_config_crawled_metadata)user.meta-datar r r r .sensitive_metadata_keysTci_pkl_versionr Nc s t | d| _d S )NT)rF _unpickleskip_hotplug_detect)rK rv rL r2 r3 rw s
zDataSourceLXD._unpicklec C sB t jtstdt dS tt tj s tdt dS dS )z@Check platform environment to report if this datasource may run.z%s does not exist.Fz%s is not a socketT)
ospathexistsr[ r) r* statS_ISSOCKlstatst_moder2 r2 r2 r3 ds_detect s zDataSourceLXD.ds_detectc C s t | _td| jd| _| jdi }|di }|r&| jtd| d| jv r1| jd | _d| jv r?td| jd | _d| jv rJ| jd | _dS )z=Crawl LXD socket API instance data and return True on success meta-datar> rt r r r T)
read_metadatars ro getmetadataupdate userdata_rawrr vendordata_raw)rK r>
user_metadatar2 r2 r3 _get_data s&
zDataSourceLXD._get_datac C s dj ttdS )z.Return subplatform details for this datasourcez"LXD socket API v. {ver} ({socket}))verrO )rk LXD_SOCKET_API_VERSIONr[ rS r2 r2 r3 _get_subplatform s z DataSourceLXD._get_subplatformc C sB t tjd}|di }t|tst|}|d| jdkS )z%Return True if instance_id unchanged.
metadata_keysr z instance-id) r MetaDataKeys META_DATAr rf rg r rh r )rK sys_cfgresponsemdr2 r2 r3 check_instance_id s
z DataSourceLXD.check_instance_idc C s | j tjkr?| jtjkr| t| jtr?| jdr(t d | jd | _ n| jdr?dd | jd
D }t || _ | j tjkrNt d t | _ t t| j S )zNetwork config read from LXD socket config/user.network-config.
If none is present, then we generate fallback configuration.
r z,LXD datasource using provided network configdevicesc S s g | ] \}}|d dkr|qS )r9 nicr2 ).0kvr2 r2 r3
s
z0DataSourceLXD.network_config..z8LXD datasource generating network config using fallback.)
rr r UNSETrs r rf rg r r) r? itemsrA r )rK r r2 r2 r3 network_config s(
z DataSourceLXD.network_config) rT rU rV dsnamer r rr r
r str__annotations__rs r
DataSourceru r rx intrw staticmethodboolr r r r propertyrg r rW r2 r2 rL r3 rp s"
rp Tsessionr\ do_raisec
C sr t | ||}|jstd||j|jd i S z| W S ty8 } zt
dj ||jdd|d }~ww )NSkipping %s on [HTTP:%d]:%sutf-8zFUnable to process LXD config at {url}. Expected JSON but found: {resp})r\ resp) _do_requestokr) r? status_codecontentdecodejsonr r rj rk )r r\ r url_responsern r2 r2 r3 _get_json_response s,
r c C s t dddD ]}| |}d|jkr!td td|j|| q td|j| |r?|js?t
dj |j||j
d d
|S ) N r i g?z,[GET] [HTTP:%d] %s, retrying %d more time(s)z[GET] [HTTP:%d] %sz3Invalid HTTP response [{code}] from {route}: {resp}r )coderouter )ranger r timesleepr) r* r? r r rj rk r r )r r\ r retriesr r2 r2 r3 r , s*
r c @ s0 e Zd Ze Ze Ze Ze ZeeB eB ZdS )r N) rT rU rV r NONECONFIGDEVICESr ALLr2 r2 r2 r3 r I s r c @ sD e Zd ZefdefddZdejdefddZ de
defd d
Z d S ) _MetaDataReader api_versionc C s || _ tt| j | _d S rN )r r combine_urlLXD_URL _version_url)rK r r2 r2 r3 rG R s z_MetaDataReader.__init__r r c
C s di i}t | jd}t||}t|D ]L}t t|}t||dd}|jd}|j s6t
d||j | q|
dd } ||d | < | tv r`t| |vrT||t| < qt
d| | d d
d q|S ) a Iterate on LXD API config items. Promoting CONFIG_KEY_ALIASES
Any CONFIG_KEY_ALIASES which affect cloud-init behavior are promoted
as top-level configuration keys: user-data, network-data, vendor-data.
LXD's cloud-init.* config keys override any user.* config keys.
Log debug messages if any user.* keys are overridden by the related
cloud-init.* key.
r> Fr r r /r z,Ignoring LXD config %s in favor of %s value.userz
cloud-initr6 )r r r r sortedr r r r r r) r? r
rpartitionCONFIG_KEY_ALIASESr* replace)
rK r r>
config_url
config_routes config_routeconfig_route_urlconfig_route_response
response_textcfg_keyr2 r2 r3 _process_configV s:
z _MetaDataReader._process_configr c C s t T}|| jt d| ji}tj|v r)t | jd}t
||j d|d< tj
|v r6|| | tj|v rOt | jd}t||dd}|rO||d< |W d S 1 s[w Y d S )N_metadata_api_versionr r r Fr )requestsSessionmountr rZ r r r r r r r r r r r r r )rK r r r md_router\ r r2 r2 r3 __call__ s*
$z_MetaDataReader.__call__N) rT rU rV r r rG r r rg r r r r2 r2 r2 r3 r Q s 6r r r c C s t | d|dS )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 /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 `ds_detect` in that case.
Perform a GET of /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
:param api_version:
LXD API version to operated with.
:param metadata_keys:
Instance of `MetaDataKeys` indicating what keys to fetch.
:return:
A dict with the following optional keys: meta-data, user-data,
vendor-data, network-config, network_mode, devices.
Below 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.
)r r )r )r r r2 r2 r3 r s #r c C s t | tS rN )r list_from_depends datasources)dependsr2 r2 r3 get_datasource_list s r __main__z*Query LXD metadata and emit a JSON object.) descriptionr rN )T)F__doc__loggingry rO r| r enumr r json.decoderr typingr r r r r r
r r requests.adaptersr urllib3.connectionr
urllib3.connectionpoolr cloudinitr r r r r
cloudinit.netr getLoggerrT r) r[ r r r r r4 rA rC rX rZ rg ro r rp r r r Responser r r r r DEP_FILESYSTEMr r argparser ArgumentParserparser
parse_argsprint
json_dumpsr2 r2 r2 r3 s
$
& j
R
*