ó
¡ô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 s | 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 } | j d ƒ r | d } n | d d
d } t j j | j d ƒ } | j | | ƒ } | j
d j d
} | | k rt d j
| j d | | ƒ ƒ ‚ n | j d j | d d ƒ \ } } } t j j g | j
D] } t j j | j ƒ ^ qIƒ }
x¤ | j
D]™ } d j | | j f ƒ } t j | d | j d d | j d d | ƒ} y | j ƒ Wqwt k
r}
|
j d k r | j | | |
ƒ q‚ qwXqwWd S( Nt dry_runt
show_progresss Uploading image for taskt taskt ConversionTaskIdt conversionTasksi t 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 euca2oolst utilt get_filesizet% _ResumeImport__get_or_create_manifestt image_partst endR t formatt resolve_url_to_locationt build_progressbar_label_templatet osR/ 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.pyR2 L sB
.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: R? t tempfilet SpooledTemporaryFileR R1 R0 R2 t logt infot seekR t read_from_fileobjR R@ t _ResumeImport__generate_manifestt mkdtempR< R/ R= t opent dump_to_fileobjt TrueR t removet rmdir( R RC RD RG RH R> t manifest_s3patht manifest_destfilet get_reqRE RM 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 loglevelR9 R, R- R. R/ t sizet volumet part_sizei
i i s {0}/{1}.part.{2}R i (% R R R: t rsplitR RT t levelt file_formatR R1 R? t get_presigned_url2t self_destruct_urlt intt
image_sizet volume_sizet enumeratet sixt movest rangeR t indext startt minR8 R9 R< R/ R= R> R
R t head_urlt get_urlt
delete_urlR7 t append( R RC RD t dayst timeoutRG RH R> t
key_prefixRE t
delete_reqRj Rw t
part_startRI t part_pathRL Ra ( ( 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 fnameRw i R R, R( R- R. RO Rh R! t progressbar_label( RT RU Rx R8 R9 R< R/ R= R> Rw RZ R RV R R1 R R0 R2 ( R RI RK RJ t part_pbar_labelR Re ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt
__upload_part¾ s % ( t __name__t
__module__t DESCRIPTIONR R\ Rp t argparset SUPPRESSt ARGSR R2 R6 RX RA ( ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyR 0 s$ . # !(" RΠt os.pathR< RR t requestbuilderR t requestbuilder.exceptionsR R t requestbuilder.mixinsR Rt 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.utilR3 R ( ( ( sG /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/resumeimport.pyt <module> s"