⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
cloudinit
/
__pycache__
/
View File Name :
url_helper.cpython-312.pyc
fO > d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m Z m Z d dl m Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZmZmZmZmZm Z m Z d d l m Z m Z m!Z!m"Z" d dl#Z#d d l#m$Z$ d d l%m&Z&m'Z' ejP e) Z*d Z+d Z,d Z-de.fdZ/d@de0de1de2ddfdZ3de0ddfdZ4de d fdZ5 G d d Z6 G d de6 Z7 G d de6 Z8 G d d Z9 G d! d"e: Z;d# Z< dAd&e=de9fd'Z> dBd(ed)ef d*e0de.d+ej~ d,ee1 def d-Z@ dCd(ed)ef d/ee0 d0e1de.de f d1ZA e1d2 de*j dddddd%d$d.f d3e1dee1 d4ed5ee d6ee1 d7ee d8eeee1ge1f d9e0d:e=d;e1fd<ZC G d= d> ZD dBd?ZEy)D N)ThreadPoolExecutor TimeoutError as_completed) parsedate)partial) NOT_FOUND)count)create_default_context)AnyCallableIteratorListOptionalTupleUnion)quoteurlparseurlsplit urlunparse) exceptions)utilversionREDACTEDc r t t | d }|d s|d r |d |d< d|d< t | S )Nhttp)scheme )listr r )url parsed_urls 6/usr/lib/python3/dist-packages/cloudinit/url_helper.py _cleanurlr$ & sC hs623J a=Z] #1 1 1 j !! c 0 d }| }|D ] } ||| } |S )Nc t t | }|d }|r|j d s|dz }|t t | d z }||d< t | S )Nr /z/:)safe)r r endswithr strr )r! add_on url_parsedpaths r# combine_singlez#combine_url.<locals>.combine_single1 sY (3-( !} c* CKD c&k-- 1 *%%r% )baseadd_onsr/ r! r, s r# combine_urlr3 0 s) & C S&) Jr% returnc 8 t j dt j dt j dt j dt di}|j t | }|s5t | t r| j }|S t j d d}|S )z4helper for read_ftps to map return codes to a number, iX i z9Unexpected exception type while connecting to ftp server.i) ftplib error_reply error_temp error_perm error_protoEOFErrorgettype isinstanceOSErrorerrnoLOGwarning)excftp_error_codescodes r# "ftp_get_return_code_from_exceptionrI @ s C33C# O tCy )D c7 #99D K KKK D Kr% r! timeoutkwargs FtpResponsec L t | }|j st dt d| t j 5 }|j xs d}|j xs d}d|j k( rH t j t }t j d| | |j |j ||xs d t j d| |j# ||j$ xs d t j d |j' t j d|j, |j/ d|j, |j0 t3 |j5 | t j d |j7 cddd S t j8 } t j d| | | j |j ||xs d t j d| | j# ||j$ xs d t j d|j, | j/ d|j, |j0 t3 |j5 | t j d | j7 cddd S # t j $ r'}t! | } t d | d | d | d| |d}~ww xY w# t j( $ r*}t j+ d t ddd| |d}~ww xY w# t j $ r'}t! | } t d| d | d | d| |d}~ww xY w# t j d |j7 w xY w# t j $ r'}t! | } t d| d | d | d| |d}~ww xY w# t j d j7 w xY w# 1 sw Y yxY w)az connect to URL using ftp over TLS and read a file when using strict mode (ftps://), raise exception in event of failure when not using strict mode (ftp://), fall back to using unencrypted ftp url: string containing the desination to read a file from. The url is parsed with urllib.urlsplit to identify username, password, host, path, and port in the following format: ftps://[username:password@]host[:port]/[path] host is the only required component timeout: maximum time for the connection to take kwargs: unused, for compatibility with read_url returns: UrlResponse zInvalid url providedNcauserH headersr! anonymousftps)contextz3Attempting to connect to %s via port [%s] over tls. @)hostportrJ z1Reading file from server over tls failed for url z []z"Attempting to login with user [%s]r )userpasswdz Creating a secure connectionzAttempted to connect to an insecure ftp server but used a scheme of ftps://, which is not allowed. Use ftp:// to allow connecting to insecure ftp servers.r8 zReading file: %szRETR )callbackzClosing connectionz,Reading file from ftp server failed for url z(Attempting to connect to %s via port %s.) r hostnameUrlErrorr ioBytesIOrW usernamer r9 FTP_TLSr rD debugconnect all_errorsrI loginpasswordprot_pr< rE r. retrbinarywriterL getvaluecloseFTP) r! rJ rK url_partsbufferrW rY ftp_tlserH ftps r# read_ftpsrr W s I (y$C ~~#!!0[ Y%% % .. 2 4 I "++ #Ns II:D A $--3 89 " ,inn=""INN+,v|| # #6??#4c: ./ S V jjl >T "++ #Ns >E $--3 ,inn=y~~&6 7&,,O"6??#4c: ./ U $ $$ 9!< **-ba9 & $$ C N . $$ 9!< ++.%r$q: ./ ( $$ 9!< ++.%r$q: ./ U s 1P1AKP AL &A#M %P9C'N3 %PL ""LL P M %MM P N "NNN 'N00P3O-"O((O--O00'PPP#r. FileResponsec * |j d rt j d| t j | }t || S # t $ r}t |t d| |d}~wt $ r }t ||j d| |d}~ww xY w)zmread a binary file and return a FileResponse matches function signature with read_ftps and read_url dataz'Unable to post data to file resource %sNrN ) r? rD rE r load_binary_filers FileNotFoundErrorr] r IOErrorrC )r. rK contentsrp s r# _read_filerz s zz& =tDM((.Hd++ OQY$GQN MQQWWdE1LMs# A BA'' B3B B)rs UrlResponserL c ^ | j } t | }|j }|dk( s | r d| d k( rt |j fi |S |dv r t | fi |S |dv r t | fi |S t j d| t | fi |S # t $ r}t || |d}~ww xY w) a0 Wrapper function around readurl to allow passing a file path as url. When url is not a local file path, passthrough any kwargs to readurl. In the case of parameter passthrough to readurl, default values for some parameters. See: call-signature of readurl in this module for param docs. )rO r! Nfiler( r )rq rS )r httpsz Attempting unknown protocol %s) lstripr ValueErrorr] r rz r. rr readurlrD rE )r! rK parsedrp r s r# read_file_or_urlr s **,C0# ]]F CC3q6M&++000 ? "''' $ $s%f%% 4f=s%f%% 0QC(a/0s B B,B''B,c e Zd ZddZd Zd Zy)StringResponsec < || _ i | _ || _ || _ y N)rH rP ry r! )selfry r! rH s r# __init__zStringResponse.__init__ s r% c $ | j dk7 ryy)N FTrH r argsrK s r# okzStringResponse.ok s 99 r% c 8 | j j d S )Nzutf-8)ry decoder s r# __str__zStringResponse.__str__ s }}##G,,r% Nr )__name__ __module__ __qualname__r r r r0 r% r# r r s -r% r c * e Zd Zddedef fd Z xZS )rs ry r! c * t | ||| y )Nr superr )r ry r! rH __class__s r# r zFileResponse.__init__ s 3T2r% r r r r bytesr+ r __classcell__r s @r# rs rs s 3 3S 3 3r% c ( e Zd Zdedef fd Z xZS )rL ry r! c & t | || y r r )r ry r! r s r# r zFtpResponse.__init__ s 3'r% r r s @r# rL rL s ( (S ( (r% c e Zd Zdej fdZedefd Zede fd Z dde fdZ ed Z edefd Zd Z dd ee d e dee fd Zy )r{ responsec || _ y r ) _response)r r s r# r zUrlResponse.__init__" s !r% r4 c \ | j j y| j j S )Nr% )r contentr s r# ry zUrlResponse.contents% s% >> ! ! )~~%%%r% c . | j j S r )r r! r s r# r! zUrlResponse.url+ s ~~!!!r% c @ d}|rd}d| j cxk r|k ry yy)Nr6 r7 r TFr )r redirects_okuppers r# r zUrlResponse.ok/ s- E $)) #e # $ r% c . | j j S r )r rP r s r# rP zUrlResponse.headers8 s ~~%%%r% c . | j j S r )r status_coder s r# rH zUrlResponse.code< s ~~)))r% c . | j j S r )r textr s r# r zUrlResponse.__str__@ s ~~"""r% chunk_sizedecode_unicodec # X K | j j || E d{ y7 w)at Iterates over the response data. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. :param chunk_size: Number of bytes it should read into memory. :param decode_unicode: If True, content will be decoded using the best available encoding based on the response. N)r iter_content)r r r s r# r zUrlResponse.iter_contentC s" >>..z>JJJs *(*N)F)r F)r r r requestsResponser propertyr ry r+ r! boolr rP intrH r r r r r0 r% r# r{ r{ ! s "!2!2 " &% & & "S " " & & *c * *# EJ K"3- K=A K % Kr% r{ c e Zd ZddZy)r] Nc t j | t | || _ || _ || _ | j i | _ || _ y r )rx r r+ rO rH rP r! )r rO rH rP r! s r# r zUrlError.__init__S sC s5z* << DLr% )NNN)r r r r r0 r% r# r] r] R s r% r] c i }t | j }|dk( rE|rCd|v r|d r |d |d< nd|d< d|v rd|v r|d |d g|d< |S d|v rt |d |d< |S )Nr~ ca_certsverifyT cert_filekey_filecert)r r r+ )r! ssl_detailsssl_argsr s r# _get_ssl_argsr ] s H c] ! !F [ $Z)@!,Z!8HX !%HX + %* *CK(J' HV O K ' ";{#; <HV Or% Tr streamc z t | } | |d}|j t | | | |d< |s|rdnd}||d< |.t |t r||d< nt t | d |d< |g }d }|rt t | d z d }d t j z }||j }ni }|r||d < |d }| t j } t D ] }|r || }d |vr||d < ||d< i }|j D ]g \ }}|d k( r |dk( rR|rP|D cg c] }|j | s| }}|s7t j | |< |D ] }t" || |< c|||< i |r t$ j' d|| rdn|| | | j( di |}| r|j+ t$ j' d| |j, t/ |j0 |d z t3 | c S tI d c c}w # t4 j6 $ r}t9 || |d}~wt4 j: $ r}t |t4 j< rZt? |d rNt? |j@ d r8t9 ||j@ j, |j@ jB | } n t9 || } | r | |j | s| || xs |d z |k } | s| ||dkD r-|rt$ j' d| tE jF | Y d}~Pd}~ww xY w)a Wrapper around requests.Session to read the url and retry if necessary :param url: Mandatory url to request. :param data: Optional form data to post the URL. Will set request_method to 'POST' if present. :param timeout: Timeout in seconds to wait for a response. May be a tuple if specifying (connection timeout, read timeout). :param retries: Number of times to retry on exception if exception_cb is None or exception_cb returns True for the exception caught. Default is to fail with 0 retries on exception. :param sec_between: Default 1: amount of seconds passed to time.sleep between retries. None or -1 means don't sleep. :param headers: Optional dict of headers to send during request :param headers_cb: Optional callable returning a dict of values to send as headers during request :param headers_redact: Optional list of header names to redact from the log :param ssl_details: Optional dict providing key_file, ca_certs, and cert_file keys for use on in ssl connections. :param check_status: Optional boolean set True to raise when HTTPError occurs. Default: True. :param allow_redirects: Optional boolean passed straight to Session.request as 'allow_redirects'. Default: True. :param exception_cb: Optional callable which accepts the params msg and exception and returns a boolean True if retries are permitted. :param session: Optional exiting requests.Session instance to reuse. :param infinite: Bool, set True to retry indefinitely. Default: False. :param log_req_resp: Set False to turn off verbose debug messages. :param request_method: String passed as 'method' to Session.request. Typically GET, or POST. Default: POST if data is provided, GET otherwise. :param stream: if False, the response content will be immediately downloaded. )r! r allow_redirectsPOSTGETmethodNrJ r r z Cloud-Init/%sru z User-AgentrP z'[%s/%s] open '%s' with %s configurationinfinitez(Read from %s (%s, %sb) after %s attempts)r! r r rH rP r! 1Please wait %s seconds while we wait to try againz"This path should be unreachable...r0 )%r$ updater rA tuplemaxfloatr r version_stringcopyr Sessionr itemsr? deepcopyr rD rb requestraise_for_statusr lenr r{ r SSLErrorr] RequestException HTTPErrorhasattrr rP timesleep RuntimeError) r! ru rJ retries sec_betweenrP headers_cbheaders_redactr check_statusr exception_cbsessionr log_req_resprequest_methodr req_args manual_tries user_agentifiltered_req_argskvmatched_headerskeyrrp url_error will_retrys r# r r o sY h C.CH OOM#{34"1H #'U'HX gu %")HY "%eGna"8HY L3w<!+Q/ G$:$:$<=J,,. ""$ W oG w &$.GL ! % NN$DAqF{I~..<"Ina1n"I"+/==+;%a( .4<)!,S1 / ()!!$ %> ( ="*J % +(+A""$ II: AIIQ q> !Y h ; <<O #J@ "" . 1#&A -** ! (1z 3 35Az*JJ %// JJ . . %QC 0 L )$L Q&!;a!el&:J Q&Q IIK# ;'C! (s2 *HH>BHL:+H99L:C L55L:func.addreventdelayc > |r|j | ry | || S )z Execute func with optional delayrJ Nwaitr r rJ r r s r# _run_func_with_delayr s' ::e: $ g r% 333333? addresses stagger_delayc N d}d}d}g }t j }t t | } t | D ci c]$ \ } } | j t | | ||| |z | & } } } t | | D ]h } | | }| j }|r|} |j | /| j }|sB|j ||fc | j d S |rt j d|| |t j d| t! d c c} } w # t" $ rF t j d d j% | d j% t' t( | Y nw xY w | j d ||fS # | j d w xY w) a execute multiple callbacks in parallel Run blocking func against two different addresses staggered with a delay. The first call to return successfully is returned from this function and remaining unfinished calls are cancelled if they have not yet started N) max_workersr r Fr z<Exception(s) %s during request to %s, raising last exceptionzEmpty result for address %szNo result returnedzJTimed out waiting for addresses: %s, exception(s) raised while waiting: %s ) threadingEventr r enumeratesubmitr r exceptionappendresultsetshutdownrD rE errorr r joinmapr+ )r r r rJ return_resultreturned_addresslast_exceptionr is_doneexecutorr r futuresfuturereturn_exceptions r# dual_stackr 1 s M.2NJoo G "c)n=H5& %Y/ 04 OO$ =( 0 #7G<F &v % / / 1 !1! !!.1 & KKM ,m<<2 u%O =$ KK- ! II35E F 12 2S X 4 HHY HHSj) * u% m ,, u%s> D' )D!*AD' <D' $AD' 'A E63F 5E66F F$infmax_wait status_cbr sleep_timer sleep_time_cbr connect_synchronously async_delayc n dt dt ffd } ddt dt dt fdd fd fd fd } fd }t j }r |r t d | r| n|}|xs | }dd} || } ||||| }|r|\ }}||j fS || rn`dz t j d| t j | t j }|r||z |z kD r||z z }|dk rnt j d y)a1 urls: a list of urls to try max_wait: roughly the maximum time to wait before giving up The max time is *actually* len(urls)*timeout as each url will be tried once and given the timeout provided. a number <= 0 will always result in only one try timeout: the timeout provided to urlopen status_cb: call method with string message when a url is not available headers_cb: call method with single argument of url to get headers for request. headers_redact: a list of header names to redact from the log sleep_time: Amount of time to sleep between retries. If this and sleep_time_cb are None, the default sleep time defaults to 1 second and increases by 1 seconds every 5 tries. Cannot be specified along with `sleep_time_cb`. exception_cb: call method with 2 arguments 'msg' (per status_cb) and 'exception', the exception that occurred. sleep_time_cb: call method with 2 arguments (response, loop_n) that generates the next sleep time. Cannot be specified along with 'sleep_time`. request_method: indicate the type of HTTP request, GET, PUT, or POST connect_synchronously: if false, enables executing requests in parallel async_delay: delay before parallel metadata requests, see RFC 6555 returns: tuple of (url, response contents), on failure, (False, None) the idea of this routine is to wait for the EC2 metadata service to come up. On both Eucalyptus and EC2 we have seen the case where the instance hit the MD before the MD service was up. EC2 seems to have permanently fixed this, though. In openstack, the metadata service might be painfully slow, and unable to avoid hitting a timeout of even up to 10 seconds or more (LP: #894279) for a simple GET. Offset those needs with the need to not hang forever (and block boot) on a system where cloud-init is configured to look for EC2 Metadata service but is not going to find one. It is possible that the instance data host (169.254.169.254) may be firewalled off Entirely for a system, meaning that the connection will block forever unless a timeout is set. The default value for max_wait will retry indefinitely. loop_numberr4 c S |dz dz S )N r r0 )_r% r s r# default_sleep_timez(wait_for_url.<locals>.default_sleep_time s ' 3zM9IA9MMr% r r start_timer c j | t d dfv ry| dk xs t j |z |z | kD S )z4Check if time is up based on start time and max waitr NFr )r r monotonic)r r* r s r# timeupz wait_for_url.<locals>.timeup s@ e d+ +A NN z )J 6 A r% c F | j s?d| j z }t t | | j | j | }||fS | j s?d| j z }t t | | j | j | }||fS d}d}||fS )z?Map requests response code/contents to internal "UrlError" typezempty response [%s]r zbad status code [%s]r N)ry rH r] r rP r )r r! reasonurl_excs r# handle_url_responsez)wait_for_url.<locals>.handle_url_response s *hmm<F 6" ]] (( G" +x}}=F 6" ]] (( G FG r% c l d}d} | | \ }} || \ }}|s||fS t t j |z } rdz nd} d|xs t |dd d | d | d |} || |r || | yy# t $ r} d| z }| }Y d} ~ qd} ~ wt $ r} d| z }| }Y d} ~ d} ~ ww xY w) z:Execute request, handle response, optionally log exceptionr Nzrequest error [%s]zunexpected error [%s]z%ss unlimitedz Calling 'r! z ' failed [r( z]: )msgr )r] Exceptionr r r, getattr) url_reader_cburlsr* exc_cblog_cbr/ r! r r0 rp time_taken max_wait_str status_msgr1 r s r# read_url_handle_exceptionsz0wait_for_url.<locals>.read_url_handle_exceptions s )$ /MC 1(C @OGVX& )J67 +3ux' 177E51 1 z zW 5 )A-FG ,q0FG s# B B3 B B3"B..B3c : t | i n | |d S )NF)rP r rJ r r )r )r! rJ r r r s r# read_url_cbz!wait_for_url.<locals>.read_url_cb s- $,B*S/) ) r% c fd} D ]X }t j }dk7 r+ | r y r |z | z kD rt | z |z ||| || }|sV|c S y)z|iterate over list of urls, request each one and handle responses and thrown exceptions individually per url c | | fS r r0 )r! r@ rJ s r# url_reader_serialz@wait_for_url.<locals>.read_url_serial.<locals>.url_reader_serial s S'23 3r% r N)r r, r )r* rJ r9 r: rC r! nowoutloop_nr r@ r> r- r8 s ` r# read_url_serialz%wait_for_url.<locals>.read_url_serial s 4 C.."C{(J/ ( w *x*?@ ":#8C"? @G,!3 FFC # r% c L t t | } | | || }|r|S y)zpass list of urls to dual_stack which sends requests in parallel handle response and exceptions of the first endpoint to respond )r rJ N)r r ) r* rJ r9 r: url_reader_parallelrE r# r@ r> r8 s r# read_url_parallelz'wait_for_url.<locals>.read_url_parallel$ sB & % ) z66 J r% z3sleep_time and sleep_time_cb are mutually exclusiveNr r z$Timed out, no response from urls: %s)FN)r ) r r r r, r ry rD rb r r ) r8 r rJ r r r r r r! r r" r# r) rG rJ r* do_read_urlcalculate_sleep_timer current_sleep_timer! address current_timer1 rF r@ r> r- s `` ``` ` ` @@@@@r# wait_for_urlrP sf rN3 N5 N E u !. 6@ 6 !JmNOO 16G )>,>FH 1(F C*g|YG # GXX . ./ / (J(: ; ! ? %& ~~' |g- X0EE ,";<G!|1 4 II4d; r% c T e Zd Z d dZd Zd Zd Zd Zd Zd Z d Z d Z d Z y) OauthUrlHelperNc < || _ |xs d| _ || _ || _ || _ d| _ d| _ | j | j | j f}t | sd| _ nt | s t d | j }|xs i | _ y )Nr Tr' FzBall or none of token_key, token_secret, or consumer_key can be set) consumer_keyconsumer_secret token_key token_secretskew_data_file _do_oauthskew_change_limitanyallr read_skew_file skew_data)r rT rV rW rU rX requiredolds r# r zOauthUrlHelper.__init__d s ) . 4" " ( , !" NND$5$5t7H7HI8} "DNX * !!# r% c | j r_t j j | j r6t | j d 5 }t j | cd d d S y # 1 sw Y y xY w)Nr mode)rX osr. isfileopenjsonload)r fps r# r] z OauthUrlHelper.read_skew_file sQ 277>>$2E2E#Fd))4yy} 54 5s A--A6c | j sy | j }|i }|||< t | j d 5 }|j t j | d d d y # 1 sw Y y xY w)Nwrb )rX r] rf ri rg dumps)r rV valuecurri s r# update_skew_filez OauthUrlHelper.update_skew_file sa "" !!# ;CD $%%C 0B HHTZZ_ % 1 0 0s %A,,A5c t |t r |j dk( s|j dk( sy d|j vr!t j d|j y |j d } t j t | }t |t j z }t |j j }| j j |d }t! ||z | j" kD r)| j% || t j d|| || j |< y # t $ r!}t j d|| Y d }~y d }~ww xY w)Ni i datez$Missing header 'date' in %s responsez#Failed to convert datetime '%s': %sr z$Setting oauth clockskew for %s to %d)rA r] rH rP rD rE r mktimer r5 r r r! netlocr^ r? absrZ ro ) r r4 r rq remote_timerp skewrV old_skews r# r zOauthUrlHelper.exception_cb s! y( + 3&)..C*? ** * KK> O ( ++io6K ;,- &-->>%%dA. x$ $"8"8 8 ! !$ - KK>d K #t KK=tQ G s / D< < E&E!!E&c L | j si S d }t | j }| j r;|| j v r-t t j | j | z }t || j | j | j | j | S )N)r! rT rV rW rU timestamp) rY r rs r^ r r oauth_headersrT rV rW rU )r r! ry rV s r# r zOauthUrlHelper.headers_cb s ~~I }## >>ddnn 4DIIK(4>>$+??I **nn ** 0 0 r% c t | j |j d |d< t | j |j d |d< ||i |S )Nr r )r _headers_cbr? _exception_cb)r wrapped_funcr rK s r# _wrappedzOauthUrlHelper._wrapped s\ & fjj 6 | ") > :" ~ T,V,,r% c 0 | j t || S r )r rP r s r# rP zOauthUrlHelper.wait_for_url s }}\488r% c 0 | j t || S r )r r r s r# r zOauthUrlHelper.readurl s }}WdF33r% c t d } |r ||| }| j || |S # | j || w xY wr )r )r extra_exception_cbr4 r rets r# r} z OauthUrlHelper._exception_cb sD .!(i8 c9 - c9 -s # 7c ^ i }|r || }|j | j | |S r )r r )r extra_headers_cbr! rP s r# r| zOauthUrlHelper._headers_cb s. &s+Gts+,r% )NNNNz/run/oauth_skew.json) r r r r r] ro r r r rP r r} r| r0 r% r# rR rR c sE - #6 &8 $-94r% rR c dd l m} |r t | }nd }|j |||||j | }|j | \ } } } | S # t $ r}t d |d }~ww xY w)Nr z oauth support is not available) client_secretresource_owner_keyresource_owner_secretsignature_methodry )oauthlib.oauth1oauth1 ImportErrorNotImplementedErrorr+ ClientSIGNATURE_PLAINTEXTsign) r! rT rV rW rU ry r rp client_urisigned_headers_bodys r# rz rz s K( N ]]%$ * 33 F #)++c"2 D.% # K!"BCJKs A A* A%%A*)rU )NNr r NNNNTTNNFTr Fr )r )Fr r9 r^ rg loggingrd r r concurrent.futuresr r r email.utilsr functoolsr http.clientr itertoolsr sslr typingr r r r r r r urllib.parser r r r r r cloudinitr r getLoggerr rD r r$ r3 r rI r+ r dictrr rz r r rs rL r{ rx r] r r r r r r rb rP rR rz r0 r% r# <module>r s M M ! ! & H H H > > #g! " s . 3 D MS M~ M & 78&< - - 3> 3 (. ( .K .Kbw ( #m=" #m=$ %m=j " 38 ?? E? * ! P- 38 P-CyP- P- P- P-j El # ))%)"&'+=A "& \\ e_\ \ " \ \ 8$\ Hc5\5%8 9:\ \ \ \~x xx LPr%