ó
oBú]c @ s. d d l m Z d d l m 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 Z
d Z d
Z d Z d Z d
e j f d „ ƒ YZ e e j e j f f g Z d „ Z e e
e e e d „ Z e e
e e e d „ Z e
d k r*d d l Z e j d d ƒ Z e j d d d d d d e ƒe j d d d d d d e
ƒe j d d d d! e d d" d e ƒe j d# d d d! e d d$ d e ƒe j d% d d& d! e d d' d e ƒe j ƒ Z e d( e j! d) e j" d* e j# d+ e j$ d, e j% ƒ Z& e j' e& ƒ GHn d S(- iÿÿÿÿ( t ec2_utils( t log( t sources( t helpers( t
url_helper( t utils http://169.254.169.254s 1.0i i
i t Exoscalet DataSourceExoscalec B sS e Z d Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
RS( R ix c C s´ t t | ƒ j | | | ƒ t j d ƒ | j j d t ƒ | _ | j j d t ƒ | _
t | j j d t ƒ ƒ | _
| j j d t ƒ | _ | j j d t ƒ | _ i | _ d S( Ns$ Initializing the Exoscale datasourcet metadata_urlt api_versiont password_server_portt timeoutt retries( t superR t __init__t LOGt debugt ds_cfgt gett METADATA_URLR t API_VERSIONR t intt PASSWORD_SERVER_PORTR
t URL_TIMEOUTt url_timeoutt URL_RETRIESt url_retriest extra_config( t selft sys_cfgt distrot paths( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyR s
c C sQ d } | j j d ƒ } t j | ƒ } | j d | d ƒ rM t j d ƒ n d S( s< Adjust set-passwords module to run 'always' during each boott
set_passwordst semt config_s5 Overriding module set-passwords with frequency alwaysN( R t
get_ipath_curR t FileSemaphorest cleart NoneR R ( R t cfgt is_new_instancet modt sem_patht
sem_helper( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt activate+ s
c C sX d j | j | j ƒ } t j d | g d | j d | j d t j ƒ \ } } t | ƒ S( s. Wait for the metadata service to be reachable.s {}/{}/meta-data/instance-idt urlst max_waitR t status_cb(
t formatR R R t wait_for_urlt url_max_waitR R t criticalt bool( R R t urlt _response( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt wait_for_metadata_service: s c C sS t j d t j d d d | j ƒ } | s. i St | j | j | j | j | j
ƒ S( sw
Crawl the metadata service when available.
@returns: Dictionary of crawled metadata content.
t logfunct msgs waiting for the metadata servicet func( R t log_timeR t infoR7 t
read_metadataR R R
R R ( R t metadata_ready( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt crawl_metadataH s c C s· | j ƒ s t St j d t j d d d | j ƒ } | s> t S| d | _ | d | _ | j d ƒ } i } | r˜ i t
d 6| d 6i t d 6d
6} n t j | j | g ƒ | _ t
S( sç Fetch the user data, the metadata and the VM password
from the metadata service.
Please refer to the datasource documentation for details on how the
metadata server and password server are crawled.
R8 R9 s Crawl of metadata serviceR: s user-datas meta-datat passwordt
ssh_pwautht expiret chpasswd(
t _is_platform_viablet FalseR R; R R R? t userdata_rawt metadataR t Truet
mergemanydictR ( R t dataR@ t password_config( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt _get_dataZ s*
c C s | j S( N( R ( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt get_config_obj† s c C s t j d ƒ j t ƒ S( Ns system-product-name( R t
read_dmi_datat
startswitht EXOSCALE_DMI_NAME( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyRD ‰ s ( t __name__t
__module__t dsnameR2 R R, R7 R? RL RM RD ( ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyR s , c C s t j | t ƒ S( N( R t list_from_dependst datasources( t depends( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt get_datasource_list• s c
C s• d j | | | ƒ } t j | d d d i d d 6d | d | ƒ} | j j d ƒ } | d k re d St j | d d d i d
d 6d | d | ƒ| S(
s Obtain the VM's password if set.
Once fetched the password is marked saved. Future calls to this method may
return empty string or 'saved_password'.s {}:{}/{}/t ssl_detailst headerst send_my_passwordt DomU_RequestR R s utf-8t t saved_passwordN( R\ R] ( R0 R t read_file_or_urlR& t contentst decode( R R R
R R t password_urlt responseR@ ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt get_password™ s$
c C sç i } | | d <yH t j | | d | d | ƒ| d <t j | | d | d | ƒ| d <Wn* t k
r„ } t j t d | | ƒ i SXy/ t d | d | d | d
| d | ƒ | d <Wn, t k
râ } t j t d
| | | ƒ n X| S( s8 Query the metadata server and return the retrieved data.t _metadata_api_versionR R s user-datas meta-datas( failed reading from metadata url %s (%s)R R R
R R R@ s2 failed to read from password server url %s:%s (%s)( t ec2t get_instance_userdatat get_instance_metadatat ExceptionR t logexcR Rc ( R R R
R R t crawled_metadatat e( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyR= º s8
t __main__Nt descriptions Query Exoscale Metadatas
--endpointt metavart URLt helps The url of the metadata service.t defaults --versiont VERSIONs. The version of the metadata endpoint to query.s --retriest NUMt types, The number of retries querying the endpoint.s --timeouts. The time in seconds to wait before timing out.s --password-portt PORTs/ The port on which the password endpoint listensR R R
R R (( t cloudinitR Re R t loggingR R R R t getLoggerRQ R R R R R R RP t
DataSourceR t DEP_FILESYSTEMt DEP_NETWORKRU RW Rc R= t argparset ArgumentParsert parsert add_argumentR t
parse_argst argst endpointt versiont
password_portR R RJ t
json_dumps( ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceExoscale.pyt <module> s€ w "