x[h. %SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJs J r SSK J r SSK Jr SSKJrJrJr SSKJrJrJrJr SSKrSSKJrJrJrJrJrJr SSKJ r J!r! SSK"J#r# SS K$J%r%J&r&J'r' SS K(J)r)J*r* SS K+J,r, SS K-J.r.J/r/J0r0J1r1 SS K2J3r3 SSK4J5r5J6r6J7r7J8r8J9r9J:r:J;r;Jr>J?r?J@r@JArA SSKBJCrC SSKDrD\R"\DRS\R"SS93S9rG\\HS'\R"\P5rQSrRSS0rSSrTSrUSrVSrW"SS\ 5rXSrY\\Z\HS '/S!Qr[S"r\S#r]S$\ZS%\ZS&\\Z4S'jr^S(\ZS&\Z4S)jr_\9S&\\Z4S*j5r`\9S(\ZS&\\Z4S+j5raS_S&\Z4S,jjrbS-rcS.rdS/reS&\\Z4S0jrf\R"5(a7S1rU\f"S25rh\hb\QRS35 S4\h-rTO\QRS55 SrY\VS6\T0S7S7S8.rjS6S9S:/S7S;.0\US.rkS?\R/rlS@rmSArn"SBSC\R5rpSDrqSErrSFrsSGrtSHruS`SIjrv\9SJ5rw\9SK5rx\9\TSLSL4SM\ZSN\ZSO\ySP\y4SQjj5rz\9S_SRj5r{\9SS5r|STr}\9SU5r~\9\Y4SVj5r\9SW5r\9SX5r\9SY\SZ\yS&\4S[j5r\9S&\4S\j5r\9S_S]j5r\pr\p\GR44/rS^rg!\I\J4a: SSKKrL\LRRRrGGN!\Ia SrGGNf=ff=f)aN)Enum)Path) monotonicsleeptime)AnyDictListOptional)net performancesourcesssh_utilsubputil) EventScope EventType) device_driver)NoDHCPLeaseErrorNoDHCPLeaseInterfaceErrorNoDHCPLeaseMissingDhclientError)EphemeralDHCPv4EphemeralIPv4Network)events)errorsidentityimdskvp)netlink) DEFAULT_WIRESERVER_ENDPOINTNonAzureDataSource OvfEnvXmlazure_ds_reporterazure_ds_telemetry_reporterbuild_minimal_ovf dhcp_log_cbget_boot_telemetryget_metadata_from_fabricget_system_inforeport_diagnostic_eventreport_dmesg_to_kvpreport_failure_to_fabric)UrlErrorz$6$)strlen)salt blowfish_hashc[S5e)zRaise when called so that importing this module doesn't throw ImportError when ds_detect() returns false. In this case, crypt and passlib are not needed. z/crypt and passlib not found, missing dependency) ImportError)_s C/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceAzure.pyr1r1@s A Azure instance-idziid-AZURE-NODEz/dev/disk/cloud/azure_resourceext4z/var/lib/waagentz/dev/sr0c(\rSrSrSrSrSrSrSrSr g) PPSTypeWNonePreprovisionedOSDiskRunningSavableUnknownN) __name__ __module__ __qualname____firstlineno__NONEOS_DISKRUNNINGSAVABLEUNKNOWN__static_attributes__rBr6r5r;r;Ws D$GGGGr6r;z/sys/firmware/acpi/tables/OEM0PLATFORM_ENTROPY_SOURCE)z"/etc/netplan/90-hotplug-azure.yamlz /usr/local/sbin/ephemeral_eth.shz+/etc/udev/rules.d/10-net-device-added.rulesz#/run/network/interfaces.ephemeral.dcxUR5Hn[R"SU5(dM!UR5n[ U5S:dMBUSRS5n[ U5S:dMgUSS:XdMrUSR U5(dMUSRS5nUSs $ g ) z| dev.storvsc.1.%pnpinfo: classid=32412632-86cb-44a2-9b5c-50d1417354f5 deviceid=00000000-0001-8899-0000-000000000000 pnpinfo=rdeviceid.N) splitlinesresearchsplitlen startswith) sysctl_outrSlinefieldscolumnscompss r5"find_storvscid_from_sysctl_pnpinforaks%%' 99Z & &ZZ\F6{a )//#.LA% j0 --h77"1IOOC0E 8O( r6cUR5H5n[R"X5(dM UR5nUSs $ g)z scbus0 on ata0 bus 0 scbus1 on ata1 bus 0 scbus2 on blkvsc0 bus 0 scbus3 on blkvsc1 bus 0 scbus4 on storvsc2 bus 0 scbus5 on storvsc3 bus 0 scbus-1 on xpt0 bus 0 rN)rVrWrXrY)camcontrol_outdisk_drvr]itemss r5find_busdev_from_diskrfs?))+ 99X $ $JJLE8O, r6rcbusdevreturncUR5H[n[R"X5(dM URS5n[ U5S:XdMBUSRS5nUSs $ g)z at scbus1 target 0 lun 0 (cd0,pass0) at scbus2 target 0 lun 0 (da0,pass1) at scbus3 target 1 lun 0 (da1,pass2) (rQrT,rN)rVrWrXrYrZ)rcrgr]redev_passs r5find_dev_from_busdevrms_))+ 99V " "JJsOE5zQ 8>>#.{" , r6macc [U5S:Xa)SRUSSUSSUSSUSSUSSUSS/5nUR5$) z1Normalize mac address with colons and lower-case. :rrQ )rZjoinlower)rns r5normalize_mac_addressrxs] 3x2~hh 1Xs1QxQq3q8S2YBr K  99;r6c[R"5Vs/sHnUSS:XdM[US5PM sn$s snf)z-Get Hyper-V NICs as normalized MAC addresses.rQ hv_netvscrT)r get_interfacesrx)ns r5get_hv_netvsc_macs_normalizedr}sJ ##% %A Q4;  $ad#%  s >>c<[R"5Vs/sHnU[US5:XdMUSPM nnSU;ag[U5S:Xa%[ SU<SU<3[ R S9 US$[ SU<SU<3[ RS9 g s snf) z0Determine the device driver to match on, if any.rTrQrzz'Assuming driver for interface with mac=z drivers= logger_funcrz0Unable to specify driver for interface with mac=N)r r{rxrZr*LOGdebugwarning)rnidriverss r5determine_device_driver_for_macrs ##%%A '!- - !%  g 7|qG   qz  KK +s B Bc[R"U5R$![Ra* [R SSR U55 Us$f=f)NzFailed to execute: %s )rstdoutProcessExecutionErrorrrrv)cmdfail_rets r5execute_or_debugrsLyy~$$$  % % )388C=9s";A A c[SS/SS9$)Nsysctlz dev.storvsc)rrrBr6r5get_dev_storvsc_sysctlrs X}5 CCr6c[/SQ5$)N) camcontroldevlistz-brrBr6r5get_camcontrol_dev_busrs ; < ? II- .!!),G "#3 =F &~> ? II- . r6z freebsd-ufsrTzresource disk is not None/dev/zresource disk is None ephemeral0T)data_dir disk_aliasesapply_network_config&apply_network_config_for_secondary_ipsgptd) table_typelayout overwritez ephemeral0.1) filesystemdevice) disk_setupfs_setup datasourcenever_destroy_ntfsREDACTEDc X^\rSrSrSr\R \R\R10r Sr \ RrSrSrS\SS4U4S jjrS rS r\S \S\4S j5r\SSSSS.S\\S\S\S\S\4 Sjj5r\SLSj5rS\4SjrSLSjr\S5r\S\S\ 4Sj5r!SMU4Sjjr"\S5r#\S5r$Sr%S r&\S\'\4S!j5r(S"\)S\'\4S#jr*S\'\4S$jr+S%r,S&r-SNS'jr.\S(5r/\SOS)\S*\S\04S+jj5r1\S,5r2\SSS-.S.\S/\SS4S0jj5r3\S15r4\S\5Rj4S2j5r6\S35r7\SLS4j5r8\S55r9\S65r:\S\;4S7j5r<\SPS8\=R|S9\S\4S:jj5r?\SS;.S<\\'\S\\'\4S=jj5r@S"\)S\\4S>jrAS?\)S"\)S\B4S@jrC\SA5rD\SB\)S"\)S\\'\4SCj5rESDrF\SE5rG\HSF5rI\SG5rJ\HSH5rK\HSI5rL\S"\)S\4SJj5rMSKrNU=rO$)QDataSourceAzurei8r7FrTc[RRXX#5 [RR UR S5Ul0UlSUl[R"[R"U[05[/5UlSUlSUlSUlSUlSUl[(Ul[RR UR,SS5Ulg)NazureFdatareported_ready)r DataSource__init__ospathrvseed_dircfgseedr mergemanydictget_cfg_by_path DS_CFG_PATHBUILTIN_DS_CONFIGds_cfg_iso_dev_network_config_ephemeral_dhcp_ctx_route_configured_for_imds _route_configured_for_wireserverr _wireserver_endpoint cloud_dir_reported_ready_marker_file)selfsys_cfgdistropathss r5rDataSourceAzure.__init__Ds##D6A U^^W=  ((  ! !'; ;=N O   #>B */'05-$?!+-77<< OOV%5, (r6ci_pkl_versionrhNc>[TU]U5 SUlSUlSUlSUl[ Ul[RRURRSS5Ul g)NFrr)super _unpicklerrrrr rrrrvrrr)rr __class__s r5rDataSourceAzure._unpickleVs^ .)#'  */'05-$?!+-77<< JJ &*:, (r6ch[RRU5nU<SUR<S3$)Nz [seed=])rr__str__r)rroots r5rDataSourceAzure.__str__bs'!!))$/!%tyy11r6cURcSnOFURRS5(aSnO#URR5S:XaSnOSnU<SUR<S3$)z/Return the subplatform metadata source details.unknownz/devz config-diskrzseed-dir ())rr[rw)rsubplatform_types r5_get_subplatform DataSourceAzure._get_subplatformfs[ 99 (  YY ! !& ) ),  YY__ & (% ) ,dii88r6ephipv4c UR(dgURVs/sHo"SRS5SPM nnSU;UlURU;UlUR=(d UR$s snf)NFr/z169.254.169.254) static_routesrYrrr)rrrrouted_networkss r5_check_if_primary!DataSourceAzure._check_if_primaryrs$$7>7L7LM7L!Q4::c?1-7LM+<*N'  % % 8 -  + + 544 Ns BT)ifacereport_failure_if_not_primary retry_sleeptimeout_minutesrrrrcURb [S5e[SU<S[R"5<3[ R S9 [URU[S9UlSn[5nXdS--n[R"SS [S 9 UcAURR5nUc[5U-U:a [?U5 OOUcMAUcSUl[-5eUSnXRl SU;a USUl![EU5n URRFn U c [S5eURIU 5n [SU<SU <SU <SU RJ<SU RL<SU<S URN<S!URP<S"3[ R S9 U(aAU (d:UR#[$RR"UU U RJU RLUS#9S S9 U sSSS5 $![aI [S [ R S9 UR#[$R&"[5U- S 9S S9 GN[(a! [S[ R*S9 SUle[,aM [SU-[ R*S9 UR#[$R."[5U- US9S S9 GN#[0a&n[SU-[ R*S9 SnAGNMSnAf[2R4a[n[SUR6<SUR8<SUR:<SUR<<3[ R*S9 SnAGNSnAff=f!,(df  g=f)$aSetup ephemeral networking. Keep retrying DHCP up to specified number of minutes. This does not kill dhclient, so the timeout in practice may be up to timeout_minutes + the system-configured timeout for dhclient. :param timeout_minutes: Number of minutes to keep retrying for. :raises NoDHCPLeaseError: If unable to obtain DHCP lease. :returns: True if NIC is determined to be primary. Nz/Bringing up networking when already configured.z,Bringing up ephemeral networking with iface=: r)r dhcp_log_func<zobtain-dhcp-leasezobtain dhcp leasename descriptionparentzInterface not found for DHCP)durationT host_onlyzdhclient executable not foundz&Failed to obtain DHCP lease (iface=%s))r interfacezFile not found during DHCP %rzCommand failed: cmd= stderr= stdout= exit_code=rz unknown-245zdhcp context missing ephipv4z!Obtained DHCP lease on interface z (primary=z driver=z router=z routes=z lease=z imds_routed=z wireserver_routed=r)rdriverrouterrlease)*r RuntimeErrorr*r r{rrrrr&rrReportEventStackr# obtain_leaserr_report_failurer$ReportableErrorDhcpInterfaceNotFoundrerrorrReportableErrorDhcpLeaseFileNotFoundErrorrrrstderrr exit_coderrrr_ephipv4rr rrr(ReportableErrorDhcpOnNonPrimaryInterface) rrrrrr  start_timedeadlinerr rprimarys r5_setup_ephemeral_networking+DataSourceAzure._setup_ephemeral_networkingsG*  # # /A  c((* ,  $3 KK%$  +/[ " 44  $ $$+$ -1 44AACEf=Y[;%>%I+&q-t}+/(&((+&E-2 $ $ *%,1-,@)"5)F..77G"#ABB,,W5G # NN))3399  II "-W$$CC"'%&~~&-&;&;# #% [  1 +6CKK((CC%.[:%=#' ) 7+7SYY04D,' +@5H$'II((77%.[:%=#' ) )+7%?$'II11 +"II!LL!LL!OO %(II   W  sjM8H 6$M8D#M8 AM5M8A;M5M8 M5"L=M8M5AM0*M80M55M88 Nc~SUlSUlURcgURR5 SUlg)zTeardown ephemeral networking.FN)rrr clean_networkrs r5_teardown_ephemeral_networking.DataSourceAzure._teardown_ephemeral_networkings=+0'05-  # # +    ..0#' r6cfURSL=(d URRSL(+$)z"Check if networking is configured.N)rr rs r5_is_ephemeral_networking_up+DataSourceAzure._is_ephemeral_networking_up*s5  $ $ , 6''--5  r6c t/SQn[R"U5up#[SU<SU<SU<3[RS9 g ![Ran[ UR [5(a@[RS5 [R"5nURU5 S nAg [SUR<SUR<S UR<S UR<3[RS9 [R "U5nURU5 S nAg S nAff=f) aCheck if azure-proxy-agent is ready for communication with WS/IMDS. If ProvisionGuestProxyAgent is true, query azure-proxy-agent status, waiting up to 120 seconds for the proxy to negotiate with Wireserver and configure an eBPF proxy. Once azure-proxy-agent is ready, it will exit with code 0 and cloud-init can then expect to be able to communicate with these services. Fail deployment if azure-proxy-agent is not found or otherwise returns an error. For more information, check out: https://github.com/azure/guestproxyagent )zazure-proxy-agentz--statusz--wait120z Executing z resulted in stderr=z with stdout=rzGFailed to activate Azure Guest Proxy Agent: azure-proxy-agent not foundzDFailed to activate Azure Guest Proxy Agent: status check failed cmd=rrrN)rr*rrr isinstancereasonrrr!ReportableErrorProxyAgentNotFoundrrrrr&ReportableErrorProxyAgentStatusFailure)rrouterrr report_errorreportable_errors r5_check_azure_proxy_agent_status/DataSourceAzure._check_azure_proxy_agent_status1s% 7C yy~HC #14c3@II  )) 7%,,(9:: 2 &GGI $$\22'    !$  AA%H!$$%5661 7s AAD7AD26A7D22D7c 2 0nURSnSnSS0nSSSS000nSn0n[URU5HnURS5(a][R "5(a[R "U[S S 9upFpWO[R "U[5upFpWXlO[U5upFpWUn[S U-[RS 9 O Sn [U [RS 9 [UR5=(d USLn U (aSOSn UR!U S9 0n UR%5(a5UR'S5(aUR)5 UR+SS9n U (d&Uc#Sn [U 5 [,R."U 5eUR1X\5n U [2R4:wGa[R "5(a0Sn [U [R6S 9 [,R."U 5eUR%5(d0Sn [U [R6S 9 [,R."U 5eU [2R8:XaUR;5 OZU [2R<:XaUR?5 O5U [2R@:XaURC5 OURE5 URG5upFpWUR'S5(aUR)5 UR+SS9n URIU 5nUS[2R4RJ4;a$URM[NRP"SUS95 URSU S9 U=(d SUl*URWUU[RX"USU 0/5US.5 [[U 5n[]U 5n[_U 5nU(a [RSU5 XSSS'U(a[RS U5 UUS!S'Ub#[RS"U5 U(+US#S$'URTS:XaUS%(d[aUUUS&9nS'U0US%'U(d^[eU 5nU(aL[RS)5 [fRh"SRkURm555US*'X2:Xa[S,U-[RS 9 [o5nU(aUUS!S-'URq5US!S.'URrS/LakUR%5(aVURuX\S09nURwUS19n[RS2U5 U(aUUS!S3'URy5 U$U$![a [S U-[RS 9 GM[Ra [SU-[RS 9 GMf=f!["a GNf=f![ba&n[S(U-[RS 9 SnAGNSnAff=f![ba [S+[RS 9 GNf=f![ba U$f=f)4zWalk all instance metadata sources returning a dict on success. @return: A dictionary of any metadata content for this instance. @raise: InvalidMetaDataException when the expected metadata service is unavailable, broken or disabled. rNlocal-hostnamer system_info default_userrrudf)mtypez!Found provisioning metadata in %srz$Did not find Azure data source in %sz%s was not mountablezUnable to find provisioning media, falling back to IMDS metadata. Be aware that IMDS metadata does not support admin passwords or custom-data (user-data only).rrProvisionGuestProxyAgentT)report_failurezNo OVF or IMDS availablez%Free BSD is not supported for PPS VMszDHCP failed while in source PPSzextended.compute.ppsType)keyvalue)imds_mdIMDSr)rfilesmetadata userdata_rawz Username retrieved from IMDS: %sz Hostname retrieved from IMDS: %sr@z(Disable password retrieved from IMDS: %sr ssh_pwauthr?)usernamehostname disableSshPwd ovf-env.xmlz)Failed to construct OVF from IMDS data %szRetrieved userdata from IMDSrAzBad userdata in IMDSzusing files cached in %s random_seedr8F)rr= pubkey_infoznegotiating returned %s public-keys)=rlist_possible_azure_dsrr[r is_FreeBSDmount_cbload_azure_ds_dirrr*rrr!MountFailedErrorrboolrrr#getr/get_metadata_from_imdsrInvalidMetaDataException_determine_pps_typer;rGrrI_wait_for_pps_running_reuserJ_wait_for_pps_savable_reuserH_wait_for_pps_os_disk_shutdown_wait_for_pps_unknown_reuse _reprovision_ppstype_from_imdsr<rr"ReportableErrorImdsInvalidMetadatavalidate_imds_network_metadatarupdater_username_from_imds_hostname_from_imds_disable_password_from_imdsr% Exception_userdata_from_imdsbase64 b64decodervrY_get_random_seed_iid _negotiated!_determine_wireserver_pubkey_info _report_ready_cleanup_markers)r crawled_dataddir ovf_sourcemdrrAr?srcmsgrequires_imds_metadatarr=pps_type imds_ppstype imds_username imds_hostnameimds_disable_passwordcontentse imds_userdatarrIssh_keyss r5crawl_metadataDataSourceAzure.crawl_metadatags0 {{:&   #~|<= )$-->C >>'**((7;}}!2%84#u8<}}!284#%(M3DS3I0Bc '7*D # +?FC  $CS[[ A"&dmm!4!J d8J 6"A   , ,_ , M  + + - -ww122446111FG:-,C #C (2237 7++C9 w|| #  ='C66s;;33557'C66s;;7??*002W__,002W__,335002+/+<+<+> (Bcww122446111FG 227;LD',,*<*<#==$$==6l ++G+<(&  ..VW4E/FG ,   ,G4 +G4 ;G D  II8- H9F ~ .v 6  II8- H9FL $%5 6 , II:% 5J0IL  - 99 |G'< ,**"7 *7(A W%/8M 89393C3C 3 3 564L0   #*T1syy  ! 6:L $] 326))+ Z /   u $)I)I)K)K@@AK (--+-F  3X>>FL,];%%'|Q& ':S@ # (( '*S0cii  ,    x '?!C #   !+.CKK,  sfBV<&X:X,;6Y4Z<%X%.XX X)(X), Y6YY"ZZ ZZr:cB[5nUS-nUR(dSnOSnSnSn[R"UUS9$![arn[ U5n[5U- n[ R"XxS9nUR(d+[UR[R5(aSnSnAO9SnAf[a)n[ U5n[ R"US9nSnAOSnAff=fURXa(+S9 [SU-[ R"S 9 0$) Ni, )max_connection_errorsretry_deadline) exceptionrF)rrz!Ignoring IMDS metadata due to: %sr)rrr fetch_metadata_with_api_fallbackr-rrReportableErrorImdsUrlErrorr'causerequestsConnectionError ValueError+ReportableErrorImdsMetadataParsingExceptionrr*rr) rr:rrr error_string error_reportrrs r5rR&DataSourceAzure.get_metadata_from_imds?s[ #c)..$& !$( !&* 9=  88&;-  'u:L {Z/H!==L22z X5588"' u:L!MML  \5GH /, >   s$A C- A(B77 C-C((C-cV>[[U] U5 [RUlg)z.Reset any cached class attributes to defaults.N)rrclear_cached_attrsrUNSET_metadata_imds)r attr_defaultsrs r5r"DataSourceAzure.clear_cached_attrsms ot7 F%mmr6c[RR5nUbgURcg[ URS5R 5$)zACheck platform environment to report if this datasource may run. TFrF)rChassisAssetTag query_systemrrexists)r chassis_tags r5 ds_detectDataSourceAzure.ds_detectrsJ ..;;=  " == DMM=188::r6c[5 [ 5 UR 5nUR5 UR(aDURRS:Xa*URRS5(a [5 [ n["R$R'U5(a@[)SU-[R*S9 [,R."US [0/5UlO%[)S U-[R*S9 US UlUS S Ul[,R."US [6/5UlUS Ul[=URSUSSS9 g![a!n[RSU5 SnAGNSnAff=f![a!n[RSU5 SnAGNSnAff=f![ Ra+nURU5 SnAUR5 gSnAf[aAn[ R"U5nURU5 SnAUR5 gSnAff=f!UR5 f=f)zCrawl and process datasource metadata caching metadata as attrs. @return: True on success, False on error, invalid or disabled datasource. z Failed to get boot telemetry: %sNz$Failed to get system information: %sFubunturzXEphemeral resource disk '%s' exists. Merging default Azure cloud ephemeral disk configs.rrzdEphemeral resource disk '%s' does not exist. Not merging default Azure cloud ephemeral disk configs.r@rrArr?i)dirmodeT)r'rarrr)r{rReportableErrorrr !ReportableErrorUnhandledExceptionrrrrQ*maybe_remove_ubuntu_network_config_scriptsRESOURCE_DISK_PATHrrrr*rrr#BUILTIN_CLOUD_EPHEMERAL_DISK_CONFIGrrDEFAULT_METADATAr@rA write_files)rrxrkrr.devpaths r5 _get_dataDataSourceAzure._get_datas' ?   C   2..0L  / / 1 KK   H,  677 6 8 % 77>>' " " #F II   ))e$&IJDH $J II   $E*DH*:6v>** * %'7 8  )8  KK #\'%:E } ? KK:A > > ?  C KK> B B C %%    '  / / 1  %GGN   !1 2  / / 1    / / 1si E4 F"G4 F>FF" G ,GG I$H 5I I'I>IIII-cUR(aSUR;aUR5$[URS5$)Nr8)r@rfrrs r5get_instance_idDataSourceAzure.get_instance_ids4}} T]] B99; 4==/00r6c>URSRU5$)Nr)rrQ)rrs r5device_name_to_device%DataSourceAzure.device_name_to_devices{{>*..t44r6cURURS5$![[4a UR 5$f=f)z Retrieve public SSH keys. r)_get_public_keys_from_imdsr@KeyErrorr_get_public_keys_from_ovfrs r5get_public_ssh_keys#DataSourceAzure.get_public_ssh_keyssG  224==3HI I*%  --// s AAr=cvUSSVs/sHnUSPM nn[ SU55(a%Sn[U[RS9 [ U5eSR [U55n[U[RS9 U$s snf![a Sn[U[RS9 ef=f) zGet SSH keys from IMDS metadata. :raises KeyError: if IMDS metadata is malformed/missing. :raises ValueError: if key format is not supported. :returns: List of keys. compute publicKeyskeyDataz"No SSH keys found in IMDS metadatarc3># UHn[US9(+v M g7f))r;N)_key_is_openssh_formatted).0r;s r5 =DataSourceAzure._get_public_keys_from_imds..sJ#,555szKey(s) not in OpenSSH formatzRetrieved {} keys from IMDS)rr*rranyrrrZ)rr= public_keyrzlog_msgs r5r*DataSourceAzure._get_public_keys_from_imdss #*)"4\"B"BJ9%"B  JJ J J4G #G CW% %/66s8}ESYY?! :G #G C  s BB B B&B8c/nURSnSR[U55n[U[R S9 U$![ a Sn[U[R S9 U$f=f)zIGet SSH keys that were fetched from wireserver. :returns: List of keys. rJzRetrieved {} keys from OVFrzNo keys available from OVF)r@rrZr*rrr)rrzrs r5r)DataSourceAzure._get_public_keys_from_ovfsq  D}}]3H299#h-HG #G C   D2G #G C  DsAA$A/.A/cUR$Nrrs r5get_config_objDataSourceAzure.get_config_obj s xxr6cJ[R"UR55$r)rinstance_id_matches_system_uuidr)rrs r5check_instance_id!DataSourceAzure.check_instance_id s66t7K7K7MNNr6c[RRURR S5S5n[ R "5n[RRU5(aQ[R"U5R5n[ R"U5nUR5X44;aU$U$)Nrr8) rrrvr get_cpathrquery_system_uuidrrload_text_filestripbyte_swap_system_uuidrw)rprevious prev_iid_path system_uuid swapped_ids r5rfDataSourceAzure._iids JJ  (- 002 77>>- ( (**=9??AH!77 DJ ~~K#<<r6cxSn[R"SS[S9 [R"U5nSSS5 UcSn[ U[ RS9 g[ SU-[ RS9 g!,(df  NH=f![a'n[ [U5[ RS9 eSnAff=f)zUse the netlink socket provided to wait for nic detach event. NOTE: The function doesn't close the socket. The caller owns closing the socket and disposing it safely. Nzwait-for-nic-detachzwait for nic detachrzHPreprovisioned nic not detached as expected. Proceeding without failing.rz%The preprovisioned nic %s is detached) rr r#rwait_for_nic_detach_eventr*rrrAssertionErrorrr)rnl_sockifnamerprs r5_wait_for_nic_detach$DataSourceAzure._wait_for_nic_detach!s  F((*1( !::7C  ~2(E';fD # "  #CJCII F  s3BA7%BB7 BB B9"B44B9rretriesc [U5H`nURRRU5(a[ SU-[ R S9 gUS-U:dMU[U5 Mb [ SXU-4-[ R S9 g)NzThe link %s is up.rrTz;The link %s is not up after %f seconds, continuing anyways.)ranger networkingtry_set_link_upr*rinfor)rrrrrs r5wait_for_link_up DataSourceAzure.wait_for_link_upAswA{{%%55f=='(61sxxA k"  $M[012HH r6cURn[RSU5 [R"USR [ R"5[5S95 [S[RS9 g)Nz*Creating a marker file to report ready: %sz{pid}: {time} )pidrzRSuccessfully created reported ready marker file while in the preprovisioning pool.r) rrrr write_filerrgetpidrr*r)rrs r5_create_report_ready_marker+DataSourceAzure._create_report_ready_markerUs\// =tD  #**ryy{*H   1  r6) create_markerexpect_url_errorrrcjUR5 SUl U(aUR5 gg![avnU(a9[U[5(a$[ S[ R S9 SUlSnANjSn[ U[ RS9 [R"U5UeSnAff=f)zReport ready for PPS, creating the marker file upon completion. :raises sources.InvalidMetaDataException: On error reporting ready. z,Ignoring http call failure, it was expected.rNz9Failed reporting ready while in the preprovisioning pool.F) rirar'r-r*rrrrrrSrgr)rrrrrps r5_report_ready_for_pps%DataSourceAzure._report_ready_for_ppsbs G    ,!   , , . / G  Juh$?$?'B #  !% P(C66s;F% Gs2 B2;B-<1B--B2c[RS5 /nSnSn[R"SS[ U5-[ S9 [ R"X5nSSS5 URU5 [SU-[RS9 URU5 U(d'[RS U5 URUS SS 9nU(a[RS 5 gUR5 M!,(df  N=f![a+n[[U5[RS9 SnAgSnAff=f) z6Wait until the primary nic for the vm is hot-attached.z*Waiting for primary nic to be hot-attachedFNzwait-for-nic-attachz4wait for nic attach after %d nics have been attachedrzDetected nic %s attached.rz!Checking if %s is the primary nicr7)rrrzFound primary nic for this VM.)rrrr rZr#rwait_for_nic_attach_eventappendr*rrr rrr)rr nics_foundprimary_nic_foundrrs r5"_wait_for_hot_attached_primary_nic2DataSourceAzure._wait_for_hot_attached_primary_nics- =>3 GJ %  ,,.Nj/*- %>>F!!&)'/&8chh %%f- )HH@&I(,(H(H$(*6;)I)%%HH=>779QP G #CJCII F Gs6-DC=BD+D= D D E!D>>Ec[R"5$![Ra!n[SU3[R S9 eSnAff=f)Nz!Failed to create netlink socket: r)rcreate_bound_netlink_socketNetlinkCreateSocketErrorr*rr)rrs r5_create_bound_netlink_socket,DataSourceAzure._create_bound_netlink_socketsJ 668 8//  #3E7;II    sA AA cURSS9 [S[RS9 [ S5 [ R "5e)z4Report ready and wait for host to initiate shutdown.F)rz"Waiting for host to shutdown VM...ri3)rr*rrrrReportableErrorOsDiskPpsFailurers r5rW.DataSourceAzure._wait_for_pps_os_disk_shutdowns? """7 0  h4466r6c`UR5nURbURRc [S5eURRnUR 5 [ R SU5 [R"SS[S9 [R"X5 SSS5 UR5 UR!5 g![a%n[SU-[ RS9 SnANSSnAff=f!,(df  Na=f!UR5 f=f) z9Report ready and wait for nic link to switch upon re-use.Nzmissing ephemeral contextz#Wait for vnetswitch to happen on %sz!wait-for-media-disconnect-connectzwait for vnet switchrz'Error while waiting for vnet switch: %sr)rrrr rrrrr r#r!wait_for_media_disconnect_connectrr*rcloser )rrrrxs r5rU+DataSourceAzure._wait_for_pps_running_reuses335 ((0++119"#>??,,22E  & & ( II5 ((82( ==gM  MMO ++-&+AAE$'II MMOsHBDD C/D D"D=D DD  DDD-czUR5nURSS9 UR5 URU5 URU5 UR5 g![Ra,n[ SU-[ RS9 SUlSnANnSnAff=f!UR5 f=f)z@Report ready and wait for nic(s) to be hot-attached upon re-use.T)rzLIgnoring failure while tearing down networking, NIC was likely unplugged: %rrN) rrr rrr*rrrrrr)rrrxs r5rV+DataSourceAzure._wait_for_pps_savable_reuses335   & & & = 0335  % %g .  3 3G < MMO-- 0'3567 # ,0((  0 MMOs3B(A%"B(%B%9"B B( B%%B((B:c[RRUR5(agUR 5 UR 5 g)z0Report ready if needed for unknown/recovery PPS.N)rrisfilerrr rs r5rX+DataSourceAzure._wait_for_pps_unknown_reuses: 77>>$:: ; ;  ""$ ++-r6cSnSnU(dmUR5(dUS- nURSS9 [R"SS[ S9 [ R"5nSSS5 U(dMm[S U-[RS 9 U$![a Mf=f![a UR5 SSS5 Mf=f!,(df  Nn=f) z0Poll IMDs for reprovisiondata XML document data.rNrTrr8zget-reprovision-data-from-imdszget reprovision data from imdsrz#attempted dhcp %d times after reuser) r#rrrr r#rfetch_reprovision_datar-r r*rr)r dhcp_attemptsreprovision_datas r5 _poll_imdsDataSourceAzure._poll_imds s ,0"3355" 44Q4G((5<( '+'B'B'D$ #"& 1M A   %( 779s;BCB' B$#B$'C C C  C Crrc[SUR53[RS9 [ 5 [ R "U5nU(aU$UR5(a5[S[RS9 [URUS9 SUl g[S[RS9 UR5 URS S 9 [URUS9 SUl g![a%n[SU-[RS9 SnANSnAff=f![a NZf=f![a%n[S U-[RS9 SnAg SnAff=f) aReport failure to Azure host and fabric. For errors that may be recoverable (e.g. DHCP), host_only provides a mechanism to report the failure that can be updated later with success. DHCP will not be attempted if host_only=True and networking is down. @param error: Error to report. @param host_only: Only report to host (error may be recoverable). @return: The success status of sending the failure signal. z#Azure datasource failure occurred: rz>Using cached ephemeral dhcp context to report failure to Azure)endpointrTz@Failed to report failure using cached ephemeral dhcp context: %sNz3Using new ephemeral dhcp to report failure to Azurer7r8z5Failed to report failure using new ephemeral dhcp: %sF)r*as_encoded_reportrrr+rreport_failure_to_hostr#rr,rrgrar rr)rrrreportedrxs r5rDataSourceAzure._report_failure>s\ 1%2I2I2K1L M   --e4 O  + + - - '1 #  )!66e$(   #EII   / / 1 000D %22%  $D - '8:;< #  $    #G!KII    sT)3C2(D4D$D42 D!<DD!$ D1.D40D11D44 E#>EE#rHrIc[5 [R"5 [URUR UR US9nSUlSUl U$![a!n[SU-[RS9 eSnAff=f)zTells the fabric provisioning has completed. :param pubkey_info: Fingerprints of keys to request from Wireserver. :raises Exception: if failed to report. :returns: List of SSH keys, if requested. )rriso_devrIzQError communicating with Azure fabric; You may experience connectivity issues: %srNT) r+rreport_success_to_hostr(rrrrar*rrrg)rrIrrxs r5riDataSourceAzure._report_readys  ""$ +22{{ ' D    #*,-.KK    s*A B%BBc~USSS$![a%n[SU-[RS9 SnAgSnAff=f)NextendedrppsTypez2Could not retrieve pps configuration from IMDS: %sr)rar*rr)rr=rxs r5rZ"DataSourceAzure._ppstype_from_imdssH :&y1)< <  #DqHII   s <7<ovf_cfgc[RRUR5(a[R nGOhUR SS5[RR:Xd-URU5[RR:Xa[RnOUR SS5[RR:Xd-URU5[RR:Xa[RnOUR S5SLd[UR SS5[RR:Xd-URU5[RR:Xa[RnO[Rn[SUR-[RS9 U$)z@Determine PPS type using OVF, IMDS data, and reprovision marker.PreprovisionedVMTypeNPreprovisionedVmTz PPS type: %sr)rrrrr;rKrQrJr<rZrHrIrGr*rr)rrr=rrs r5rT#DataSourceAzure._determine_pps_types/ 77>>$:: ; ;H KK. 59N9N N&&w/7??3H3HHH KK. 59N9N N&&w/7??3H3HHH KK* +t 3{{148$$%&&w/7??3H3HHH||H X^^ + r6cUR5n[R"SS[S9 [ U5up#nX#USU04sSSS5 $!,(df  g=f)zbInitiate the reprovisioning workflow. Ephemeral networking is up upon successful reprovisioning. zreprovisioning-read-azure-ovfz$read azure ovf during reprovisioningrrFN)r rr r#read_azure_ovf)rrwrnudrs r5rYDataSourceAzure._reprovisionsV ??$  $ $0>$ )2KBCC-!:;    s A  ArcSnURU5 U$![[4aM URSS5nSR Ub [ U5OS5n[ U[RS9 U$f=f)zDetermine the fingerprints we need to retrieve from Wireserver. :return: List of keys to request from Wireserver, if any, else None. N_pubkeysz"Retrieved {} fingerprints from OVFrr) rrrrQrrZr*rr)rrr=rIrs r5rh1DataSourceAzure._determine_wireserver_pubkey_infos,0  D  + +G 4 *% D''*d3K:AA$/$;K G $G C  DsAA43A4cD[R"UR5 g)zCleanup any marker files.N)rdel_filerrs r5rj DataSourceAzure._cleanup_markerss d667r6cURR5n[UUURR [ S5S9 [ 5 g![ 5 f=f)NF)is_new_instance preserve_ntfs)r get_ipath_curaddress_ephemeral_resizerrQDS_CFG_KEY_PRESERVE_NTFSr+)rrr+ instance_dirs r5activateDataSourceAzure.activatesOzz//1  " $ /"kkoo.FN  ! !s )A AcxURRS05RS05RS5$)NrrplatformFaultDomainr@rQrs r5availability_zone!DataSourceAzure.availability_zones4 MM  fb ) SB  S& ' r6cUR(aoUR[R:waQURR S5(a1[ URSURR S5S9$[5$![ a)n[RS[U55 SnAN9SnAff=f![ a*n[RS[U55 SnA0$SnAff=f)z:Generate network configuration according to configuration.rnetworkr)rz?Failed generating network config from IMDS network metadata: %sNz-Failed generating fallback network config: %s) rrrrrQ6generate_network_config_from_instance_network_metadatararrr-_generate_network_config_from_fallback_config)rrxs r5_generate_network_config(DataSourceAzure._generate_network_configs   ##w}}4  677 M'' 2;?;;??@< O@B B  5F  O IIEs1v N N  Os0/B  C B?B::B? C6 C11C6cUR(a*UR[R:wa UR$UR5UlUR$)z,Provide network configuration v2 dictionary.)rrrr<rs r5network_configDataSourceAzure.network_config$sG   D$8$8GMM$I'' '#<<>###r6cxURRS05RS05RS5$)Nrrlocationr5rs r5regionDataSourceAzure.region.s1}}  ,00B?CCJOOr6c[5nUSnUSVs/sHn[US5PM nnUVs/sH ofU;dM UPM nnU(dg[SU<S U<3[ R S9 UR(aURR(dg[R"URR5nU(a[U[5(dg[U5nX;a [S U<S U<3[ R S9 gs snf![a- [SUR S5-[ R S9 gf=fs snf) z=Validate IMDS network config and report telemetry for errors.r9r macAddressz6IMDS network metadata has incomplete configuration: %rrFTz8IMDS network metadata is missing configuration for NICs rz-IMDS network metadata is missing primary NIC ) r}rxrr*rQrrrrr get_interface_macr'r) rr= local_macsr?r imds_macsm missing_macs primary_macs r5r\.DataSourceAzure.validate_imds_network_metadata2sA34  $Y/N( 44A&a o64 $.D:a)1C: D^ -  ''t/G/G/M/M++D,D,D,J,JK *[#">">+K8  & #0KK  O  #H++i()KK    Es, DDD EED4EE)rrrrgrrrrrrrr@rrrA)rhN)rBr)rg?)F)PrCrDrErFdsnamerNETWORKrBOOT_NEW_INSTANCEBOOTdefault_update_eventsrgrrr_ci_pkl_versionrintrrrr$rrPrr rrr r#r/r{r rRrrrrrr rdictrrrrrfrfloatrrrrsocketrrWrUrVrXbytesr rrrrirZr;rTrYrhrjr1propertyr6r<r?rCr\rL __classcell__)rs@r5rr8s F  ' ' NN  K]]NO $      2 9! )= $ ! *! $.2 T}T(, T  T  T T!Tl!(!( T 47l!U!Un!+T+d+!+Z, ! ;! ;!F!FP1 5! 0T#Y 0! 0$49649 O"!!>!DG$'2TB ephemeral disk have gpt, and will have a microsoft reserved partition as part 1. LP: #1686514) c.) the ntfs partition will have no files other than possibly 'dataloss_warning_readme.txt' User can indicate that NTFS should never be destroyed by setting DS_CFG_KEY_PRESERVE_NTFS in dscfg. If data is found on NTFS, user is warned to set DS_CFG_KEY_PRESERVE_NTFS to make sure cloud-init does not accidentally wipe their data. If cloud-init cannot mount the disk to check for data, destruction will be allowed, unless the dscfg key is set.z#config says to never destroy NTFS (rUz), skipping checksFzdevice %s does not existzResolving realpath of %s -> %szdevice %s was not partitionedrQzdevice z had 3 or more partitions: rrTrz partition rz ) on device z was not ntfs formattedc[SS/5n[[R"U5Vs/sHo"R 5U;dMUPM sn5$s snf)Nzdataloss_warning_readme.txtzsystem volume information)setrZrlistdirrw)mpignoredfs r5 count_files+can_dev_be_reformatted..count_filessG *,G H rzz"~J~!'1IA~JKKJs AAz was ntfs formattedzmount-ntfs-and-countrntfsLANGC)r6update_env_for_mount log_errorzcannot mount ntfszunknown filesystem type 'ntfs'Tz^ but this system cannot mount NTFS, assuming there are no important files. Formatting allowed.Nz but mount of z failed: zmounted and counted %d fileszxit looks like you're using NTFS on the ephemeral disk, to ensure that filesystem does not get wiped, set %s.%s in configz but had %d files on it.z3 and had no important files. Safe for reformatting.)rvrr/rrrrrrrrxrZr}r$rr r#rrMrOrrr) rr,rp partitions partition_lenrq cand_part cand_pathrbmsgevt file_countrxs r5can_dev_be_reformattedrs& HH[ ! $ cz 77>>' " "07:::II('2773C3CG3L 'w/J 5??? OMq  HHJ/JqdJ/ 0 cz)!} 9)!}  * *     cz L!L  D  #*    P&,c] J( ?>' " " :W D    2W <  F C4 ,WD II$f2 ''',,|UIOD07= 77>>' " " @ '" -. II)4 0( % @ 5t?? @s0,D99 E$EE$cSnU(dgU(d0n[R"X5 UR5HGupE[RR X5nSU;aU"XV5n[R "XeSS9 MI g)Nc@[R"U5nUR5H6nSUR;dMUR[ :wdM+[ UlM8 [R "U5$![a [RSU5 Us$f=f)z>Azure provides the UserPassword in plain text. So we redact it UserPasswordz#failed to redact userpassword in %s) ET fromstringitertagtextDEF_PASSWD_REDACTIONtostringrarcritical)cntfnamerelems r5_redact_password%write_files.._redact_passwordFsy ==%D "dhh. %99 4DI $ ;;t$ $  LL> FJ s7A8A8$A88"BBrFi)filenamecontentmode)r ensure_dirrerrrvr)datadirr?rrrrrs r5rrDsg   OOG%  W+ D &w6G eD 'r6ct[R"U5n0n0nUR=(d SnUR(aURUS'UR(aURUS'UR bUR (+US'OUR (aSUS'0nUR(aURUS'UR (a1SUS'[UR :wa[UR 5US 'U(aS U0US 'URUS '[S UR-[RS9 URUS'[SUR-[RS9 URUS'[SUR-[RS9 X$U4$)zParse OVF XML contents. :return: Tuple of metadata, configuration, userdata dicts. :raises NonAzureDataSource: if XML is not in Azure's format. :raises errors.ReportableError: if XML is unparsable or invalid. rr2r%rBTrF lock_passwd hashed_passwdr4r3rzPreprovisionedVm: %srrzPreprovisionedVMType: %sr9zProvisionGuestProxyAgent: %s)r" parse_text custom_datarD public_keysdisable_ssh_password_authpasswordrCr encrypt_passpreprovisioned_vmr*rrpreprovisioned_vm_typeprovision_guest_proxy_agent)rwovf_envrnrr"defusers r5r!r!as""8,GB C    "B&// !--J((4 ' A AAL    LG!**!&  7#3#3 3'3G4D4D'EGO $,g6M%77C!:!::HH #*"@"@C"W%C%CCHH '.&I&IC"#&)L)LLHH C=r6c[U5$r)r1)rs r5rrs  ""r6c[U5nURS5 SSS5 g!,(df  g=f![a [R SU5 gf=f)z;Return boolean indicating path to cdrom device has content.iNTzcdrom (%s) is not configuredF)openreadIOErrorrr) cdrom_devfps r5_check_freebsd_cdromrsO= )_ GGDM__  = 0)< =s# :): 7:: AAc|Ucg[R"USS9n[R"U5R 5$)zEReturn content random seed file if available, otherwise, return None.NT)quiet)rload_binary_filerc b64encodedecode)sourcers r5reres: ~  t 4D   D ! ( ( **r6c## Uv [v [R"5(aSn[U5(aUv O*SH$n[R"SU-5ShvN M& U(aUv ggN7f)Nz/dev/cd0)iso9660r5zTYPE=%s)DEFAULT_PROVISIONING_ISO_DEVrrLrr{)r cache_dirrfstypes r5rKrKsh J &&   * *O(F**9v+=> > >) ?sAA9!A7"A9c[RRUS5n[RRU5(d [ S5e[ R "S5 [US5nUR5nSSS5 SSS5 [W5upEnXEUSU04$!,(df  N+=f!,(df  N4=f)NrFzNo ovf-env file foundzReading ovf-env.xmlrb) rrrvrr!r Timedrrr!) source_dirovf_filerrwrnr"rs r5rNrNsww||J 6H 77>>( # # !899   0 14$3G27794H 1!*KBC C-2 33 4H3G 1 1s$& B:3B)B:) B7 3B:: Cnetwork_metadatarc @S0S.n[US5GHup4SnSRUS9nSUS-S -0nUS :aSUS 'S USS .nSHn URU 05RS/5n U (d[R SX5 MDS nU S:XaSn OSn U (a S US'XxS'U(dMjU SSH^n XISS RSU 5n U SnURS5(d/US'USR SRXS95 M` M U(a]U(aV[ US5nURSUR50US.5 [U5nU(aUUS S!'XS"U'GMm[R S#UUU5 GM U$)$zConvert imds network metadata dictionary to network v2 configuration. :param: network_metadata: Dict of "network" key from instance metadata. :return: Dictionary containing network version 2 standard configuration. rQ)version ethernetsrFzeth{idx})idxz route-metricrTrrzuse-dnsT)dhcp4zdhcp4-overridesdhcp6)ipv4ipv6 ipAddresszNo %s addresses found for: %rr24128rzdhcp6-overridesNsubnetprefixprivateIpAddress addressesz {ip}/{prefix})iprrF macaddress)matchzset-namerr rzB r6c8[R"SS9nUc0$U$)zlGenerate fallback network config. @return: Dictionary containing network version 2 standard configuration. T) config_driver)r generate_fallback_configrs r5r;r;,s#  & &T :C { Jr6cU(d[nSnUHn[RRU5(dM)U(dJ[R S[ RR[ RR/5 Sn[RRU5(a[R"U5 M[R"U5 M g)aRemove Azure-specific ubuntu network config for non-primary nics. @param paths: List of networking scripts or directories to remove when present. In certain supported ubuntu images, static udev rules or netplan yaml config is delivered in the base ubuntu image to support dhcp on any additional interfaces which get attached by a customer at some point after initial boot. Since the Azure datasource can now regenerate network configuration as metadata reports these new devices, we no longer want the udev rules or netplan's 90-hotplug-azure.yaml to configure networking on eth1 or greater as it might collide with cloud-init's configuration. Remove the any existing extended network scripts if the datasource is enabled to write network per-boot. Fz|Removing Ubuntu extended network scripts because cloud-init updates Azure network configuration on the following events: %s.TN)UBUNTU_EXTENDED_NETWORK_SCRIPTSrrrrrrrQr< BOOT_LEGACYisdirrdel_dirr()rloggedrs r5rr8s& / F 77>>$  -^^))9+@+@+F+FG  ww}}T"" T" d#r6c8[R"U[5$r)rlist_from_depends datasources)dependss r5get_datasource_listrhs  $ $Wk ::r6r)r.)rc functoolsloggingros.pathrWrWxml.etree.ElementTreeetree ElementTreerenumrpathlibrrrrtypingrr r r r cloudinitr r rrrrcloudinit.eventrr cloudinit.netrcloudinit.net.dhcprrrcloudinit.net.ephemeralrrcloudinit.reportingrcloudinit.sources.azurerrrrcloudinit.sources.helpersrcloudinit.sources.helpers.azurer r!r"r#r$r%r&r'r(r)r*r+r,cloudinit.url_helperr-cryptpartialrand_strr1__annotations__r3AttributeError passlib.hashpasslibhash sha512_crypt getLoggerrCrDS_NAMErr DEFAULT_FSAGENT_SEED_DIRrr;rMrrrarfrmrxr}rrrrrrrLres_diskrrrrr/rrrr^rbr_r`rrxr}rrPr.rr!rrrerKrNrUr:r;rDataSourceAzureNetDEP_FILESYSTEMrrrBr6r5r(sp  ""'',,EE1' J&??-*"** C R 89:M3(! !#346  #)d*J#I#,&chsm"sstCy#4CD=7'Xc]'V??J+A.H -.$x/ )*"!#56 .2  e !+nEF '#W% /"hg((hV)#" 55 mNmN`&! ( ( ( (  ( ( VEE844n#3++(   4 4MM-1M MM`t"$"$L%w--/0 ;_A ^$  1166     s*:5J44K6=$K$$ K2-K61K22K6