iddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZmZmZmZmZddlmZmZmZmZmZmZmZmZmZddlmZddlm Z ddl!m"Z"m#Z#ddl$m%Z%dd l&m'Z'dd l(m)Z)dd l*m+Z+d Z,d Z-dZ.dZ/e,e-e.gZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8ejre:Z;ddfddfddfdZGd#d$e?Z@Gd%d&e?ZAGd'd(e?ZBdEd)ZCe5fd*ZDGd+d,eZEGd-d.eZFGd/d0eZGGd1de)ej2ZId3ZJd4eeIeKffd5ZLd6ZM dFd7eKd4eNfd8ZOd9ZPdGd:ZQGd;deId?eKd4eNfd@ZUd?eKd4eeIfdAZVd4eKfdBZWdCeKd4eKfdDZXy)HN)Enumunique)AnyDictList NamedTupleOptionalTupleUnioncast) atomic_helperdmiimporter lifecyclenet performance type_utils user_datautil) write_json)Distro) EventScope EventType) launch_index)Paths)CloudInitPickleMixin)eventsdisabledlocalrpass FILESYSTEMNETWORK DataSourcez|EXPERIMENTAL: The structure and format of content scoped under the 'ds' key may change in subsequent releases of cloud-init.zredacted for non-root user cloud-name_unsetunknownz aws-chinac |dk(SNawscs r.Fs 1:zaws-govc |dk(Sr(r*r+s r-r.r.Gs Q%Zr/z azure-chinac |dk(S)Nazurer*r+s r-r.r.Hs qG|r/)zcn-zus-gov-chinac0eZdZdZdZdZdZdZdZde fdZ y ) NetworkConfigSourcezb Represents the canonical list of network config sources that cloud-init knows about. cmdlineds system_cfgfallback initramfsreturnc|jSNvalueselfs r-__str__zNetworkConfigSource.__str__Y zzr/N) __name__ __module__ __qualname____doc__CMD_LINEDS SYSTEM_CFGFALLBACK INITRAMFSstrrBr*r/r-r5r5Ls. H BJHIr/r5c$eZdZdZdZdZdefdZy)NicOrderzRepresents ways to sort NICsmacnic_namer;c|jSr=r>r@s r-rBzNicOrder.__str__crCr/N)rDrErFrGMACNIC_NAMErMrBr*r/r-rOrO]s& CHr/rOceZdZdZy)DatasourceUnpickleUserDataErrorzERaised when userdata is unable to be unpickled due to python upgradesNrDrErFrGr*r/r-rVrVgsOr/rVc eZdZy)DataSourceNotFoundExceptionNrDrErFr*r/r-rYrYkr/rYceZdZdZy)InvalidMetaDataExceptionz8Raised when metadata is broken, unavailable or disabled.NrWr*r/r-r]r]osBr/r]cxtj|}g}g}|jD]\}}|r |dz|z}n|}|j|vs|j|vr|j |t |t r7|jdr&|j ||jdd||<t |tst|||} |j| jd|j| jd| ||<t||d<t||d<|S)zProcess all instance metadata cleaning it up for persisting as json. Strip ci-b64 prefix and catalog any 'base64_encoded_keys' as a list @return Dict copy of processed metadata. /zci-b64:base64_encoded_keyssensitive_keys)copydeepcopyitemslowerappend isinstancerM startswithreplacedictprocess_instance_metadataextendpopsorted) metadatakey_pathrbmd_copyra sens_keyskeyval sub_key_path return_vals r-rlrlss/mmH%GINN$&S #c>C/LL IIK> )!!#~5   \ * c3 CNN9$=  & &| 4;;y"5GCL c4 2\>J & &z~~6K'L M   Z^^,<= >%GCL'&(&,,?%@G !" &y 1G  Nr/c|jdgs|Stj|}|jdD]M}|jd}|}|D])}||vst ||t s||dk7s%||}+|vsI|||<O|S)zRedact any sensitive keys from to provided metadata dictionary. Replace any keys values listed in 'sensitive_keys' with redact_value. rbr_)getrcrdsplitrhrk)rp redact_valuerrrq path_partsobjpaths r-redact_sensitive_keysrs <<(" -mmH%GLL!12 %^^C(  D s4y$/JrN*$i   3;$CI % Nr/c6eZdZUeed<eed<eed<eed<y) URLParamsmax_wait_secondstimeout_seconds num_retriessec_between_retriesN)rDrErFint__annotations__r*r/r-rrsr/rc(eZdZUeeed<eed<y)DataSourceHostnamehostname is_defaultN)rDrErFr rMrboolr*r/r-rrssmr/rc0eZdZUdZeed<eed<eed<y)HotplugRetrySettingsz in seconds force_retry sleep_period sleep_totalN)rDrErFrGrrrr*r/r-rrsr/rc eZdZUeZdZdZdZee e d<dZ dZ dZ eeee fe d<ej"ej$ej&ej(fZeedfe d<dZd Zd Zd Zej8ej<ej>ej@ejBhiZ"ej8ej<hiZ#d e$fd e$fdifddddddf Z%eee e&fdfe d<dZ'dZ(ee dfe d<dZ)e*dddZ+dZ,ee e d<d Z-dPde.de/fdZ0de1ddfd Z2d!Z3de4fd"Z5de4fd#Z6d$Z7d%Z8dQd&Z9e:jvd'd()de4fd*Zd-Z?dSd.Z@d/ZAd0ZBeCd1ZDeCd2ZEd3ZFeCd4ZGd5ZHeCd6ZId7ZJd8ZKd9ZLd:ZMd;ZNd<ZOd=ZPd>ZQd?ZRd@ZSeCdAZTeCdBZUdCZVdTdDZWdEZXdFeYefdGZZdFeYede4fdHZ[dIZ\dJZ]e^dUdKZ_eCdLZ`dMZadNZbdOZcy)Vr#z en_US.UTF-8_undefN _cloud_name_crawled_metadata.network_config_sourcesry  ec2_metadata network_jsonrp)userdataN) userdata_rawN) vendordataN)vendordata_rawN) vendordata2N)vendordata2_rawNcached_attr_defaultsF) combined_cloud_config merged_cfgmerged_system_cfgzsecurity-credentialsr user-datarr vendor-datazds/vendor_datasensitive_metadata_keysrextra_hotplug_udev_rulesdistropathsc||_||_||_d|_i|_d|_d|_d|_d|_d|_ d|_ t|_ t|_ tj|jd|j fi|_|j"si|_|s%t%j&|j|_y||_y)N datasource)sys_cfgrrrrprrrrrmetadata_addressUNSETrrrget_cfg_by_pathdsnameds_cfgrUserDataProcessorud_proc)rArrrrs r-__init__zDataSource.__init__Os   '+   9="#/3+0!** LL<5r  {{DK$66tzzBDL"DLr/ci_pkl_versionr;cdddtddtdddtdddd }|jD]\}}t||rt |||!t|dst |ddt|dr$|j  t |j yyy#t$r&}tjd|t|d}~wwxYw) z(Perform deserialization fixes for Paths.NFr) r_platform_type _subplatformrrrrskip_hotplug_detectrrhotplug_retry_settingscheck_if_fallback_is_allowedcyNFr*r*r/r-r.z&DataSource._unpickle..}r/rz:Unable to unpickle datasource: %s. Ignoring current cache.) rrrehasattrsetattrrrMAttributeErrorLOGdebugrV)rArexpected_attrsrtr?es r- _unpicklezDataSource._unpickleis"&" !(, $!#(#&:5!Q&G  )..0 *JC4%c5) *t;< D8- H 4 $)B  ?DMM"*C $" ? / 67Q>  ?sB C(!C  Cc,tj|Sr=)robj_namer@s r-rBzDataSource.__str__s""4((r/cy)z#Check if running on this datasourceTr*r@s r- ds_detectzDataSource.ds_detectr/c|jjtjk(rtj d|y|j j dg|jgk(rtj d|yy)aJOverride if either: - only a single datasource defined (nothing to fall back to) - command line argument is used (ci.ds=OpenStack) Note: get_cmdline() is required for the general case - when ds-identify does not run, _something_ needs to detect the kernel command line definition. z6Kernel command line set to use a single datasource %s.Tdatasource_listz2Datasource list set to use a single datasource %s.F)rrf parse_cmdlinerrrrzr@s r-override_ds_detectzDataSource.override_ds_detectst ;;   -/"7"7"9 9 IIH  \\  / 4 E IIDd r/c|jr|jS|jr&tj d||jStj d|y)z&Overrides runtime datasource detectionz Detected %szDid not detect %sF)r _get_datarrrr@s r-_check_and_get_datazDataSource._check_and_get_datasX  " " $>># # ^^  II >># # II)4 0r/c|jj}|j}|j}|d}diddgd|d|dt |j |j |jd|j d |j d |d d d |d dd|d dd|jd|jd|dd|d|d|ddd|d||dd|j |j|d|ddiS)z2Return a dictionary of standardized metadata keys.sys_infov1 _beta_keys subplatformavailability-zoneavailability_zonecloud_idr$ cloud_namerdistrdistro_versionrdistro_releaseplatformpublic_ssh_keyspython_versionpython instance-id instance_idkernel_releaseunamelocal-hostnamelocal_hostnamevariant)machineregionrsystem_platformr) get_hostnamerget_instance_idrcanonical_cloud_idrr platform_typeget_public_ssh_keysr)rA instance_datarrrsysinfos r-_get_standardized_metadataz%DataSource._get_standardized_metadatas**,55**,  22 + }o#%6$%6.OOT[[$2D2D doodoo'&/!,!'&/!"4!'&/!"4D.."4#;#;#=!'("3{ {!"!''"21"5#$!.%&!.'(#7+A.++#//#*:#6"9-1  r/c|jsy|r|}n |j}|D]\}}t||st|||!|sd|_yy)zReset any cached metadata attributes to datasource defaults. @param attr_defaults: Optional tuple of (attr, value) pairs to set instead of cached_attr_defaults. NF) _dirty_cacherrr)rA attr_defaults attr_values attributer?s r-clear_cached_attrszDataSource.clear_cached_attrss_    'K33K + 0 IutY'i/ 0 %D r/zGetting metadataalways)log_modec\d|_|j}|s|S|j|S)zDatasources implement _get_data to setup metadata and userdata_raw. Minimally, the datasource should return a boolean True on success. T)rrpersist_instance_data)rA return_values r-get_datazDataSource.get_datas7 !//1   ""$r/c|rXtjj|jjr%t ||jj d|jVtttj|j}|jdd|jddd|i}nZdd|jii}|jtk7r|j|dd<|j tk7r|j |dd<t"|dd <tj|j$|d <d |d d <tj|d |d <d |d d <t'j(|d<|j+|j-| t/j0|}t3t5j6||j8}|jjEd}|djGdd}tjjI|jjJd} t'jL| d||dd} | d|} tjjO| rtjjQ| } t'jR| | d| r| | k7rt'jT| tW||d|jjEd} tW| tY|y#t:$r)}t<j?dtA|Yd}~yd}~wtB$r)}t<j?dtA|Yd}~yd}~wwxYw)aPProcess and write INSTANCE_JSON_FILE with all instance metadata. Replace any hyphens with underscores in key names for use in template processing. :param write_cache: boolean set True to persist obj.pkl when instance_link exists. @return True on successful write, False otherwise. obj_pklNrrr7 meta_datarr_docrz TZZ%7%7D  =/8*5(2G!,oQxj9 77>>- (!#!1!1-!@  'dC "48I"I MM, -&UCJJ**?; 93NCD1  KKA3q6 J!  KKA3q6 J s$(?L## N,M NNNctd)z@Walk metadata sources, process crawled data and save attributes.zlSubclasses of DataSource must implement _get_data which sets self.metadata, vendordata_raw and userdata_raw.)NotImplementedErrorr@s r-rzDataSource._get_data[s! D  r/c R|j} t|jjd|j}|j} tdt|jjd|j}|j} t|jjd|j}|j} t|jjd|j}t||||S#t$r9t j td|jjd|Y wxYw#t$rE|j}t j td|jjd|YwxYw#t$r9t j td|jjd|Y!wxYw#t$r9t j td |jjd|Y*wxYw) zReturn the Datasource's preferred url_read parameters. Subclasses may override url_max_wait, url_timeout, url_retries. @return: A URLParams object with max_wait_seconds, timeout_seconds, num_retries. max_waitz6Config max_wait '%s' is not an int, using default '%s'rtimeoutz5Config timeout '%s' is not an int, using default '%s'retriesz5Config retries '%s' is not an int, using default '%s'rzAConfig sec_between_retries '%s' is not an int, using default '%s') url_max_waitrrrz ValueErrorrlogexcr url_timeoutmax url_retries Exceptionurl_sec_between_retriesr)rAr2r3r4rs r-get_url_paramszDataSource.get_url_paramsbs$$ 4;;??:t7H7HIJH"" !SDE  E A FF>G! G!$>H&%H&c|j.|jj|j|_|r|j |jS|jSr=)rrprocessget_userdata_raw _filter_xdata)rA apply_filters r- get_userdatazDataSource.get_userdatasM ==  LL001F1F1HIDM %%dmm4 4}}r/c|j.|jj|j|_|jSr=)rrr?get_vendordata_rawr@s r-get_vendordatazDataSource.get_vendordatas5 ?? ""ll2243J3J3LMDOr/c|j.|jj|j|_|jSr=)rrr?get_vendordata2_rawr@s r-get_vendordata2zDataSource.get_vendordata2s:    ##||33D4L4L4NOD r/cp|js|jj|_|jSr=)rrrfr@s r-rzDataSource.platform_types,"""&++"3"3"5D """r/c\|js|j|_|jS)aReturn a string representing subplatform details for the datasource. This should be guidance for where the metadata is sourced. Examples of this on different clouds: ec2: metadata (http://169.254.169.254) openstack: configdrive (/dev/path) openstack: metadata (http://169.254.169.254) nocloud: seed-dir (/seed/dir/path) lxd: nocloud (/seed/dir/path) )r_get_subplatformr@s r-rzDataSource.subplatforms*  $ 5 5 7D    r/cF|jrd|jdStS)z?Subclasses should implement to return a "slug (detail)" string.z metadata ())rMETADATA_UNKNOWNr@s r-rLzDataSource._get_subplatforms'   5 56a8 8r/c,|jr |jS|jr|jjtr|jjt}t |t r!|j |_|jS|jj |_tjdtt||jS|jj |_|jS)zReturn lowercase cloud name as determined by the datasource. Datasource can determine or define its own cloud product name in metadata. z5Ignoring metadata provided key %s: non-string type %s) rrprzMETADATA_CLOUD_NAME_KEYrhrMrf_get_cloud_namerrtype)rArs r-rzDataSource.cloud_names   ## # ==T]]../FG**+BCJ*c*#-#3#3#5 $(#7#7#9#?#?#A  K+$ $335;;=D r/c|jS)zReturn the datasource name as it frequently matches cloud name. Should be overridden in subclasses which can run on multiple cloud names, such as DatasourceEc2. )rr@s r-rRzDataSource._get_cloud_names {{r/cX|jsyd|jvr|jdSy)Nz launch-index)rpr@s r-rzDataSource.launch_indexs*}} T]] *==0 0r/ctjtj|jg}|}|D]}|j |}|Sr=)rFilterrsafe_intapply)rA processed_udfiltersnew_udfs r-rAzDataSource._filter_xdatasN    d.?.? @ A  %AWWV_F % r/c|jSr=)rr@s r-r@zDataSource.get_userdata_raws   r/c|jSr=)rr@s r-rEzDataSource.get_vendordata_raws"""r/c|jSr=)rr@s r-rHzDataSource.get_vendordata2_raws###r/ciSr=r*r@s r-get_config_objzDataSource.get_config_objs r/cJt|jjdS)Nz public-keys)normalize_pubkey_datarprzr@s r-rzDataSource.get_public_ssh_keys s$T]]%6%6}%EFFr/cy)a5Publish the public SSH host keys (found in /etc/ssh/*.pub). @param hostkeys: List of host key tuples (key_type, key_value), where key_type is the first field in the public key file (e.g. 'ssh-rsa') and key_value is the key itself (e.g. 'AAAAB3NzaC1y...'). Nr*)rAhostkeyss r-publish_host_keyszDataSource.publish_host_keysrr/cddi}|jD]V\}}|j|s|D]:}d||t|d}tjj |s6|ccSXy)Nsd)vdxvdvtbz/dev/)rerilenrrr")rA short_namemappingsnfromtlistntocands r- _remap_devicezDataSource._remap_devicesx ./$NN, LE5((/ &):c%jl+CD77>>$'K  r/cyr=r*)rA_names r-device_name_to_devicez DataSource.device_name_to_device's r/ct|j} |jj}|S#t$rY|SwxYw)z, (str, bool). is_default is a bool and it's true only if hostname is localhost and was returned by util.get_hostname() as a default. This is used to differentiate with a user-defined localhost hostname. Optionally return (None, False) when metadata_only is True and local-hostname data is not available. localdomain localhostFrNT.rzip-%sr r)rprzrrrget_fqdn_from_hostsfindrMr{ris_ipv4_address gethostbyaddrrjrmr) rAfqdn resolve_ip metadata_only defdomaindefhostdomainrtoksr hosts_fqdnlhosts r-rzDataSource.get_hostnameKs&"  }}DMM$5$56F$G)$ ;; D((*H;&! 11(;Jjooc2Q6:,,S1hmmC0148}**3/ ),+MM"23E""5)--e4Dt9??3/D#emmC&==>D{{3' t9q=AwHXXd12h'FAwH Fi'"*F3H!(J77r/c:|jj|S)N) data_source)rget_package_mirror_infor@s r-rz"DataSource.get_package_mirror_infos{{22t2DDr/source_event_typesci}|D][}|jjD]<\}}||vs |j|s t||<||j |>]|Sr=)supported_update_eventsrerzsetadd)rArsupported_eventsevent update_scope update_eventss r-get_supported_eventszDataSource.get_supported_eventss~24' >E--335 >M)+// =9<(6$\266u= > > r/c |j|}|jD]h\}}tjd|jdj |Dcgc]}|jc}|j d|ztffj|r#|j |j}|rytjd|dj |Dcgc]}|jc}ycc}wcc}w)aRefresh cached metadata if the datasource supports this event. The datasource has a list of supported_update_events which trigger refreshing all cached metadata as well as refreshing the network configuration. @param source_event_types: List of EventTypes which may trigger a metadata update. @return True if the datasource did successfully update cached metadata due to source_event_type. z:Update datasource metadata and %s config due to events: %s, z _%s_configTz(Datasource %s not updated for events: %sF) rrerrr?rrrr)rArrscopematched_eventsrresults r-update_metadata_if_supportedz'DataSource.update_metadata_if_supporteds 445GH%5%;%;%= F !E> IIL  NC55;;CD   # #lU&:E%B$D E F   # # %]]_F 6  II0BCuu{{C D !DDs C1C6cyrr*)rArs r-check_instance_idzDataSource.check_instance_idsr/cy)acheck_if_fallback_is_allowed() Checks if a cached ds is allowed to be restored when no valid ds is found in local mode by checking instance-id and searching valid data through ds list. @return True if a ds allows fallback, False otherwise. Fr*r@s r-rz'DataSource.check_if_fallback_is_allowedsr/c~|t}|t}|D]'}|||vr|cStjd|||cS|S)Nz%invalid dsmode '%s', using default=%s)DSMODE_NETWORK VALID_DSMODESrr) candidatesdefaultvalid candidates r-_determine_dsmodezDataSource._determine_dsmodes_ ?$G =!E# I E!   ;Y r/cyr=r*r@s r-network_configzDataSource.network_configrr/cy)a(setup(is_new_instance) This is called before user-data and vendor-data have been processed. Unless the datasource has set mode to 'local', then networking per 'fallback' or per 'network_config' will have been written and brought up the OS at this point. Nr*)rAis_new_instances r-setupzDataSource.setups r/cy)aactivate(cfg, is_new_instance) This is called before the init_modules will be called but after the user-data and vendor-data have been fully processed. The cfg is fully up to date config, it contains a merged view of system config, datasource config, user config, vendor config. It should be used rather than the sys_cfg passed to __init__. is_new_instance is a boolean indicating if this is a new instance. Nr*)rAcfgrs r-activatezDataSource.activates r/cy)z Called when the user issues 'cloud-init clean -c datasource' command. Individual data sources should implement their own cleanup handler. Nr*r@s r-cleanzDataSource.clean s r/r=)r*T)F)FFF)NN)drDrErFrdsmoderyrrr rMrrrrr rr5rHrLrJrIrr r5r8r:r<rr"rBOOT_NEW_INSTANCEBOOT BOOT_LEGACYHOTPLUGrdefault_update_eventsrrrrrrrrr_ci_pkl_versionrrrrrrBrrrrrrrtimedrrrr=rCrFrIpropertyrrrLrrRrrAr@rErHrbrrgrtrwrzrrrrrrrrrr staticmethodrrrrrr*r/r-r#r#ss F"NF"&K#%N L48xdCi 018 $$%%&& ?E"5s":;LKK@   ' ' NN  ! !        ' '    R ! 9%c3h 45 L 0U38_ " 2%A>/3hsm2O##u#4#?#?#?J)4D, $ L&&[)H=$>$Tl 4 :Jx  ##  ! !   .!#$ G  KK++1 F8PE  tI  $"&y/$ $L*  r/) metaclasscr|sgSt|tr|jSt|ttfr t|St|t rag}|j D]J\}}t|tr|g}t|ttfs0|D]}|s|j|L|SgSr=)rhrM splitlineslistrrkrerg) pubkey_datakeys_keynameklistpkeys r-rdrds  +s#%%''+c{+K  +&*002 *OHe%%%$-!*D D) * * Ir/r;c t|||}|Dcgc]}tj|} }t|vrdnd} tj d| | t | |D]\} } tjd| jddzd| d| d | d | | } | 5tj d | | |||}|jtjgr/d | d| | _ |tj| fcdddcS dddddj#| z}t%|cc}w#1swY/xYw#t$rtj td| YwxYw)Nnetworkrz#Searching for %s data source in: %sz search-%sr#r`zsearching for z data from zno z data found from )name descriptionmessageparentz%Seeing if we can get any data from %szfound zGetting data from %s failedz4Did not find any data source, searched classes: (%s)r) list_sourcesrr DEP_NETWORKrrziprReportEventStackrjrrrrr;rr7rrY)rrrds_depscfg_listpkg_listreporterds_listr]ds_namesrrclsmyrepsmsgs r- find_sourcer0sz8Wh7G0781 ##A&8H8#w.9GDII3T8D7+A c''t||L"==;?F26=   A 9 A3G/11001@DT$JEMz22378 9 9 9A& A499D C &c **59 9 9 A KK:C @ As6D:E  A$D? E E ?E E  $E32E3cbg}tjd||||D]}tj|}tj||dg\}}|stj d||D]@}tj |} t| d} | |} | s/|j| |S)zReturn a list of classes that have the same depends as 'depends' iterate through cfg_list, loading "DataSource*" modules and calling their "get_datasource_list". Return an ordered list of classes that match (if any) zLLooking for data source in: %s, via packages %s that matches dependencies %sget_datasource_listzDCould not import %s. Does the DataSource exist and is it importable?) rrr"match_case_insensitive_module_name find_moduleerror import_modulegetattrrm) rdependsrsrc_listr7ds_namem_locs _looked_locsm_locmodlistermatchess r-rrQs HII 8 ==bA'33 X 56   II$   E((/CS"78FWoG(  $ Or/fieldcz|sytj|}|sy|j|jk(Sr)r read_dmi_datarf)rr dmi_values r-instance_id_matches_system_uuidrus; !!%(I     )//"3 33r/c|st}|st}|tk(r |tk7r|S|StjD](\}}|\}}|j|s||s&|cS|tk7r|S|S)z@Lookup the canonical cloud-id for a given cloud_name and region.)rOCLOUD_ID_REGION_PREFIX_MAPreri)rrrprefix cloud_id_testr valid_clouds r-rrs % ! !! ) ) !;!A!A!C "/;   V $Z)@O%% Or/c|syt|tr|St|trtj|St|t r+|durt |jddStdtdt|z)aLdata: a loaded object (strings, arrays, dicts). return something suitable for cloudinit vendordata_raw. if data is: None: return None string: return string list: return data the list is then processed in UserDataProcessor dict: return convert_vendordata(data.get('cloud-init')) NTz cloud-initF)recursez'vendordata['cloud-init'] cannot be dictz$Unknown data type for vendordata: %s) rhrMrrcrdrkconvert_vendordatarzr6rS)datars r-rrsz $ $}}T""$ d?%dhh|&  C;UCs 2A$AA$BBcdd} tj|}|sy tj|S#t$r@}tjj |rt jd||Yd}~]d}~wwxYw#t$rYyt$rtjt d|YywxYw)zBUse pickle to deserialize a instance Datasource from a cache file.Nzfailed loading pickle in %s: %sz#Failed loading pickled blob from %s) rload_binary_filer;rrisfilerrrrrVr7)r pickle_contentsrs r-pkl_loadrsOE//6 ||O,, E 77>>% KK95! DE +  C>Fs+2A> A;6A66A;> B/ #B/.B/c<ttjS)zCheck if command line argument for this datasource was passed Passing by command line overrides runtime datasource detection )parse_cmdline_or_dmir get_cmdliner*r/r-rrs  0 0 2 33r/inputcvtjd|}tjd|}tjd|}|xs|xs|}|xs|}|rA|jdj}t j d|d|dd|d  |r"|jdr|jdSy ) Nz(?:^|\s)ds=([^\s;]+)z(?:^|\s)ci\.ds=([^\s;]+)z (?:^|\s)ci\.datasource=([^\s;]+)rz8Defining the datasource on the command line using ci.ds=z or ci.datasource=z23.2zUse ds=z instead) deprecateddeprecated_version extra_messager`)researchgroupstripr deprecate)r ds_parse_0 ds_parse_1 ds_parse_2r7rrs r-rrs2E:J6>J>FJ  /z /ZB)zJ!!!$**,!!!'* &#F884  bhhqkxx{ r/)r`r*)z system-uuidr)Yabcrcrloggingrrrenumrrtypingrrrrr r r r cloudinitr rrrrrrrrcloudinit.atomic_helperrcloudinit.distrosrcloudinit.eventrrcloudinit.filtersrcloudinit.helpersrcloudinit.persistencercloudinit.reportingrDSMODE_DISABLED DSMODE_LOCALr DSMODE_PASSrDEP_FILESYSTEMr DS_PREFIXrREDACT_SENSITIVE_VALUErQrrO getLoggerrDrrr5rOr;rVrYr]rlrrrrABCMetar#rdrMrrrrrrIOErrorrrrrrrr*r/r-r;s  LLL   /$1*#6&   ,?   < 6'g! - ./03 4 $   tPiP ) CyC F2H:  :I %I X:+ :s?+B!J, 4 4  4&J0 W :cd$CHZ0*4s4r/