Viewing File: /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyo
ó
oBú]c @ s¢ d d l m Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m
Z
e j e ƒ Z
d Z d d e e f d d e e f d
d
e e f d d e e f d
d
e e f g Z d e j f d „ ƒ YZ d „ Z d „ Z d „ Z d d e d d d „ Z d „ Z d e f d „ ƒ YZ d e f d „ ƒ YZ e e j e j f f g Z d „ Z e d k ržd „ Z! e! ƒ n d S( iÿÿÿÿ( t print_functionN( t log( t sources( t
url_helper( t utils
2012-03-01s meta-data/instance-ids meta-data/local-hostnames meta-data/public-keyss meta-data/vendor-datas vendor-datas user-datat DataSourceMAASc B sn e Z d Z d Z d
Z d
Z d „ Z e d „ ƒ Z d „ Z
d „ Z d „ Z d „ Z
d „ Z d „ Z RS( sç
DataSourceMAAS reads instance information from MAAS.
Given a config metadata_url, and oauth tokens, it expects to find
files under the root named:
instance-id
user-data
hostname
vendor-data
t MAASc C sS t j j | | | | ƒ d | _ t j j | j d ƒ | _ t | j
ƒ | _ d S( Nt maas( R t
DataSourcet __init__t Nonet base_urlt ost patht joint seed_dirt get_id_from_ds_cfgt ds_cfgt id_hash( t selft sys_cfgt distrot paths( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR 0 s c C s% | j s t | j ƒ | _ n | j S( N( t
_oauth_helpert get_oauth_helperR ( R ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt oauth_helper6 s c C s# t j j | ƒ } d | | j f S( Ns %s [%s]( R R t __str__R ( R t root( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR < s c
C s | j } y$ | j | j t | j ƒ ƒ t SWn< t k
r@ n, t k
rk } t j d | j | ƒ ‚ n X| j d d ƒ } | sˆ t SyL | j | ƒ sž t S| j | t
| d | j j d | j d d ƒƒ t SWn% t k
rû t j t d | ƒ t SXd S( Ns %s was malformed: %st metadata_urlt read_file_or_urlR t retriesi s$ Failed fetching metadata from url %s( R t _set_dataR t read_maas_seed_dirt Truet MAASSeedDirNonet MAASSeedDirMalformedt LOGt warningt getR
t Falset wait_for_metadata_servicet read_maas_seed_urlR t readurlR t ExceptionR t logexc( R t mcfgt exct url( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt _get_data@ s.
c C s… | | _ | \ } } } | | _ | | _ | | _ | r y t j | ƒ | _ Wq t k
r} } t j d | ƒ d | _ q Xn d S( Ns" Invalid content in vendor-data: %s( R t userdata_rawt metadatat vendordata_pureR t convert_vendordatat vendordata_rawt
ValueErrorR$ R% R
( R R/ t datat udt mdt vdt e( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR b s c C s d | j S( s/ Return the subplatform metadata source details.s
seed-dir (%s)( R ( R ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt _get_subplatformp s c C se | j } d } y t | j d | ƒ ƒ } Wn$ t k
rQ t j t d | ƒ n X| d k rb t Sd } y+ | | k r’ t | j d | ƒ ƒ } n Wn! t k
r¶ t j d | ƒ n Xt j ƒ } | j
d ƒ rß | d } n d
| t f } | g } | j j
d | d | d | ƒ \ } } | r8t j d | ƒ n# t j d
| t t j ƒ | ƒ ƒ t | ƒ S( Nix t max_waits Failed to get max wait. using %si i2 t timeouts Failed to get timeout, using %st /iÿÿÿÿs %s/%s/meta-data/instance-idt urlss Using metadata source: '%s's( Giving up on md from %s after %i seconds( R t intR& R+ R R, R$ R' R% t timet endswitht
MD_VERSIONR t wait_for_urlt debugt criticalt bool( R R/ R- R= R> t starttimet check_urlR@ t _response( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR( t s4
c C sD | j d k r t St j | d | j f i ƒ } | j t | ƒ k S( s locally check if the current system is the same instance.
MAAS doesn't provide a real instance-id, and if it did, it is
still only available over the network. We need to check based
only on local resources. So compute a hash based on Oauth tokens.t
datasourceN( R R
R' R t get_cfg_by_patht dsnameR ( R R t ncfg( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt check_instance_id– s N( t __name__t
__module__t __doc__RN R
R R R t propertyR R R0 R R< R( RP ( ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR ! s " "c C sA d } t g | D] } | | j | ƒ f ^ q ƒ } t j | S( s° Return an oauth helper instance for values in cfg.
@raises ValueError from OauthUrlHelper if some required fields have
true-ish values but others do not.t consumer_keyt consumer_secrett token_keyt token_secret( RU RV RW RX ( t dictR& R t OauthUrlHelper( t cfgt keyst rt kwargs( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR ¢ s .c C sT d } d j g | D] } | j | d ƒ ^ q ƒ } d t j | j d ƒ ƒ j ƒ S( s; Given a config, generate a unique identifier for this node.RU RW RX t t s v1:s utf-8( s consumer_keys token_keys token_secret( R R& t hashlibt sha256t encodet hexdigest( R t fieldst ft idstr( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR ¬ s .c C sm | j d ƒ r | d } n t j j | ƒ sJ t t j | ƒ ƒ d k rY t d ƒ ‚ n t d | d d ƒS( Ns file://i i s %s: not a directorys file://%st version( t
startswithR R
t isdirt lent listdirR" R) R
( t seed_d( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR µ s
.c C sx | d k r t j } n | j d ƒ r4 | d } n i } x.t D]&\ } } } }
| d k rr d | | f } n d | | | f } y‚ t j | ƒ } | | d | d | d | ƒ}
|
j ƒ rð | r× |
j | | <qt j |
j ƒ | | <n t
j d | |
j ƒ WqA t j
k
rf} | j d k rK|
rKt d
| | f ƒ ‚ qg| j d k rg| ‚ qgqA XqA Wt | | ƒ S( s›
Read the maas datasource at seed_url.
read_file_or_url is a method that should provide an interface
like util.read_file_or_url
Expected format of seed_url is are the following files:
* <seed_url>/<version>/meta-data/instance-id
* <seed_url>/<version>/meta-data/local-hostname
* <seed_url>/<version>/user-data
If version is None, then <version>/ will not be used.
R? iÿÿÿÿs %s/%ss %s/%s/%sR R> t ssl_detailss4 Fetching from %s resulted in an invalid http code %si” s Missing required %s: %sN( R
R R RC t DS_FIELDSR t fetch_ssl_detailst okt contentst
decode_binaryR$ R% t codet UrlErrorR# t check_seed_contents( t seed_urlR R> Rh R R R9 R
t _dictnamet binaryt optionalR/ Rn t respR; ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR) ¿ s4
c
C st i } g } x¢ t D]š \ } } } } | | k rM | s | j | ƒ q q n d | k rŸ | j d ƒ \ } } }
| | k rŠ i | | <n | | | | |
<q | | | | <q Wt | ƒ d k rÖ t d | ƒ ‚ n | rõ t d | | f ƒ ‚ n d } | j d ƒ rUt ƒ } t j
| j d ƒ d | d t ƒ} | | k rUt d ƒ ‚ qUn | j d ƒ | j d
ƒ | f S( s½ Validate if dictionary content valid as a return for a datasource.
Either return a (userdata, metadata, vendordata) tuple or
Raise MAASSeedDirMalformed or MAASSeedDirNone
R? i s %s: no data files founds %s: missing files %ss vendor-datat defaultt alloweds% vendor-data was not loadable as yaml.s user-datas meta-dataN( Ro t appendt partitionRk R" R# R
R& t objectR t load_yaml(
t contentt seedt rett missingt spatht dpatht _binaryRz t topt _t pt vd_datat err( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyRv î s2
R" c B s e Z RS( ( RQ RR ( ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR" s R# c B s e Z RS( ( RQ RR ( ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR# s c C s t j | t ƒ S( N( R t list_from_dependst datasources( t depends( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt get_datasource_list# s t __main__c
s˜ d d l } d d l } d d l } | j d d ƒ } | j d d d d d d
d ƒ| j d d d d d
d
d ƒ| j d d d d d d
d ƒ| j d d d d d d
d ƒ| j d d d d d d
d ƒ| j d d d d d d
t ƒ| j d d d d ƒ } xQ dD dE dF f D]@ \ } } | j | d | ƒ} | j d# d d$ d% d& d
d ƒqW| j ƒ } i | j
d' 6| j d( 6| j d) 6| j
d* 6} | j d k rxf dG D][ }
d- |
d. } t j j | ƒ r¬t j | t j ƒ r¬| j j d/ | ƒ | | _ q¬q¬Wn | j r¸t j | j ƒ } d0 | k rF| d0 d1 } n xA | j ƒ D]3 }
|
| k rS| |
d k rS| |
| |
<qSqSW| j d k r¸d2 | k r¸| d2 | _ q¸n | j d k rç| j j d3 ƒ | j d4 ƒ n t | ƒ ‰ ‡ f d5 † ‰ ‡ f d6 † ‰ ‡ ‡ ‡ f d7 † ‰ | j d! k r1| j j d8 | j ƒ ˆ j } | j d9 d: k sz| j j d; ƒ r•t | j ƒ \ } } } n- t | j d | j! d< | d= d> ƒ\ } } } t" d? ƒ t" | d k rád@ n | j# ƒ ƒ t" dA ƒ | j | ƒ t" dB ƒ | j | d k r'd@ n | ƒ nc | j d k rPˆ | j ƒ nD | j d k r”| j j$ d: ƒ s„dC | j | _ n ˆ | j ƒ n d S(H sä
Call with single argument of directory or http or https url.
If url is given additional arguments are allowed, which will be
interpreted as consumer_key, token_key, token_secret, consumer_secret
iÿÿÿÿNt descriptions Interact with MAAS DSs --configt metavart filet helps specify DS config fileR| s --ckeyt keys the consumer key to auth withs --tkeys the token key to auth withs --csect secrets the consumer secret (likely '')R` s --tsecs the token secret to auth withs --apiverRh s the apiver to use ( can be used)t titlet subcommandst destt subcmdt crawls crawl the datasourceR& s do a single GET of provided urls
check-seeds read and verify seed at urlR/ s the datasource urlt nargst ?RU RW RX RV t 91_kernel_cmdline_urlt 90_dpkg_maass /etc/cloud/cloud.cfg.d/s .cfgs Used config in %s.
RL R R s) Must provide a url or a config with url.
i c s ˆ j | d d ƒj S( NR i ( R* Rr ( R/ ( R ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt geturle s c s$ t d | ˆ | ƒ j ƒ f ƒ d S( Ns == %s ==
%s
( t printt decode( R/ ( R¢ ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt printurli s c s | j d ƒ r’ xŠ ˆ | ƒ j ƒ j ƒ D]c } | j d ƒ rT ˆ d | | f ƒ q( | d k rw ˆ d | d f ƒ q( ˆ d | | f ƒ q( Wn
ˆ | ƒ d S( NR? s %s%ss meta-datas
meta-data/( RC R¤ t
splitlines( R/ t line( R R¢ R¥ ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyR l s s Checking seed at %s
i R? s file://R R i s === user-data ===s N/As === meta-data ===s === vendor-data ===s %s/( s crawls crawl the datasource( s gets do a single GET of provided url( s
check-seeds read and verify seed at url( R R¡ (% t argparset pprintt syst ArgumentParsert add_argumentR
RD t add_subparserst
add_parsert
parse_argst ckeyt tkeyt tsect csect configR R
t existst accesst R_OKt stderrt writeR t read_confR\ R/ t exitR Rœ R* Ri R R) t apiverR£ R¤ RC ( R¨ R© Rª t parsert subcmdst nameR– R‹ t argst credst fnamet fpathR[ R— R* t userdataR2 R: ( ( R R¢ R R¥ sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt main( sŠ
'
%
"
"(" t
__future__R Ra R RB t cloudinitR t loggingR R R t getLoggerRQ R$ RD R' R! Ro R R R R R R
R) Rv R+ R" R# t DEP_FILESYSTEMt DEP_NETWORKR R‘ RÅ ( ( ( sD /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceMAAS.pyt <module> s8
. & i
Back to Directory
File Manager