Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
idna / lib / python2.7 / site-packages / contego / nova / extension / driver / vaultswift.pyc
Size: Mime:
ó
w=4\c
@s6ddlmZmZddlZddlZddlZddlmZmZm	Z	ddl
mZmZm
ZddlmZmZmZddlmZddlmZmZmZddlmZmZdd	lmZdd
lm Z m!Z!m"Z"ddl#m$Z$ddl%m&Z&dd
lm'Z(ddl)m*Z*m+Z+m,Z,m-Z-ddl.m/Z/m0Z0m1Z1yddl2m3Z4Wn!e5k
r¡ddl6m3Z4nXdZ7d&Z8da:da;da<da=da>da?da@d„ZAd„ZBd„ZCd„ZDd „ZEd!„ZFd"„ZGd#„ZHd$„ZId%„ZJdS('iÿÿÿÿ(tprint_functiontunicode_literalsN(tOptionParsertOptionGroupt
SUPPRESS_HELP(tenvirontwalkt_exit(tisfiletisdirtjoin(t	text_type(targvtexittstderr(tgmtimetstrftime(tRequestException(tconfig_true_valuetgenerate_temp_urlt	prt_bytes(t
OutputManager(tClientException(t__version__(tSwiftServicet
SwiftErrortSwiftUploadObjecttget_conn(tprint_account_statstprint_container_statstprint_object_stats(tquoteuswiftudeleteudownloadulistupostustatuuploaducapabilitiesuinfoutempurluauthcCstjdƒtdƒdS(Nu	 Aborted
i(Rtwritetos_exit(tsignumtframe((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytimmediate_exit4s
cCs=t|ƒ}tdkr*td|ƒanyê|sHtjd|ƒ}nˆ|d}d|kr‡td|jdddƒ|fƒ‚dS|d}|r¸tjd|d|d|ƒ}ntjd|d|ƒ}xA|D]9}|jd	d
ƒ}|jdd
ƒ}|jdƒ}	q×W|d
rÙ|jr|	dkrBdj	|	ƒnd
}	|ddkr|j
rvdj	||ƒ}
q½|}
n>|ddkr¤dj	||ƒ}
n|ddkr½|}
ntdj	|
|	ƒƒqn:|rñdj	||ƒn|}
tdj	|
|dƒƒ‚Wn"tk
r8}t|j
ƒ‚nXdS(Ntoptionsiu/uHWARNING: / in container name; you might have meant '%s' instead of '%s'.u it	containertobjectsu	containeruuobjectuattemptsusuccessu [after {0} attempts]uactionu
delete_objectu{0}/{1}udelete_segmentudelete_containeru{0}{1}uError Deleting: {0}: {1}uerror(tdicttswift_deletetNoneRtdeletet	Exceptiontreplacetgettverbosetformattyes_alltprintRtvalue(targsR%t_optstdel_iterR&R'trtctotatpterr((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt	st_delete9sN

	

	!				cCs¸|jdkrd|_n|jrEt|ƒdkrEtdƒ‚n|jsZt|_n|jr„t|ƒdkr„tdƒ‚n|r•|js¤|r½|jr½tdt	t
tƒ‚dSt|ƒj
ƒ}tdkrítd|ƒany™|stjd|ƒ}n|d}d|krJtd	|jdd
dƒ|fƒ‚dS|d}|srtj|d|ƒ}ntj||d|ƒ}xø|D]ð}|jdkrÚd|krÚ|d}xÂ|D]}t|ƒqÃWq‘|d
rß|jr|d}	|d|	}
|d|	}|d}|d}
|d}||	}||}d}|drkd||
|f}n*t|
ƒ||}d||
||f}|d}|dkrÅtd|||fƒqÜtd||fƒqq‘|d}|d}|d}|d}t|tƒrl|jdkrB|jrBtd|ƒq‘n|jd krltd!||ƒ‚q‘qlntd"|||ƒ‚q‘WWn+tk
rž}‚ntk
r³}‚nXdS(#Nu-iiu0-o option only allowed for single file downloadsu:Please use -o option for single file downloads and renamesuUsage: %s download %s
%sR%u/uHWARNING: / in container name; you might have meant '%s' instead of '%s'.u iucontentsusuccessu
start_timeuheaders_receiptu
auth_end_timeufinish_timeuread_lengthuattemptsi@Bu	pseudodiru.auth %.3fs, headers %.3fs, total %.3fs, pseudou1auth %.3fs, headers %.3fs, total %.3fs, %.3f MB/supathu%s [%s after %d attempts]u%s [%s]uerroru	containeruobjecti0uSkipped identical file '%s'i”uObject '%s/%s' not foundu$Error downloading object '%s/%s': %s(tout_fileR/tlenR,tprefixtFalset
remove_prefixt
out_directoryR1tBASENAMEtst_download_optionstst_download_helpR(tcopytswift_downloadR*RtdownloadR-R2tfloatt
isinstanceRthttp_statustskip_identicalR(R4R%R5t	down_iterR&R'tdowntcontentstchunkt
start_timetheaders_receiptt	auth_timetfinish_timetread_lengthtattemptst
total_timet	down_timet_megattime_strtspeedtpathterrortobjte((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_downloadosž	 	





	













		cCsOd„}|jr(|r(tdƒ‚nt|ƒjƒ}|dr^|jdƒt|d<n|jr‹|jr‹|jr‹tdƒ‚dSt	dkr©td|ƒa	ny(t	jƒ}|d}|dd	}Wnt
k
ré}‚nXd
|d<d}tƒ}	tdkr!td|ƒany|rc|d}|d
}d|ksP|rctdƒ‚dSnxÇtr,tjd|d|ƒ}
t}xŒ|
D]„}|drt}x(|dD]}
|	j|
jdƒƒq²Wt|dƒ|kròt|	ƒS|
jdƒ|d<q‘q‘|d‚q‘W|rft|	ƒSqfWgSWnt
k
rJ}‚nXdS(NcSsqd}}|jddƒ}xñ|dD]å}|jdƒ}|jrr|jrrt|jd|jdƒƒƒq'|s2|jdƒ}t||jƒ}|jdƒ}	||	7}y=|jdƒ}
tt|
jd	ƒƒƒ}td
|ƒ}Wnt	k
rd}nX|j
std|	|||fƒqnÐ|jdƒ}
|jd
ƒ}|
dkr±|jdƒ}t||jƒ}|jdƒjdƒ\}}|jdƒd}n(d}t||jƒ}d}}|
}|j
std|||||fƒn||7}q'W|js"|jrm|sTtdt|tƒt||jƒfƒqmtt||jƒƒndS(Niu	containerulistingunameusubdirubytesucountumetaux-timestampu%Y-%m-%d %H:%M:%Su????-??-?? ??:??:??u%5s %s %s %sucontent_typeu
last_modifieduTu.uu%s %10s %8s %24s %su%5s %s(
R.R*tlongthumanR2RRRJRt	TypeErrorttotalstsplittTrue(R%tstatsttotal_countttotal_bytesR&titemt	item_namet
item_bytestbyte_strtcounttmetatutct	datestamptsubdirtcontent_typetdatetxtime((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt_print_statsÞsX
"


		
	u--d option only allowed for container listingsuhumanulongu*Listing totals only works with -l or --lh.R%ucapabilitiesuswiftuaccount_listing_limituumarkeriiu/uUsage errorR&usuccessulistingunameuerror(t	delimiterR,R(RGtpopRgReRbRct	swift_capR*RtcapabilitiesRtsett
swift_listtlistRAtaddR.R?(R4R%RwR5tcapabilities_resultR{taccount_listing_limitR`R&titem_settstats_parts_gent	gen_emptyRhRk((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_listÚsb	4


	

	

	


cCs€t|ƒjƒ}tdkr0td|ƒany3|sftjd|ƒ}|dsb|d‚n|S|d}d|kr¥td|jdddƒ|fƒ‚dS|d}|sètjd	|d|ƒ}|dsä|d‚n|St|ƒdkrM|dg}tjd	|d
|d|ƒ}x:|D]}|dr@|S|‚q,Wntdt	t
tƒ‚Wntk
r{}‚nXdS(NR%usuccessuerroriu/uHWARNING: / in container name; you might have meant '%s' instead of '%s'.u iR&R'uUsage: %s stat %s
%s(
R(RGt
swift_statR*RtstatR,R-R?RDtst_stat_optionstst_stat_helpR(R4R%R5tstat_resultR&R'tstat_resultsR`((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_statSsF



	


	


cCs|js$|js$|js$|jr:|r:tdƒ‚nt|ƒjƒ}tdkrjt	d|ƒany	|sˆtj
d|ƒ}n×|d}d|krÏtd|djdddƒ|dfƒ‚dS|d}|rGt|ƒdkr+|dg}tj
d|d	|d|ƒ}t
|ƒ}q_td
tttƒ‚dSntj
d|d|ƒ}|dsr|‚nWntk
r‹}‚nXdS(Nu6-r, -w, -t, and -k options only allowed for containersR%iu/uHWARNING: / in container name; you might have meant '%s' instead of '%s'.u iR&R'uUsage: %s post %s
%susuccess(tread_aclt	write_acltsync_totsync_keyR,R(RGt
swift_postR*RtpostR-R?tnextRDtst_post_optionstst_post_helpR(R4R%R5tresultR&R'tresults_iteratorR`((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_post‚s@
'

	

c
Cs»|d}|d}|jdk	rRt|ƒdkrEtdƒ‚dS|d}n|jryt|jƒWn|tk
rêy3dj|jdjƒƒ}t|jd ƒ}Wntk
rÏtdƒ‚dSXt	d||ƒ|_nXt|jƒdkrtdƒ‚dSnt
|ƒjƒ}tdkrCt
d	|ƒany[g}g}	x¬|D]¤}
t|
ƒr{|j|
ƒqYt|
ƒríxst|
ƒD]R\}}}
||
s½|	j|ƒq”|jg|
D]}t||ƒ^qʃq”WqYtd
|
ƒ‚qYW|jdk	rŽg|D]*}t|d|j||jdƒƒ^q}g|	D]7}tdd|j||jdƒd	itd6ƒ^qN}	nxtj|||	d	|ƒD]î}|d
r«|jrYd|kr–|ddkr–d|krtd|d|dfƒqVd|kr(t|dƒqVd|krVtd|d|dfƒqVq–q™|d}d|krD|ddkrDt|tƒr%|drÃd|dkrÃd|ddjƒ}q/djd„|j|jfDƒƒ}|jr|r|d7}n||jd 7}nd|}n
d|}td||ƒ‚q™td |ƒ‚t|tƒoo|jd!k}|r™|jdkr™td"ƒ‚q™q«q«WWnt k
r¶}‚nXdS(#Niiu+object-name only be used with 1 file or diruBKMGiÿÿÿÿuInvalid segment sizeiusegment-size should be positiveR%uLocal file '%s' not foundtobject_nameu
dir_markerusuccessuattemptsuobjectu%s [after %d attempts]u
for_objectu
%s segment %su
segment_indexuerroruactionucreate_containeruheadersuX-Storage-Policyu with Storage Policy %su css|]}t|ƒVqdS(N(tstr(t.0tx((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pys	<genexpr>su: i<u: %su*Warning: failed to create container '%s'%su%siu<Consider using the --segment-size option to chunk the object(!R™R*R?R,tsegment_sizetintt
ValueErrortindextupperRšR(RGtswift_uploadRRtappendR	RtextendR
RR-RgtuploadR/R2RKRtstripRLthttp_reasonthttp_response_contentR(R4R%R&tfilest	orig_pathtsize_modt
multiplierR5tobjstdir_markerstft_dirt_dst_fst_fR9tdR7R^tmsgt	too_largeR`((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt	st_upload¯sª


	



04D	


	


	


cCsd„}|r:t|ƒdkr:tdtttƒ‚dSt|ƒjƒ}tdkrjt	d|ƒany~t|ƒdkr¥|d}tj
|ƒ}|d}ntj
ƒ}|d}|di|dd6ƒ|d=|d	|ƒWntk
r}‚nXdS(
NcSs—xt|jƒdd„ƒD]s\}}td||fƒ|rtdƒx@t|jƒdd„ƒD] \}}td||fƒqhWqqWdS(NtkeycSs|dS(Ni((Rœ((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt<lambda>/su%s: %su	 Options:cSs|dS(Ni((Rœ((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyR¹4su  %s: %s(tsortedtitemsR2(tnameR{tfeatureR%R¸R3((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt_print_compo_cap-s
iuUsage: %s capabilities %s
%sR%iucapabilitiesuCoreuswiftuAdditional middleware(R?R,RDtst_capabilities_optionstst_capabilities_helpR(RGRzR*RR{R(R4R%R¾R5turlR€R{R`((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_capabilities*s*	



cCskt|ƒ}|jdkr!|jdkrrtdt|jƒƒtdt|jƒƒtdt|jƒƒqgtdt|jƒƒtdt|jƒƒtd	t|jƒƒx­t|j	ƒƒD]P\}}|rÊ|j
d
ƒrÊ|dkrÊtd
|jƒt|ƒfƒqÊqÊWnFt|ƒ}|j
ƒ\}}tdt|ƒƒtdt|ƒƒdS(Niu1u1.0uexport ST_AUTH=%suexport ST_USER=%suexport ST_KEY=%su!export OS_IDENTITY_API_VERSION=%suexport OS_AUTH_VERSION=%suexport OS_AUTH_URL=%suos_uos_auth_urlu
os_optionsuexport %s=%suexport OS_STORAGE_URL=%suexport OS_AUTH_TOKEN=%s(u1u1.0(uos_auth_urlu
os_options(tvarsR/tauth_versionR2tsh_quotetauthtuserR¸RºR»t
startswithR¡Rtget_auth(R4R%R5tktvtconnRÁttoken((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pytst_authQs$	*cCsÑ|d}t|ƒdkr5tdtttƒ‚dS|d \}}}}yt|ƒ}Wntk
r{tdƒ‚dSX|jƒdkr¥td
|jƒƒnt	||||d|j
ƒ}t|ƒdS(
NiiuUsage: %s tempurl %s
%suSeconds must be an integeruGETuPUTuHEADuPOSTuDELETEuLWARNING: Non default HTTP method %s for tempurl specified, possibly an errortabsolute(uGETuPUTuHEADuPOSTuDELETE(R?R,RDtst_tempurl_optionstst_tempurl_helpRžRŸR¡R2Rtabsolute_expiry(R4R%tmethodtsecondsR]R¸RÁ((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt
st_tempurlhs"
	
(
udeleteudownloadulistupostustatuuploaducapabilitiesuinfoutempurluauth(Kt
__future__RRtloggingtsignaltsockettoptparseRRRtosRRRR!tos.pathRR	R
tsixRtsysRtsys_argvR
RttimeRRtswiftclientRtswiftclient.utilsRRRtswiftclient.multithreadingRtswiftclient.exceptionsRRtclient_versiontswiftclient.serviceRRRRtswiftclient.command_helpersRRRtshlexRRÅtImportErrortpipesRDtcommandsR*R}R†R¢RHR)R‘RzR$R=RaR…RŒR˜R·RÂRÎRÕ(((s]/home/tvault/.virtenv/lib/python2.7/site-packages/contego/nova/extension/driver/vaultswift.pyt<module>sP"
		6	k	y	/	-	{	'