ó
¡ôXc @ s( d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z d d l m
Z
d d l Z d d l m
Z
d d l m Z d d l m Z d d l m Z m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m Z d d l Z d e
e e
f d „ ƒ YZ! d S( iÿÿÿÿN( t Arg( t
ArgumentErrort ServerError( t FileTransferProgressBarMixin( t
EC2Request( t DescribeConversionTasks( t
S3AccessMixin( t ImportManifestt ImportImagePart( t DeleteObject( t
HeadObject( t GetObject( t PutObject( t AWSErrort ResumeImportc
B sþ e Z d Z e d d d d d ƒe d d d e d d ƒe d
d d d d
e d d d d ƒe d d d d
e d d d e j ƒe d d
e d e j ƒe d d d d e j ƒe d d d d e j ƒg Z d „ Z d „ Z
d „ Z d „ Z d „ Z
RS( s) Perform the upload step of an import taskt sourcet metavart FILEt helps3 file containing the disk image to import (required)s -ts --taskt requireds. the ID of the import task to resume (required)s -xs --expirest DAYSt typet defaulti s\ how long the import manifest should remain valid, in
days (default: 30 days)s --part-sizet MiBi
s --user-threadss --dont-verify-formatt actiont
store_trues --dry-runc C s_ t j | ƒ | j ƒ | j j d ƒ s9 d | j d <n | j d d k r[ t d ƒ ‚ n d S( Nt expiresi i s- argument -x/--expires: value must be positive( R t configuret configure_s3_accesst argst getR ( t self( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyR C s
c C s5 | j j d ƒ r d S| j j d t ƒ r> d G| j d GHn t j | d | j d g ƒ} | j ƒ d d } | d | j d k sŽ t ‚ | j d ƒ rª | d } n | d
d d } t j j | j d ƒ } | j
| | ƒ } | j d
j d } | | k r,t
d j | j d | | ƒ ƒ ‚ n | j d j | d d ƒ \ } } } t j j g | j D] } t j j | j ƒ ^ qfƒ }
x¤ | j D]™ } d j | | j f ƒ } t j | d | j d d | j d d | ƒ} y | j ƒ Wq”t k
r,}
|
j d k r&| j | | |
ƒ q-‚ q”Xq”Wd S( Nt dry_runt
show_progresss Uploading image for taskt taskt ConversionTaskIdt conversionTasksi t conversionTaskIdt importVolumet importInstancet volumesR iÿÿÿÿi s` file "{0}" is not the same size as the file the import started with (expected: {1}, actual: {2})t
s3_servicet imaget importManifestUrlt /t servicet autht s3_autht pathi” ( R R t FalseR t
from_othert maint AssertionErrort euca2oolst utilt get_filesizet% _ResumeImport__get_or_create_manifestt image_partst endR t formatt resolve_url_to_locationt build_progressbar_label_templatet osR0 t basenamet keyt joinR
R
t status_codet _ResumeImport__upload_part( R t desc_convR" t
vol_containert file_sizet manifestt file_size_from_manifestt _t buckett partt pbar_label_templatet part_s3patht head_reqt err( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyR3 L sD
.c C sº | j d j | d d ƒ \ } } } d j | | f ƒ } y t j d d ƒ x } t j | d | j d d | j d d
| d | d t ƒ} | j ƒ | j j
d
ƒ | j d ƒ t j
| ƒ } Wd QXWnç t k
rµ}
|
j d k r¯| j j
d ƒ | j | | ƒ } t j ƒ } t j j | t j j | ƒ ƒ } t | d ƒ }
| j |
d t ƒWd QXt j | d
| d | d t ƒ} | j ƒ t j | ƒ t j | ƒ q¶‚ n X| S( NR) R* R+ R, t max_sizei R- R. R/ R t destR! s. using existing import manifest from the serveri i” s creating new import manifestt wt pretty_print( R R< RA t tempfilet SpooledTemporaryFileR R2 R1 R3 t logt infot seekR t read_from_fileobjR RB t _ResumeImport__generate_manifestt mkdtempR> R0 R? t opent dump_to_fileobjt TrueR t removet rmdir( R RE RF RI RJ R@ t manifest_s3patht manifest_destfilet get_reqRG RO t tempdirt manifest_filenamet
manifest_filet put_req( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt __get_or_create_manifestz s@
c C sO | j j d ƒ p d } | d } | j d j | d d ƒ \ } } } | j d d ƒ d } t d
| j j ƒ } | d d | _ t j | d | j d d
| j d d d j
| | f ƒ ƒ}
|
j | ƒ | _ t
| d d ƒ | _ t
| d d ƒ | _ | j j d ƒ pd d } x)t t j j d | | ƒ ƒ D] \ } }
t ƒ } | | _ |
| _ t |
| | ƒ d | _ d j | t j j | j d ƒ | ƒ | _ d j
| | j f ƒ } t j |
d | ƒ} t j |
d | ƒ} t j |
d | ƒ}
| j | ƒ | _ | j | ƒ | _! |
j | ƒ | _" | j# j$ | ƒ q>W| S( NR i i€Q R) R* R+ R, i i t loglevelR; R- R. R/ R0 t sizet volumet part_sizei
i i s {0}/{1}.part.{2}R i (% R R R< t rsplitR RV t levelt file_formatR R2 RA t get_presigned_url2t self_destruct_urlt intt
image_sizet volume_sizet enumeratet sixt movest rangeR t indext startt minR: R; R> R0 R? R@ R
R t head_urlt get_urlt
delete_urlR9 t append( R RE RF t dayst timeoutRI RJ R@ t
key_prefixRG t
delete_reqRl Ry t
part_startRK t part_pathRN Rc ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt __generate_manifest s>
%c C së | j j d | | j | j ƒ | j d t j j | j ƒ d | j d ƒ } t
| j d ƒ … } | j | j ƒ t
j | d | j d d | j d d | d
| d | j | j d d | j j d t ƒ d
| ƒ} | j ƒ SWd QXd S( Ns Uploading part %s (bytes %i-%i)t fnameRy i R R- R) R. R/ RQ Rj R! t progressbar_label( RV RW Rz R: R; R> R0 R? R@ Ry R\ R RX R R2 R R1 R3 ( R RK RM RL t part_pbar_labelR Rg ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt
__upload_part¾ s % ( t __name__t
__module__t DESCRIPTIONR R^ Rr t argparset SUPPRESSt ARGSR R3 R8 RZ RC ( ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyR 0 s$ . # !(" RŽ t os.pathR> RT t requestbuilderR t requestbuilder.exceptionsR R t requestbuilder.mixinsR Rv t euca2ools.commands.ec2R t. euca2ools.commands.ec2.describeconversiontasksR t euca2ools.commands.ec2.mixinsR t! euca2ools.commands.ec2.structuresR R t" euca2ools.commands.s3.deleteobjectR t euca2ools.commands.s3.headobjectR
t euca2ools.commands.s3.getobjectR t euca2ools.commands.s3.putobjectR t euca2ools.exceptionsR
t euca2ools.utilR5 R ( ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt <module> s"