3
\me7D @ s: 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! ej"e#Z$d Z%d Z&d
Z'dddddddZ(e)dddZ*d9eee) e
e)e f dddZ+G dd deZ,G dd deZ-G d d d eZ.e)e/d d d Z0G d!d" d"e j1Z2e3dd#d$Z4d:ej5e)e3d&d'd(Z6d;ej5e)e3ej7d)d*d+Z8G d,d- d-eZ9G d.d/ d/Z:e&e9j;fe)e9e/d0d1d2Zd3d4 Z?e#d5kr6ddl@Z@d6ZAe@jBeAd7ZCeCjD eEejFe s z0DataSourceLXD.network_config..z8LXD datasource generating network config using fallback.)
rX r UNSETrU rY r? r@ rV r r( itemsr) r )r/ rb r r r network_config s"
z DataSourceLXD.network_config)rH rI rJ rK rL )r3 r4 r5 Zdsnamer rg rX r
r strrU
DataSourceZsensitive_metadata_keysr rO intrN staticmethodboolrQ rY r[ ra propertyr@ ri r6 r r )r0 r rG s$
rG c C s" t jjtr tjt jtjS dS )z=Return True when this platform appears to have an LXD socket.F)ospathexistsr: statS_ISSOCKlstatst_moder r r r rP s rP T)sessionr; do_raisec C sr t | ||}|js*tjd||j|j i S y|j S tk
rl } z tj dj
||jd|W Y d d }~X nX d S )NzSkipping %s on [HTTP:%d]:%szFUnable to process LXD config at {url}. Expected JSON but found: {resp})r; resp) _do_requestokr r( status_codetextZjsonr r rC rD )rw r; rx Z url_responserE r r r _get_json_response s r~ )rw r; rx r c C s xHt ddd
D ]8}| j|}d|jkrDtjd tjd|j|| qP qW tjd|j| |r|j rt j
dj |j||j d |S ) N r r# i g?z,[GET] [HTTP:%d] %s, retrying %d more time(s)z[GET] [HTTP:%d] %sz3Invalid HTTP response [{code}] from {route}: {resp})codeZroutery )
rangerV r| timeZsleepr r r( r{ r rC rD r} )rw r; rx Zretriesr_ r r r rz , s$
rz c @ s0 e Zd Ze Ze Ze Ze ZeeB eB ZdS )r] N) r3 r4 r5 r ZNONECONFIGDEVICESr^ ALLr r r r r] I s
r] c @ s@ e Zd ZefedddZejedddZ e
eddd Z d
S ) _MetaDataReader) api_versionc C s || _ tjt| j | _d S )N)r r combine_urlLXD_URL _version_url)r/ r r r r r- R s z_MetaDataReader.__init__)rw r c C s di i}t j| jd}t||}xt|D ]}t jt|}t||dd}|jsdtj d||j
|j q*|j dd
}|j |d |< |t
kr*t
| |kr|j |t
| < q*tjd||jdd d q*W |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' F)rx zSkipping %s on [HTTP:%d]:%s/r# z,Ignoring LXD config %s in favor of %s value.userz
cloud-initr )r r r r~ sortedr rz r{ r r( r| r}
rpartitionCONFIG_KEY_ALIASESr replace) r/ rw r' Z
config_urlZ
config_routesZ config_routeZconfig_route_urlZconfig_route_responseZcfg_keyr r r _process_configV s0
z _MetaDataReader._process_config)r\ r c C s t j }|j| jt d| ji}tj|krLtj | jd}t
||j |d< tj |krf|j
| j| tj|krtj | jd}t||dd}|r||d< |S Q R X d S )NZ_metadata_api_versionz meta-datarb F)rx )requestsSessionZmountr r9 r r] r^ r r rz r} r updater r r~ )r/ r\ rw r` Zmd_router; rb r r r __call__ s
z_MetaDataReader.__call__N) r3 r4 r5 rZ rj r- r r r@ r r] r r r r r r Q s 7r )r r\ r c C s t | d|dS )a8 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 `is_platform_viable` 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\ r r r rT s #rT c C s t j| tS )N)r Zlist_from_depends datasources)Zdependsr r r get_datasource_list s r __main__z*Query LXD metadata and emit a JSON object.) description)r\ )N)T)T)G__doc__Zloggingrp r1 rs r enumr r Z json.decoderr Ztypingr r r r r r
r r Zrequests.adaptersr Zurllib3.connectionr
Zurllib3.connectionpoolr Z cloudinitr r r r r Z
cloudinit.netr Z getLoggerr3 r r: rZ r r rj r! r) r* r7 r9 r@ rF rk rG rn rP r r~ ZResponserz r] r r rT ZDEP_FILESYSTEMr r argparser ArgumentParserparser
parse_argsprintZ
json_dumpsr r r r sd $
$
j
Q
'