h$d%SrSSKrSSKrSSKrSSKrSSKJrJrJ r SSK r SSK r\R"\5r0rSrSrSr\R,R/S5/rS rS rS \4S \4S \4S\4S\4S\4S.r\\\ \\44\S'SrSr Sr!SSjr"SSjr#g!\ a Sr Nf=f)aqImplements I/O streams over SSH. Examples -------- >>> with open('/proc/version_signature', host='1.2.3.4') as conn: ... print(conn.read()) b'Ubuntu 4.4.0-1061.70-aws 4.4.131' Similarly, from a command line:: $ python -c "from smart_open import ssh;print(ssh.open('/proc/version_signature', host='1.2.3.4').read())" b'Ubuntu 4.4.0-1061.70-aws 4.4.131' N)DictCallableTupleT)sshscpsftp)zssh://username@host/path/filezssh://username@host//path/filezscp://username@host/path/filezsftp://username@host/path/filez ~/.ssh/configcRU=(a [RRU5$N)urllibparseunquote)texts H/home/james-whalen/.local/lib/python3.13/site-packages/smart_open/ssh.py_unquoterDs  .FLL((..c<US:XagUS:Xag[SUS35e)NnoFyesTzExpected 'yes' / 'no', got .) ValueError)strings r _str2boolrHs+ ~  26(!< ==rconnecttimeout compressiongssapiauthenticationgssapikeyexchangegssapidelegatecredentialsgssapitrustdns)timeoutcompressgss_authgss_kexgss_deleg_creds gss_trust_dns_PARAMIKO_CONFIG_MAPc n[RRU5nUR[;de[ UR[ UR5[ UR5URUR(a[UR5OS[ UR5S9$)N)schemeuri_pathuserhostportpassword) r r urlsplitr(SCHEMESdictrpathusernamehostnamer,intr-) uri_as_string split_uris r parse_urir7ds %%m4I   w && & )..) i(( )   $-NNS ),,-  rc[RR[U5n[ U5nUR S5nUR S5 0UEUEn[XQ40UD6$)Nr)r() smart_openutils check_kwargsopenr7pop)urimodetransport_paramskwargs parsed_urir) final_paramss ropen_urirDqs]    * *41A BF3J~~j)HNN8+j+F+L  /, //rcD[R"5nUR5 UR[R"55 U=(d 0R 5nSU;aUR SU5 UR SU5 UR"X40UD6 U$)N key_filenamer-r2)paramiko SSHClientload_system_host_keysset_missing_host_key_policy AutoAddPolicycopy setdefaultconnect)r3r2r,r-connect_kwargsrrAs r _connect_sshrPzs    C##H$:$:$<=" ( ( *FV#*h/ j(+KK)&) Jrc[SXX#U455(dXX#U4$U(d [S5eU=(d 0R5n[Vs/sH+n[R R U5(dM)UPM- nnSnUHn [RRU 5n X R5;aM8U RU5n UcU RSS5nU(dU SnUc[U S5nURS5c&U RS/5n [!U 5(aXS'["R%5H/un upURU 5bMX;dM#U"X5X\'M1 M Uc[&nU(d[(R*"5nU(aUnXX#U4$s snf![a GMEf=f![[4a Nf=f) Nc3(# UHoSLv M g7fr ).0args r &_maybe_fetch_config..sW&Vsd{&Vsz'you must specify the host to connect tor*r3r,rF identityfile)anyrrL_SSH_CONFIG_FILESosr1existsrG SSHConfig from_pathPermissionError get_hostnameslookupgetr4KeyErrorlenr&items DEFAULT_PORTgetpassgetuser)r+r2r-r,rOconnect_paramsf config_filesactual_hostnameconfig_filenamecfgrY param_name sshcfg_namefrom_strs r_maybe_fetch_configrss Wtx~&VW W Wx~== BCC"%*002N0F0!BGGNN14EA0LF O' $$..?C ((* * jj  wwvt,H!*oO < 3v;'   n - 577>26L<  1=~.3G3M3M3O /J/!!*-5+:L-5c6F-G*4PG(X | ??$ 8> 99yG    j)   s0(F=?F=G9G GGG'&G'c [X#XEU5up#pEnX#4n Sn [U 5Hsn [U n U R5R(d&U R 5 [ X#XTU5=n [U 'U R5n U R5n O WRXUS9nUUl UbUR"S0UD6 U$![a [ X#XTU5=n [U 'Nuf=f![RaHnUR=(a URSS:HnXS- :XdU(de[U SnAGM"SnAff=f)a Open a file on a remote machine over SSH. Expects authentication to be already set up via existing keys on the local machine. Parameters ---------- path: str The path to the file to open on the remote machine. mode: str, optional The mode to use for opening the file. host: str, optional The hostname of the remote machine. May not be None. user: str, optional The username to use to login to the remote machine. If None, defaults to the name of the current user. password: str, optional The password to use to login to the remote machine. port: int, optional The port to connect to. connect_kwargs: dict, optional Any additional settings to be passed to paramiko.SSHClient.connect. prefetch_kwargs: dict, optional Any additional settings to be passed to paramiko.SFTPFile.prefetch. The presence of this dict (even if empty) triggers prefetching. buffer_size: int, optional Passed to the bufsize argument of paramiko.SFTPClient.open. Returns ------- A file-like object. Important --------- If you specify a previously unseen host, then its host key will be added to the local ~/.ssh/known_hosts *automatically*. If ``username`` or ``password`` are specified in *both* the uri and ``transport_params``, ``transport_params`` will take precedence rzSSH session not activeN)r?bufsizerS)rsrange_SSH get_transportactivecloserPrdopen_sftp_clientrG SSHExceptionargsr<nameprefetch)r1r?r+r*r-r,rOprefetch_kwargs buffer_sizekeyattemptsattemptr transport sftp_clientexconnection_timed_outfobjs rr<r<sPd2E HN2.D ,CH? Ws)C$$&-- ".t4>"ZZd3i ))+I#446K #4   D[  ADDI" (( K- W*4t~V VC$s) W$$ #%77#Urwwqz=U/U Q,&.B S  s*AC5 C- C*)C*-E rs      8 $     WW''89/>&!%( *'3#Y/3Y?& 2 9d3c8m 445 0 T:r  WoLsB$$B/.B/