File manager - Edit - /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyc
Back
� oB�]c @ s� d d l Z d d l 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 d d l m Z d d l m Z d d l m Z d d l m Z m Z d d l m Z e j e � Z d Z i e d d 6e d d 6e d d 6Z d Z d Z d � Z d e j j f d � � YZ d � Z d � Z! d e j" f d � � YZ# e# e j$ f f g Z% d � Z& d S( i����N( t HTTPConnection( t PoolManager( t log( t sources( t url_helper( t util( t net( t EphemeralDHCPv4t NoDHCPLeaseError( t EventTypes http://169.254.42.42s /conf?format=jsont metadata_urls /user_data/cloud-initt userdata_urls /vendor_data/cloud-initt vendordata_urli i c C sU t j d � } | d k r t St j j d � r5 t St j � } d | k rQ t St S( s There are three ways to detect if you are on Scaleway: * check DMI data: not yet implemented by Scaleway, but the check is made to be future-proof. * the initrd created the file /var/run/scaleway. * "scaleway" is in the kernel cmdline. s system-manufacturert Scaleways /var/run/scalewayt scaleway( R t read_dmi_datat Truet ost patht existst get_cmdlinet False( t vendor_namet cmdline( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt on_scaleway2 s t SourceAddressAdapterc B s# e Z d Z d � Z e d � Z RS( sF Adapter for requests to choose the local address to bind to. c K s# | | _ t t | � j | � d S( N( t source_addresst superR t __init__( t selfR t kwargs( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyR M s c C sP t j t j t j d f g } t d | d | d | d | j d | � | _ d S( Ni t num_poolst maxsizet blockR t socket_options( R t default_socket_optionst sockett SOL_SOCKETt SO_REUSEPORTR R t poolmanager( R t connectionsR R! R" ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt init_poolmanagerQ s ( t __name__t __module__t __doc__R R R) ( ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyR I s c C sw yD t j | d d d | d d d | d d � �} t j | j � SWn, t j k rr } | j d k rl d S� n Xd S( sQ Retrieve user data or vendor data. Scaleway user/vendor data API returns HTTP/404 if user/vendor data is not set. This function calls `url_helper.readurl` but instead of considering HTTP/404 as an error that requires a retry, it considers it as empty user/vendor data. Also, be aware the user data/vendor API requires the source port to be below 1024 to ensure the client is root (since non-root users can't bind ports below 1024). If requests raises ConnectionError (EADDRINUSE), the caller should retry to call this function on an other port. t datat timeoutt retriesi t sessiont exception_cbc S s& | j d k o% t | j t j j � S( Ni� ( t codet isinstancet causet requestst exceptionst ConnectionError( t _t exc( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt <lambda>w s i� N( R t readurlt NoneR t decode_binaryt contentst UrlErrorR2 ( t api_addressR. t requests_sessiont respR9 ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt query_data_api_once\ s c C s� x� t d t | d � � D]� } yn t j d | | � t j � } | j d t d d | f � � t | d | d | �} t j d | � | SWq t j k r� } t j d | | � t j d � | } q q Xq W| � d S( s/ Get user or vendor data. Handle the retrying logic in case the source port is used. Scaleway metadata service requires the source port of the client to be a privileged port (<1024). This is done to ensure that only a privileged user on the system can access the metadata service. i i s* Trying to get %s data (bind on port %d)...s http://R s 0.0.0.0R. RA s %s-data downloadeds% Error while trying to get %s data: %si N( t ranget maxt LOGt debugR5 t Sessiont mountR RC R R? t warningt timet sleep( t api_typeR@ R/ R. t portRA R- R9 t last_exc( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt query_data_api� s* t DataSourceScalewayc B s� e Z d Z i e j e j g d 6Z d � Z d � Z d � Z e d � � Z e d � � Z d � Z d � Z e e e d � Z e d � � Z e d � � Z RS( R t networkc C s� t t | � j | | | � t j t j | d d g i � t g � | _ | j d | _ | j d | _ | j d | _ t | j j d t � � | _ t | j j d t � � | _ d | _ d | _ d S( Nt datasourceR R R R R/ R. ( R RQ R R t mergemanydictt get_cfg_by_patht BUILTIN_DS_CONFIGt ds_cfgt metadata_addresst userdata_addresst vendordata_addresst intt gett DEF_MD_RETRIESR/ t DEF_MD_TIMEOUTR. R< t _fallback_interfacet _network_config( R t sys_cfgt distrot paths( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyR � s c C s� t j | j d | j d | j �} t j t j | j � � | _ t d | j | j | j � | _ t d | j | j | j � | _ d S( NR. R/ s user-datas vendor-data( R R; RX R. R/ t jsont loadsR R= R> t metadataRP RY t userdata_rawRZ t vendordata_raw( R RB ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt _crawl_metadata� s c C s� t � s t S| j d k r. t j � | _ n y< t | j � �' t j d t j d d d | j � Wd QXWn* t k r� } t j t t | � � t SXt S( Nt logfunct msgs Crawl of metadata servicet func( R R R_ R< R t find_fallback_nicR R t log_timeRF RG Ri R t logexct strR ( R t e( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt _get_data� s c C s� | j r | j S| j d k r1 t j � | _ n i d d 6d | j d 6} i d d 6g } | j d r� | i d d 6d | j d d d 6d | j d d d 6d | j d d d 6g 7} n | | d <i d d 6| g d 6| _ | j S( s` Configure networking according to data received from the metadata API. t physicalt types %st namet dhcp4t ipv6t statict addresst gatewayt netmaskt subnetsi t versiont configN( R` R_ R< R Rm Rf ( R t netcfgR| ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt network_config� s c C s d S( N( R< ( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt launch_index� s c C s | j d S( Nt id( Rf ( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt get_instance_id� s c C s� g | j d D] } | d ^ q } d } t | � } xO | j j d g � D]8 } | j | � sg qL n | j | | j d d � � qL W| S( Nt ssh_public_keyst keys AUTHORIZED_KEY=t tagsR8 t ( Rf t lenR\ t startswitht appendt replace( R R� t ssh_keyst akeypret plent tag( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt get_public_ssh_keys� s $ !c C s | j d S( Nt hostname( Rf ( R t fqdnt resolve_ipt metadata_only( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt get_hostname s c C s d S( N( R< ( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt availability_zone s c C s d S( N( R< ( R ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt region s ( R* R+ t dsnameR t BOOT_NEW_INSTANCEt BOOTt update_eventsR Ri Rr t propertyR� R� R� R� R R� R� R� ( ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyRQ � 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/DataSourceScaleway.pyt get_datasource_list s (' Rd R R$ RK R5 t$ requests.packages.urllib3.connectionR t% requests.packages.urllib3.poolmanagerR t cloudinitR t loggingR R R R t cloudinit.net.dhcpR R t cloudinit.eventR t getLoggerR* RF t DS_BASE_URLRV R] R^ R t adapterst HTTPAdapterR RC RP t DataSourceRQ t DEP_FILESYSTEMR� R� ( ( ( sH /usr/lib/python2.7/site-packages/cloudinit/sources/DataSourceScaleway.pyt <module> s8 ' )l
| ver. 1.4 |
.
| PHP 8.1.32 | Generation time: 0.01 |
proxy
|
phpinfo
|
Settings