/
lib
/
python2.7
/
site-packages
/
requestbuilder
/
Upload File
HOME
� � GXc @@ s] d d l m Z m Z d d l Z d d l Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l 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 e f d � � YZ d e f d � � YZ d d � Z d � Z d e f d � � YZ! d e f d � � YZ" d S( i ( t absolute_importt print_functionN( t partial( t EMPTYt PARAMS( t BaseCommand( t ServerError( t BaseService( t aggregate_subclass_fields( t parse_listdelimited_aws_xmlt BaseRequestc B@ s� e Z d Z e Z d Z d Z d Z e f Z d d d � Z e d � � Z e j d � � Z e d � � Z e d � � Z d � Z d � Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s The basis for a command line tool that represents a request. The data for this request are stored in a few instance members: - method: the HTTP method to use (e.g. 'GET'). Defaults to self.METHOD. - path: the path to append to the service's path (e.g. 'sub/dir') - headers: a dict of HTTP headers - params: a dict of query parameters - body: a string or file object containing a request body, or a dict to pass to the server as form data This specialization of BaseCommand that implements main() as a three-step process: - preprocess(): do any processing needed before sending the request, such as parsing complex command line arguments and storing them in self.params, self.headers, and so forth. - send(): send this request to the server using the data stored in its attributes, parse it using self.parse_result(), and return it - postprocess(): given a parsed response, do any processing needed before main() returns the response. Most requests need only implement preprocess(). Requests whose workflows involve sending other requests often do so in postprocess(), where the result of the request is known. Important members of this class, in addition to those inherited from BaseCommand, include: - SERVICE_CLASS: a class corresponding to the web service in use - AUTH_CLASS: a class corresponding to the authentication method to use, if any - NAME: a string representing the name of this request. This defaults to the class's name. - METHOD: the HTTP method to use by default t GETc K@ sq | j | _ d | _ i | _ i | _ d | _ i | _ d | _ t | _ | | _ | | _ t j | | � d S( Nt ( t METHODt methodt Nonet patht headerst paramst bodyt filest responset Falset _BaseRequest__configuredt _BaseRequest__autht _BaseRequest__serviceR t __init__( t selft servicet autht kwargs( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR O s c C@ sD | j r= | j d k r= | j | j d | j j �| _ n | j S( Nt loglevel( R t AUTH_CLASSR t configt logt level( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR a s $c C@ s | | _ d S( N( R ( R t newval( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR i s c C@ sD | j r= | j d k r= | j | j d | j j �| _ n | j S( NR ( R t SERVICE_CLASSR R! R" R# ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR m s c K@ sU | j d | j � | j d | j � | j d | j j � | d | j | � } | S( NR R R R! ( t setdefaultR R R" R# R! ( t clst otherR t new( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt from_othert s c C@ so t j | � } | j d k r= | j t | j j d � � n | j d k rk | j t | j j d � � n | S( Nt ARGS( R t collect_arg_objsR R t extendR t __class__R ( R t arg_objs( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR, } s c C@ sa t j | � | j d k r5 | j j j | j � n | j d k r] | j j j | j � n d S( N( R t distribute_argsR R t argst updateR ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR0 � s c C@ sX t j | � | j d k r, | j j � n | j d k rK | j j � n t | _ d S( N( R t configureR R R t TrueR ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR3 � s c C@ s | j p | j j S( N( t NAMER. t __name__( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt name� s c C@ s | j s | j j d � n t | j p+ i � } | j d | j j � � yb | j j d | j d | j d | d | j d | j d | j d | j � | _ | j | j � SWn] t k r } | j | _ y | j d k r� | j j n Wn t k r� n X| j | � SXd S( Ns1 send() called before configure(); bugs may results User-AgentR R R R t dataR R ( R R" t warnt dictR R& t suitet get_user_agentR t send_requestR R R R R R R t parse_responseR R t contentt RuntimeErrort handle_server_error( R R t err( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt send� s$ c C@ sg | j j d d i t d 6�| j j | j j d i t d 6�| j j d � | j j d � � d S( Ns -- response content -- t extrat appends -- end of response content --s result: failure( R" t debugR4 R t textt info( R RB ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRA � s #c C@ s | S( N( ( R R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR> � s c K@ sy | j j d d i t d 6�t | j j d � � �. } t | | j t j � } | | | � } Wd QX| j j d � | S( Ns -- response content -- RD RE i @ s -- end of response content --( R" RF R4 t _IteratorFileObjAdapterR t iter_contentt _ReadLoggingFileWrappert loggingt DEBUG( R R t parse_funcR t content_fileobjt logged_fileobjt parsed_response( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt log_and_parse_response� s c C@ s' | j � | j � } | j | � | S( s The main processing method for this type of request. In this method, inheriting classes generally populate self.headers, self.params, and self.body with information gathered from self.args or elsewhere, call self.send, and return the response. ( t preprocessRC t postprocess( R R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt main� s c C@ s d S( N( ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRS � s c C@ s d S( N( ( R R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRT � s c C@ s� t | t � rl d j t j j t j d � | j � � } t | d t j �| j r\ � n t j d � n t j | | � d S( Ns {0}: {1}i t filei ( t isinstanceR t formatt osR t basenamet syst argvt format_for_clit printt stderrRF t exitR t handle_cli_exception( R RB t msg( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRa � s N( R6 t __module__t __doc__R R% R R R5 R R t DEFAULT_ROUTESR t propertyR t setterR t classmethodR* R, R0 R3 R7 RC RA R> RR RU RS RT Ra ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR $ s. " t AWSQueryRequestc B@ se e Z d Z g Z g Z d � Z d � Z e d � � Z d � Z d � Z d d � Z e d � Z RS( c C@ sy t j | | | � | j ru | j d d d d d d d d d d t t d | j ��| j � | _ d | j d <n d S( Ns --filtert metavars NAME=VALUEt actionRE t destt filterst helps, restrict results to those that meet criteriat typet filter_objs( N( R t _populate_parsert FILTERSt add_argumentR t _parse_filtert# _AWSQueryRequest__build_filter_helpt epilogR t _arg_routes( R t parserR/ ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRq � s c C@ sU t j | � d | j k rQ t | j j d � � | j d <| j f | j d <n d S( NRm t Filter( R t process_cli_argsR1 t _process_filterst popR Rw ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRz � s c C@ s | j S( N( R7 ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRk � s c C@ s3 | j } t j | j � } | j | j � } | j | d <| j pL | j j | d <t | � } xI | D]A } | j � j d � rf t d d i d � d 6� � | | <qf qf W| j j d | � | j j � d k r� | j j d � | | _ i | _ n | j j d � | | _ z t j | � SWd | | _ Xd S( Nt Actiont Versiont passwordt REDACTEDc S@ s d S( Ns <redacted>( ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt <lambda> s t __repr__s parameters: %st POSTs) sending flattened parameters as form datas, sending flattened parameters as query string( ( R t copyt deepcopyt flatten_paramsRk t API_VERSIONR R: t lowert endswithRo R" RH R t upperRF R R RC ( R t orig_paramsR t redacted_paramst key( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRC s( ' c C@ sK | j | t d | j �} t | � d k s3 t � | t | j � � d S( Nt list_tagsi i ( RR R t LIST_TAGSt lent AssertionErrort listt keys( R R t response_dict( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR> s c C@ s� i } | d k r nnt | t � rRx\t j | � D]\ } } | r[ d j | | � } n t | � } t | t � s� t | t � r� | j | j | | � � q4 t | t � r� t | � j � | | <q4 t | t � r� | j � | | <q4 t | t � r t | � | | <q4 | s | d k r2t | � | | <q4 | t k r4 d | | <q4 q4 Wn1t | t � rmx t | d � D]� \ } } | r�d j | | � } n t | � } t | t � s�t | t � r�| j | j | | � � qqt | t � rt | � j � | | <qqt | t � r(| j � | | <qq| s:| d k rMt | � | | <qq| t k rqd | | <qqqqWn t d | j j � � | S( s Given a possibly-nested dict of args and an arg routing destination, transform each element in the dict that matches the corresponding arg routing table into a simple dict containing key-value pairs suitable for use as query parameters. This implementation flattens dicts and lists into the format given by AWS query APIs, which use dotted lists of dict keys and list indices to indicate nested structures. Keys with non-boolean, non-zero values that evaluate as false are ignored. To include an empty string as a parameter, pass EMPTY (the object, not the string) as its value. Examples: in: {'InstanceId': 'i-12345678', 'PublicIp': '1.2.3.4'} out: {'InstanceId': 'i-12345678', 'PublicIp': '1.2.3.4'} in: {'RegionName': ['us-east-1', 'us-west-1']} out: {'RegionName.1': 'us-east-1', 'RegionName.2': 'us-west-1'} in: {'Filter': [{'Name': 'image-id', 'Value': ['ami-12345678']}, {'Name': 'instance-type', 'Value': ['m1.small', 't1.micro']}], 'InstanceId': ['i-24680135']} out: {'Filter.1.Name': 'image-id', 'Filter.1.Value.1': 'ami-12345678', 'Filter.2.Name': 'instance-type', 'Filter.2.Value.1': 'm1.small', 'Filter.2.Value.2': 't1.micro', 'InstanceId.1': 'i-24680135'} s {0}.{1}i R i s non-flattenable type: N( R RW R: t sixt iteritemsRX t strR� R2 R� t boolR� RV t readt floatR t enumeratet TypeErrorR. R6 ( R R1 t prefixt flattenedR� t valt prefixed_keyt i_itemt item( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR� & sJ " c C@ s� d t j k r) d t j k r) | r) d Sd g } xB| j D]7} | j t j k rZ q< q< | j r_| j j d � \ } } } | j d � r� | j d � r� | d t j | � } n | j } t | j � d k r d j | j � } t j d t d | d d d � } n: | j d | j � t j d t d d d d d d � } | j | j | � � q< | j d | j � q< Wd j | � S( s� Return a pre-formatted help string for all of the filters defined in self.FILTERS. The result is meant to be used as command line help output. s -hs --helpR s allowed filter names:s t i s {0:<20} t fix_sentence_endingst initial_indentt subsequent_indenti s ( R[ R\ Rr Rn t argparset SUPPRESSt partitiont startswitht textwrapt dedentR� R7 RX t TextWrapperR4 RE R- t wrapt join( R t forcet helplinest filter_objt firstt _t restR? t firstlinet wrapper( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt __build_filter_helpu s. % N( R6 Rc R R� Rr R� Rq Rz Rf Rk RC R> R� R Ru ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRi � s Oc C@ sf g | p g D] } | j | � r | ^ q } | sU d j | � } t j | � � n | d j | � S( s Given a "key=value" string given as a command line parameter, return a pair with the matching filter's dest member and the given value after converting it to the type expected by the filter. If this is impossible, an ArgumentTypeError will result instead. s" "{0}" matches no available filtersi ( t matches_argvalRX R� t ArgumentTypeErrort convert( t filter_strRp t objRb ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRt � s c C@ s~ i } x; | p i D]- \ } } | j | g � | | j | � q Wg t j | � D] \ } } i | d 6| d 6^ qT } | S( s� Change filters from the [(key, value), ...] format given at the command line to [{'Name': key, 'Value': [value, ...]}, ...] format, which flattens to the form the server expects. t Namet Value( R& RE R� R� ( t cli_filterst filter_argsR� R� R7 t valuesRm ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR{ � s 3RI c B@ sG e Z d � Z d � Z d � Z e d � � Z d � Z d d � Z RS( c C@ s( | | _ g | _ t | _ d | _ d S( Ni ( t _sourcet _buflistR t _closedt _len( R t source( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR � s c C@ s | S( N( ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt __enter__� s c G@ s | j � d S( N( t close( R R1 ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt __exit__� s c C@ s | j S( N( R� ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt closed� s c C@ s" | j s d | _ t | _ n d S( N( R� R R� R4 ( R ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR� � s i����c C@ s2 | d k s | d k rc x! | j D] } | j j | � q" Wd j | j � } g | _ d | _ n� x` | j | k r� y8 t | j � } | j j | � | j t | � 7_ Wqf t k r� Pqf Xqf Wd j | j � } t | � | } g | _ d | _ | d k r.| | g | _ | | _ | | } n | S( Ni R ( R R� R� RE R� R� t nextR� t StopIteration( R t sizet chunkt resultt extra_len( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR� � s, ( R6 Rc R R� R� Rf R� R� R� ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRI � s RK c B@ s e Z d � Z d d � Z RS( c C@ s | | _ | | _ | | _ d S( N( t fileobjt loggerR# ( R R� R� R# ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR � s i����c C@ s9 | j j | � } | j j | j | d i t d 6�| S( NRD RE ( R� R� R� R" R# R4 ( R R� R� ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyR� � s #( R6 Rc R R� ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyRK � s (# t __future__R R R� R� t functoolsR RL t os.pathRY R[ R� t warningsR� t requestbuilderR R t requestbuilder.commandR t requestbuilder.exceptionsR t requestbuilder.serviceR t requestbuilder.utilR t requestbuilder.xmlparseR R Ri R Rt R{ t objectRI RK ( ( ( s: /usr/lib/python2.7/site-packages/requestbuilder/request.pyt <module> s* �� 0