ó
¡ôXc @ sà d d l Z d d l Z d d l Z d d l m Z d d l 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 d d l m Z d d
l m Z d e e e f d „ ƒ YZ d S(
iÿÿÿÿN( t Arg( t
ArgumentError( t FileTransferProgressBarMixin( t open_pipe_fileobjs( t waitpid_in_thread( t DownloadBundle( t BundleDownloadingMixin( t UnbundleStream( t S3Requestt DownloadAndUnbundlec B sw e Z d Z e d d d d d d d d d d ƒe d
d d d ƒg Z d
„ Z d „ Z d „ Z d „ Z d „ Z RS( sŽ Download and unbundle a bundled image from the cloud
The key used to unbundle the image must match a certificate that was used to bundle it.s -ds
--destinationt destt metavars (FILE | DIR)t defaultt .t helpsO where to place the unbundled image
(default: current directory)s -ks --privatekeys˜ file containing the private key to decrypt the bundle
with. This must match a certificate used when bundling the
image.c C sZ t j | ƒ | j j d ƒ s | j j d ƒ } | j j d ƒ rS | | j d <q d t j k r{ t j d ƒ | j d <q | r‘ | | j d <q t d ƒ ‚ n t j
j t j
j | j d ƒ ƒ | j d <t j
j
| j d ƒ st d j | j d ƒ ƒ ‚ n t j
j | j d ƒ s<t d j | j d ƒ ƒ ‚ n | j j d | j d ƒ d S( Nt
privatekeys private-keyt
userregiont EC2_PRIVATE_KEYs. missing private key; please supply one with -ks% private key file '{0}' does not exists$ private key file '{0}' is not a files private key: %s( R t configuret argst gett configt get_user_optiont ost environt getenvR t patht
expandusert
expandvarst existst formatt isfilet logt debug( t selft config_privatekey( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyR 9 s(
c C s² | j d d k r3 t j | j d <t | j d <n{ t | j d t j ƒ r® t j j | j d ƒ r‡ t j j
| j d | j ƒ } n
| j d } t | d ƒ | j d <| Sd S( NR
t -t
show_progresst w(
R t syst stdoutt Falset
isinstancet sixt string_typesR R t isdirt joint
image_namet open( R" t manifestt image_filename( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyt __open_destS s
c C sÅ | j | j d | j d ƒ} t ƒ \ } } z | j | ƒ Wd | j ƒ X| j | ƒ } t j | d | d | j d d | j d | j
d | j d | j d | j j
d t ƒ ƒ} | j ƒ | S(
Nt privkey_filenameR t sourceR
t enc_keyt enc_ivt
image_sizet sha1_digestR% ( t fetch_manifestt serviceR R t. _DownloadAndUnbundle__create_download_pipelinet closet _DownloadAndUnbundle__open_destR t
from_otherR6 R7 R8 t image_digestR R) t main( R" R1 t download_out_rt download_out_wR2 t unbundlestream( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyRA a s
c C s† t j | d | d | j d d | j j d ƒ d | j j d ƒ d t ƒ} t j d | j ƒ } | j ƒ t | j
ƒ | j ƒ d S( NR
t bucketR1 t local_manifestR% t target( R R? R R R) t multiprocessingt ProcessRA t startR t pidR= ( R" t outfilet downloadbundlet downloadbundle_p( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyt __create_download_pipeliner s
c C s8 | r4 | j d j ƒ t j j ƒ k r4 d G| GHn d S( NR
t Wrote( R t filenoR' R( ( R" R2 ( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyt print_result} s "(
t __name__t
__module__t DESCRIPTIONR t ARGSR R> RA R< RR ( ( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyR + s ( RH t os.pathR R' t requestbuilderR t requestbuilder.exceptionsR t requestbuilder.mixinsR R+ t euca2ools.bundle.utilR R t( euca2ools.commands.bundle.downloadbundleR t euca2ools.commands.bundle.mixinsR t( euca2ools.commands.bundle.unbundlestreamR t euca2ools.commands.s3R R ( ( ( sQ /usr/lib/python2.7/site-packages/euca2ools/commands/bundle/downloadandunbundle.pyt <module> s