/usr/lib/python3/dist-packages/cloudinit/cmd/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/cmd/__pycache__/main.cpython-310.pyc (29702B)
o
Mi' @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
Z
m Z d dl m
Z
mZ d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ d d l mZ d d
l mZ d d l mZ d d l mZ d d
l mZ d dl mZ d dl mZ d dl mZ d dl m Z m Z d dl m Z d dl!m"Z" d dl#m$Z$ d dl%m&Z& d dl'm(Z( d dl)m*Z* d dl+m,Z,m-Z-m.Z.m/Z/ e0Z1dZ2dZ3e,e-e.dZ4d d d d d Z5e6e7Z8G d!d" d"e j9Z:d^d$d%Z;d_d&d'Z
d*e8j?fd+e
e0gdf fd,d-Z@d.d/ ZAd0e$fd1d2ZBd3d4 ZCd`d6d7ZDdad9e eEe0f fd:d;ZFdd? ZHd@ee e0eIf d9e eJe1f fdAdBZKdCeejL d9e eJe1f fdDdEZMdFdG ZNdHdI ZOdJdK ZPdLdM ZQdNdO ZRdPejSfdQdRZTdSdT ZUdUdV ZVd_dWdXZWdYdZ ZXd[d\ ZYe7d]kreZeWej[ dS dS )b N)OptionalTupleCallableUnion)featuresnetinfo)signal_handler)sources)socket)stages)
url_helper)util) performance)version)warnings) reporting)
atomic_helper) lifecycle)handlers)log_utilloggers)read_cfg_paths)cc_set_hostname)Modules)validate_cloudconfig_schema)log_with_downgradable_level)events) PER_INSTANCE
PER_ALWAYSPER_ONCE CLOUD_CONFIGzOCloud-init v. {version} running '{action}' at {timestamp}. Up {uptime} seconds.zcloud_%s_modules)instancealwaysoncez Local Stagez
Network Stagez Config Stagez Final Stage)
init-localinitmodules-config
modules-finalc s2 e Zd Z fddZd fdd Zdd Z ZS ) SubcommandAwareArgumentParserc s t j|i | d | _d S N)super__init__ _raw_args)selfargskwargs __class__ 4/usr/lib/python3/dist-packages/cloudinit/cmd/main.pyr+ S s
z&SubcommandAwareArgumentParser.__init__Nc s || _ t ||S )z>Override parse_args to store raw arguments for error handling.)r, r*
parse_args)r- r. namespacer0 r2 r3 r4 W s z(SubcommandAwareArgumentParser.parse_argsc C s t d| dtjd | jstjdd | _d}| jr.| jD ]}|| jjd jv r-|} nq |rA| jjd j| }|jtjd n| jtjd t d dS )z=Override error method to show subcommand usage if applicable.zerror:
file Nr )
printsysstderrr, argv _subparsers_group_actionschoices
print_helpexit)r- message
subcommandarg subparserr2 r2 r3 error\ s"
z#SubcommandAwareArgumentParser.error)NN)__name__
__module__ __qualname__r+ r4 rH
__classcell__r2 r2 r0 r3 r( R s r( c C sV | r
t jd| t jd t jd tjt jd t jd t jd d S )N%s
z<------------------------------------------------------------r6 r7 )r< r= write traceback print_excmsgr2 r2 r3 rQ x s rQ c C s& |st | }tjd| ddtd |S )NrN FT)consoler= log)welcome_formatr multi_logLOG)actionrS r2 r2 r3 welcome s rZ c C s t jt t t | dS )N)r uptime timestamprY )WELCOME_MSG_TPLformatr version_stringr
r[ time_rfc2822rY r2 r2 r3 rV s rV
Closing stdinloggerc C sj t tj s/| d tt j}t | tj W d dS 1 s(w Y dS | d dS )zj
reopen stdin as /dev/null to ensure no side effects
logger: a function for logging messages
rb Nz"Not closing stdin, stdin is a tty.)osisattyr< stdinfilenoopendevnulldup2)rc fpr2 r2 r3 close_stdin s " rl c C sT g }| j r| j D ] }|tj|j q| jr(| jD ] }|tj|j q|S r) )
main_filesappendrd pathrealpathnamefiles)r. fn_cfgsfhr2 r2 r3 extract_fns s
ru modsc C sr t | }| |\}}t|t| }|dkr,d||f }tjd| t| g S tdt|t| |S )Nr z)No '%s' modules to run under section '%s'rN z Ran %s modules with %s failures)MOD_SECTION_TPL run_sectionlenr< r= rO rX debug)rv action_namesectionfull_section_name which_ranfailurestotal_attemptedrS r2 r2 r3 run_module_section s
r c C s" | drt| d d S d S )Nr )getr update_configuration)cfgr2 r2 r3 apply_reporting_cfg s
r cloud-config-urlurlc C s< t | }|D ]}||v r||| f S qtd| |f )Nz!No keys (%s) found in string '%s')r
keyval_str_to_dictKeyError)cmdlinenamesdatakeyr2 r2 r3 parse_cmdline_url s
r Treturnc
C s" |du rt }zt|\}}W n ty tjdf Y S w |d}|rMtj | rM|r@d| |f }tj
}|r|d t d | | t j(krd g f Y S d d gf Y S t d | Y nw t?| |@ }t d | | ||A | t j(krtB|d!d"d# |j>|d | t j(krt*j+rtC|j:\}}|rt d$| nt d%| tD|j&-dd& |j:j;| krt d'| |j: |j:g fS t d(| |j: |E |F tB|d)d*d# z|G jHd+|jItJgtJd,\}}|s-|ItK W n tyD ttd- |j:d-gf Y S w |j&6d.}tj,|rjtL|jMd/krjtNtOPtQ|ddd0d1 nt d2 t |j tR|t||j d3}z)|}|}t|j| \}}||ks||krtSd4|| t|j| \}}W n ty ttd5 Y nw t |j |T tU|j:|jd6 |j:tV|| | fS )7Nz%s.dz91_kernel_cmdline_url.cfg)ro r r$ r% ds_depsreporterc s tj| fS r) )rn r r rR
early_logsr2 r3 s zmain_init..#Failed to setup output redirection!@Logging being reset, this logger may no longer be active shortlyrR !PID [%s] started cloud-init '%s'.z0Failed to initialize, likely bad things to come!z
.skip-networkz4Will wait for network connectivity before continuingtrustrN checkmanual_cache_cleanFz"manual cache clean set from configmanual_clean_markerz(manual cache clean found from marker: %sexistingz)[%s] Exiting. datasource %s in local modezNo local datasource foundz8No instance datasource found! Likely bad things to come!)bring_upz [%s] Exiting without datasourcez No instance datasource found.z2[%s] barreling on in force mode without datasourcez5[%s] %s will now be targeting instance id: %s. new=%sr r )stage retry_stagezTNetwork connectivity determined necessary for cloud-init's network stage. Reason: %szVNetwork connectivity determined unnecessary for cloud-init's network stage. Reason: %srM z.[%s] Exiting. datasource %s not in local mode.z6[%s] %s is in local mode, will apply init modules now.zinit-netzmodules:config consume_data)r. freqzConsuming user data failed! cloud_configr T)configstrict log_detailslog_deprecationsz2Skipping user-data validation. No user-data found.r z#Stdout, stderr changing to (%s, %s)z'Failed to re-adjust output redirection!)r r )Wr DEP_FILESYSTEM DEP_NETWORKr r rd ro r r rV r Initr read_cfgru skip_log_setuprl r
fixup_outputr get_output_cfgr logexcrX rQ rn r r rz r
reset_logging
setup_loggingr rZ r getppidrU
initializer r DSMODE_LOCALDSMODE_NETWORKr MANUAL_NETWORK_WAITr get_runpathdistrowait_for_networkr< r= rO r
debug_infor r r r fetchr dsmodeDataSourceNotFoundExceptionforceapply_network_config _maybe_persist_instance_data
instancifyis_new_instance_maybe_set_hostnamer r setup_datasourceupdatecloudifyrunr r r statst_sizer r r r r warningactivate_datasourcedi_report_warnr )rq r. depsbootstage_namew_msgr% outfmterrfmtrS lvl path_helperr r mcfgmfilebring_up_interfacesiid should_waitreasonran_resultscloud_cfg_pathrv outfmt_orig errfmt_origr2 r r3 main_init sZ
rC c C s d|vr t d d S |d }|d u rt d d S t|ts't d| d S |d}|d u r7t d d S t|tsDt d| d S | jdd }| t
j r\|t t
j d }nt d
| | ||v rqt d | || d S t
jd ||t|d
d S )N di_reportz no di_report found in config.zdi_report was None.z%di_report config not a dictionary: %sdatasource_listz(no 'datasource_list' found in di_report.z(di_report/datasource_list not a list: %s.r: z1Datasource '%s' came from unexpected module '%s'.z:used datasource '%s' from '%s' was in di_report's list: %sdsid_missing_source)r dslist)rX rz r r r. r listrJ
rpartitionr r DS_PREFIXry r show_warningr )r r dicfgrH modnamer2 r2 r3 r0 sH
r0 c C sZ |j }d| |f }t|}tjg |jd}|t| z|jdd W n tj yD d| }t
t | t
| |jsB|g Y S Y nw t| t|t||jd}z|jsat t
|j| W n tyq t
t d Y nw |jr~t d t |jst|j t|j t||d t d
t | |d krt j d d
dd t!|||S )Nz%s:%sr r r zGCan not apply stage %s, no datasource found! Likely bad things to come!r r r rR r r% z
`--mode init`24.1 Use `cloud-init init` instead.)r r r )"r rV r r r r ru r r r! r
r rX rQ r" r$ r r rl r r r rz r r r r rZ r rd r r r r )r{ r. rq r2 r3 r% rS rv r2 r2 r3 main_modules sZ
rQ c
C st |j }t| }tjg |jd}|t| z|jdd W n tj y8 t
t d t
d |js6Y dS Y nw t| t|t||jd}|j}|rRt d| |j}|rbt d| t|}z t t
|jd W n ty} t
t d Y nw |jrt d
t t |j t |j t | |d | |||\}} | rt d | dS |st d
| dS dS )Nr r r z;Failed to fetch your datasource, likely bad things to come!r9 r z Using passed in arguments %sz Using passed in frequency %sr r rR zRan %s but it failed!z Did not run %s, does it exist?r )!rq rV r r r r ru r r r! r
r rX rQ r" r$ r module_argsrz frequencyFREQ_SHORT_NAMESr rl r r r r r r r rZ
run_singler. )
rq r. mod_namer3 r% rv mod_argsmod_freqr~ r r2 r2 r3 main_single/ s`
rY c C s t }|d}tj|j}tj|d}tj|d}tj|d}tj|d}t } t
||f |j \}
} | dkrH|j rEd} nd} n| dkrRd|j
} ntd| | tvrctd | g i d d d
}
d d |
|
|
|
d i}| dkr||||fD ]}t | qnz
tt |}W n ty Y nw | |d vr|
|d | < |d }| |d
< || d r|| d stdt| tt || d< tt dd | j }| }t || t j!tj"|||dd zz,| | |}| dv r|\}}|d urt#||d< n|}|| d $dd |D W n\ tyO } z t%d| t&d| || d 't#| W Y d }~n7d }~w t(y } z&|j)rwt%d| t&d| || d 'd t#|j) d W Y d }~nd }~ww W tt || d< d |d
< | }|* |+ D ]&}||v rt,t-|| || || d |< q|| || d |< qt || nHtt || d< d |d
< | }|* |+ D ]&}||v r t,t-|| || || d |< q|| || d |< qt || w | d krWg }|+ D ] }t.|| t/r;|| 0dr;|$|| 0dg q t |d |d |d i t j!tj"|||dd t1|| d S )!Nr z status.jsonz result.jsonr% r$ modules
modules-%szunknown name: %sz'Invalid cloud init mode specified '{0}')errorsrecoverable_errorsstartfinishedv1)r r% r$ r& r' r r^ r_ z=Unexpected start time found for %s. Was this stage restarted?c S s t | tjS r) )r r LogExporter)hr2 r2 r3 r s z status_wrapper..T)r" )r% r$ r r\ c S s g | ]}t |qS r2 )r ).0r r2 r2 r3
s z"status_wrapper..zfailed stage %szfailed run of stage %sz sys.exit(z) calledr] r' )r r\ )2r r rd ro normpathrun_dirr r getLoggerr
ensure_dirsrY r r
ValueError
STAGE_NAMEr^ copydel_filejsonloadsr r rX r. floatr[ r filterr export_logsr
write_jsonsym_linkrelpathr extend exceptionrQ rn
SystemExitr
clean_logskeysrI setr r r ry )rq r. r data_dlink_d status_path status_link result_path result_link root_logger_namefunctorr
nullstatusstatusfr` handler preexisting_recoverable_errorsretr r\ r new_recoverable_errorsr r r2 r2 r3 status_wrapperu s
"
r r% c C sB | j r| jr | jd}tj|s | j jdd dS dS dS dS )zCWrite instance-data.json file if absent and datasource is restored.
instance_dataF) write_cacheN)r ds_restoredr r rd ro r persist_instance_data)r% instance_data_filer2 r2 r3 r$ s r$ c
C s~ | }tj| j|dd\}}}|r=z td| j|d W dS tjy< } ztd||t | W Y d}~dS d}~ww dS )zCall set_hostname if metadata, vendordata or userdata provides it.
@param stage: String representing current stage in which we are running.
@param retry_stage: String represented logs upon error setting hostname.
T)
metadata_only set_hostnameNzGFailed setting hostname in %s stage. Will retry in %s stage. Error: %s.)
r* r
get_hostname_fqdnr r handleSetHostnameErrorrX rz r )r% r r cloudhostname_fqdn_r r2 r2 r3 r' s" r' c C s t jdttjd d S )Nr6 )r< stdoutrO r sortedr FEATURES)rq r. r2 r2 r3
main_features/ s r c C s t | s tj} t| dd}|jddddt dd |jd d
d d d
d |jdddddt
dd |jdd ddd
d |jddd d d
d |j d d |j d d d!}|j
d"d#d$}|jd%d&d d'd
d |jdddd(d)t
dd |j d"tfd* |j
d+d,d$}tjd-d.d/d0d1j}|jd2d3d4d5| d6d7d8 |jdddd(d)t
dd |j d+tfd* |j
d9d:d$}|jd;d |jd?d4d@d
tt dA |jdBd dCd
d> |jdDdEdFdGdH |jdddd(d)t
dd |j d9tfd* |j
dIdJd$}|j
dKdLd$}|j dKtfd* |j
dMdNd$} |j
dOdPd$}
|j
dQdRd$} |j
dSdTd$} |j
dUdVd$}
|j
dWdXd$}| rtdYdZ | D d }|dMkrXdd[lm} || n|dOkrhdd[lm} ||
n|dQkrdd\l m}m } || d] | j dQ|fd* nm|dSkrdd^l m}m } || | j dS|fd* nS|dIkrdd_l m}m!} || |j d`|fd* n9|dWkrddal"m}m#} || |j dW|fd* n |dUkrddbl$m}m%} ||
|
j dU|fd* n|&dc |j'| dd} t(| ded
| j)st*| |S t)|S )fNr )progz --versionz-vr z %(prog)s z'Show program's version number and exit.)rY r helpz--debugz-d
store_truez:Show additional pre-action logging (default: %(default)s).F)rY r defaultz--filez-frn rm zPUse additional yaml configuration files for subcommands: init, modules or singlerb)rY destr typez--forcezDForce running even if no datasource is found (use at your own risk).r" )rY r r r z --all-stages
all_stageszsRun cloud-init's stages under a single process using a syncronization protocol. This is not intended for CLI usage.)r rY r r r SubcommandsrE )titler r% z2Initialize cloud-init and perform initial modules.)r --localz-lz+Start in local mode (default: %(default)s).rr z(Use additional yaml configuration files.ra rZ z1Activate modules using a given configuration key.z`init`rO rP Tr z--modez-mstorez9Module configuration name to use (default: %(default)s). r )r% r final)rY r r rA singlezRun a single module.z--namez-nzModule name to run.)rY r requiredz --frequencyz Module frequency for this run.)rY r r rA z--reportzEnable reporting.rR *argumentz0Any additional arguments to pass to this module.)nargsmetavarr queryz;Query standardized instance metadata from the command line.r zList defined features.analyzez-Devel tool: Analyze cloud-init logs and data.develzRun development tools.z collect-logsz*Collect and tar all cloud-init debug info.cleanz3Remove logs and artifacts so cloud-init can re-run.r z/Report cloud-init status or wait on completion.schemaz-Validate cloud-config files using jsonschema.c s s | ]
}| d s|V qdS )-N)r )rc posargr2 r2 r3 s zmain..)
get_parser)r handle_collect_logs_args)parser)r handle_clean_args)r handle_argsrender)r handle_schema_args)r handle_status_argsza subcommand is requiredr. r )+r configure_root_loggerr< r> r( pop add_argumentr r_ argparseFileType set_defaultsadd_subparsers
add_parserrC r r rD rQ rI rT ry rY r r cloudinit.analyzer cloudinit.cmd.devel.parsercloudinit.cmd.devel.logsr cloudinit.cmd.cleanr cloudinit.cmd.queryr cloudinit.config.schemar cloudinit.cmd.statusr rH r4 setattrr sub_main) sysv_argsr
subparsers parser_init
parser_mod
extra_help
parser_single parser_queryparser_featuresparser_analyze parser_develparser_collect_logs parser_clean
parser_status
parser_schemarE analyze_parser devel_parser logs_parserr clean_parserr query_parserhandle_query_args
schema_parserr
status_parserr r. r2 r2 r3 main3 s
r c C s t d tdddd}td |d | jddgd }d
|_t|| |_W d n1 s2w Y |d | jdgd }d |_t|| |_W d n1 sVw Y |d | jd
dgd }d |_t|| |_W d n1 s{w Y |d | jd
dgd }d |_t|| |_W d n1 sw Y |j rd}|j
rd|j
}td| d td dS td td d S )z>Run all stages in a single process using an ordering protocol.z*Running cloud-init in single process mode.r r r r zREADY=1r% r r FNTrZ z
--mode=configz --mode=finalz%a stage of cloud-init exited non-zerozfirst exception received: z STATUS=Completed with failure, z2. Run 'cloud-init status --long' for more details.z
STOPPING=1r9 zSTATUS=Completed) rX r r
SocketSync sd_notifyr4 r r systemd_exit_codeexperienced_any_errorfirst_exception)r syncr. rD r2 r2 r3 r 0 sD
r c C s z| j \}}W n ty | tjd td Y nw |dvr1t| j r,t
j nt
j n| j r8t t
d|ksId|krKd| jkrKt}d }d}|dkr`| jr[d\}}n0d\}}n+|dkrpd | j d
| j }}n|d krd | j d
| j }}| j}n|}d| }d}tj|||d| _| j& td| d
||| }W d n1 sw Y W d n1 sw Y t d|krd| jkrt|}|S )NzO
No Subcommand specified. Please specify a subcommand in addition to the optionr9 )r% rZ r% rZ T)r$ z searching for local datasources)z init-networkz!searching for network datasourcesr[ zrunning modules for %sr z single/%szrunning single module %szrunning 'cloud-init %s'F)reporting_enabledzcloud-init stage: '') rY AttributeError print_usager< r= rO rC r setup_basic_loggingrz r r r r attach_handlersr r r rq reportr ReportEventStackr r Timedr flush_eventsry )r. r rq r rname report_onrdescretvalr2 r2 r3 r k sb
r __main__)rM r) )r )TN)\r rm rd r< rP r r typingr r r r cloudinitr r r r r
r r r
r r r r r r r
cloudinit.logr r cloudinit.cmd.develr cloudinit.configr cloudinit.config.modulesr r r cloudinit.lifecycler cloudinit.reportingr cloudinit.settingsr r r r r Reasonr] rw rT rj rg rI rX ArgumentParserr( rQ rZ rV timedrz rl ru r r r intr r r bytesboolr
DataSourcer rC r0 rQ rY r r r$ r' r r r r rC r> r2 r2 r2 r3 s
&
m
;
% y2AF
~;
N