⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
paginate.cpython-312.pyc
Pe k d dl Z d dlZd dlZd dlmZ d dlZd dlmZ d dlm Z m Z ej e Z G d d Z G d d Z G d d Z G d d Z G d d Z G d d Zy) N)tee)PaginationError) merge_dictsset_value_from_jmespathc . e Zd ZdZd Zd Zd Zd Zd Zy) TokenEncoderab Encodes dictionaries into opaque strings. This for the most part json dumps + base64 encoding, but also supports having bytes in the dictionary in addition to the types that json can handle by default. This is intended for use in encoding pagination tokens, which in some cases can be complex structures and / or contain bytes. c t j | }t j |j d j d S # t t f$ r2 | j |g \ }}||d< t j | }Y sw xY w)a. Encodes a dictionary to an opaque string. :type token: dict :param token: A dictionary containing pagination information, particularly the service pagination token(s) but also other boto metadata. :rtype: str :returns: An opaque string boto_encoded_keysutf-8) jsondumps TypeErrorUnicodeDecodeError_encodebase64 b64encodeencodedecode)selftoken json_string encoded_token encoded_keyss 3/usr/lib/python3/dist-packages/botocore/paginate.pyr zTokenEncoder.encode& s 4 **U+K 2 27 ;<CCGLL -. 4*.,,ub*A 'M< 2>M- . **]3K 4s A >B B c t |t r| j || S t |t r| j || S t |t r| j || S |g fS )z@Encode bytes in given data, keeping track of the path traversed.) isinstancedict _encode_dictlist _encode_listbytes _encode_bytesr datapaths r r zTokenEncoder._encodeC sb dD !$$T40 0 d #$$T40 0 e $%%dD1 18O c g }g }t | D ]B \ }}||gz }| j || \ }} |j | |j | D ||fS )z@Encode any bytes in a list, noting the index of what is encoded.) enumerater appendextend) r r$ r% new_dataencodedivaluenew_path new_value new_encodeds r r zTokenEncoder._encode_listN sc !$HAuqczH%)\\%%B "I{ OOI & NN; ' ( r& c i }g }|j D ]6 \ }}||gz }| j || \ }} |||< |j | 8 ||fS )z@Encode any bytes in a dict, noting the index of what is encoded.)itemsr r* ) r r$ r% r+ r, keyr. r/ r0 r1 s r r zTokenEncoder._encode_dictY sb **,JCse|H%)\\%%B "I{ %HSM NN; ' ' r& c P t j | j d |gfS )z Base64 encode a byte string.r )r r r r# s r r" zTokenEncoder._encode_bytesd s% %,,W5v==r& N) __name__ __module__ __qualname____doc__r r r r r" r& r r r s! M: ! !>r& r c ( e Zd ZdZd Zd Zd Zd Zy) TokenDecoderzDecodes token strings back into dictionaries. This performs the inverse operation to the TokenEncoder, accepting opaque strings and decoding them into a useable form. c t j |j d j d }t j | }|j dd }||S | j || S )ad Decodes an opaque string to a dictionary. :type token: str :param token: A token string given by the botocore pagination interface. :rtype: dict :returns: A dictionary containing pagination information, particularly the service pagination token(s) but also other boto metadata. r r N)r b64decoder r r loadspop_decode)r r r decoded_tokenr s r r zTokenDecoder.decodep sh &&u||G'<=DDWM ;/ %(()<dC << |< <r& c |D ]K }| j || }t j |j d }| j ||| M |S )z&Find each encoded value and decode it.r ) _path_getr r> r _path_set)r r r r4 r, decodeds r rA zTokenDecoder._decode sL CnnUC0G &&w~~g'>?G NN5#w / r& c " |}|D ] }|| } |S )zReturn the nested data at the given path. For instance: data = {'foo': ['bar', 'baz']} path = ['foo', 0] ==> 'bar' r: )r r$ r% dsteps r rD zTokenDecoder._path_get s! D$A r& c > | j ||dd }|||d < y)zSet the value of a key in the given data. Example: data = {'foo': ['bar', 'baz']} path = ['foo', 1] value = 'bin' ==> data = {'foo': ['bar', 'bin']} N)rD )r r$ r% r. containers r rE zTokenDecoder._path_set s( NN4cr3 # $r(r& N)r6 r7 r8 r9 r rA rD rE r: r& r r< r< i s =." $r& r< c e Zd Zd Zd Zy)PaginatorModelc |d | _ y )N pagination)_paginator_config)r paginator_configs r __init__zPaginatorModel.__init__ s !1,!? r& c \ | j | }|S # t $ r t d|z w xY w)Nz*Paginator for operation does not exist: %s)rQ KeyError ValueError)r operation_namesingle_paginator_configs r get_paginatorz PaginatorModel.get_paginator sF &*&<&<^&L # '& <~M s +N)r6 r7 r8 rS rY r: r& r rN rN s @'r& rN c e Zd ZdZd Zed Zed Zej d Zed Z d Z d Z d Z d Z d Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zy) PageIteratorzAn iterable object to paginate API results. Please note it is NOT a python iterator. Use ``iter`` to wrap this as a generator. c || _ || _ || _ || _ || _ || _ || _ | | _ | | _ | | _ d | _ || _ i | _ t | _ t | _ y N)_method _input_token _output_token _more_results _result_keys _max_items _limit_key_starting_token _page_size _op_kwargs _resume_token_non_aggregate_key_exprs_non_aggregate_partr _token_encoderr< _token_decoder) r method input_token output_token more_results result_keysnon_aggregate_keys limit_key max_itemsstarting_token page_size op_kwargss r rS zPageIterator.__init__ s{ ' ) ) '## - ## !(:%#% *n *nr& c | j S r] rb r s r rq zPageIterator.result_keys r& c | j S )z&Token to specify to resume pagination.)rh rz s r resume_tokenzPageIterator.resume_token s !!!r& c > t |t st d|z d|v rt | j dgz }nt | j }t |j }||k( r!| j j | | _ y t d|z )NBad starting token: %sboto_truncate_amount) r r rV sortedr_ keysrk r rh )r r. token_keys dict_keyss r r} zPageIterator.resume_token s %& 5 => > !U * 1 15K4L LMJ 1 12J5::<( "!%!4!4!;!;E!BD 5 => >r& c | j S r] )rj rz s r non_aggregate_partz PageIterator.non_aggregate_part s '''r& c # x K | j }d }| j D ci c] }|d }}| j | j d }d}d}| j d }d}| j | | j | } | j | } |r3| j | j | || }d}| j | nd}|j | } | g } t | } d} | j || z | j z } | dkD r| j | || || | y | || z }| j | }t d |j! D ry | j || j k( r|| _ y |||k( rd| }t% | | j' || |}Dc c}w w)Nr TFc 3 $ K | ] }|d u y wr] r: ).0ts r <genexpr>z(PageIterator.__iter__.<locals>.<genexpr>5 s >*=QqDy*=s z(The same next token was received twice: message)rg r_ re _parse_starting_tokenrq _inject_starting_params _make_request_extract_parsed_response_handle_first_request _record_non_aggregate_key_valuessearchlenrc _truncate_response_get_next_tokenallvaluesr} r _inject_token_into_kwargs)r current_kwargsprevious_next_tokenr4 next_token total_items first_requestprimary_result_keystarting_truncationresponseparsedcurrent_responsenum_current_responsetruncate_amountr s r __iter__zPageIterator.__iter__ s "+/+<+<=+<Cc4i+< = + 335a8J ! - -a 0 $$^4)).9H228<F ''3*.*D*D 24G+' !& 55f= '(# 1 8 8 @ '#% #&'7#8 O* "66 H "''&#' 33 ! 1 1& 9 >**;*;*=>>OO/#t6 )3D%'3+z9"", / *'::..~zJ&0#{ >s F: F5FF:c # K t j | }| D ]2 }|j | }t |t r |E d{ /| 4 y7 w)a Applies a JMESPath expression to a paginator Each page of results is searched using the provided JMESPath expression. If the result is not a list, it is yielded directly. If the result is a list, each element in the result is yielded individually (essentially implementing a flatmap in which the JMESPath search is the mapping function). :type expression: str :param expression: JMESPath expression to apply to each page. :return: Returns an iterator that yields the individual elements of applying a JMESPath expression to each page of results. N)jmespathcompiler r r )r expressioncompiledpageresultss r r zPageIterator.searchK sO ##J/D ood+G'4(""" #s AAA Ac & | j di |S )Nr: )r^ )r r s r r zPageIterator._make_requestd s t||-n--r& c |S r] r: )r r s r r z%PageIterator._extract_parsed_responseg s r& c i }| j D ]* }|j | }t ||j | , || _ y r] )ri r r r rj )r r rr r results r r z-PageIterator._record_non_aggregate_key_valuesj sG 77J &&x0F #"J$9$96 8 $6 r& c | j %| j d }| j || | j | j || j < y y )Nr )re r r rf rd )r rw r s r r z$PageIterator._inject_starting_paramss sX + 335a8J * *9j A ?? & *. Idoo & 'r& c ^ |j D ] \ }}| |dk7 r|||< ||v s||= y )NNone)r3 )r rw r namer s r r z&PageIterator._inject_token_into_kwargs s= %++-KD%!"' $" dO .r& c | j d }|j | }t |t t f r||d }nd }t ||j | | j D ]q }||k( r |j | }t |t rg }n.t |t rd}nt |t t f rd}nd }t ||j | s |S )N r ) r r r r strr r rq intfloat) r r r r all_datar$ r sample empty_values r r z"PageIterator._handle_first_request s # 8 8 :1 =%,,V4 hs , / 01DD (:(E(EtL %%E**\\&)F&$' FC( FS%L1 " #FE,<,<k J & #"r& c |j | }|g }t | |z }|d | }t ||j | ||z |d< || _ y )Nr )r r r r r} ) r r r r r r originalamount_to_keep truncateds r r z PageIterator._truncate_response so &,,V4 H X 8 _n- &119 0 0 )* 'r& c | j | j j | si S i }t | j | j D ]# \ }}|j | }|r|||< d ||< % |S r] )ra r zipr` r_ )r r next_tokensro input_keyr s r r z PageIterator._get_next_token s )%%,,V4 '* 1 1( #L) &,,V4J )3 I&)- I&( r& c t | t | j }t || j D cg c] \ }}t || c}}S c c}}w r] )r r rq r ResultKeyIterator)r teed_resultsr- result_keys r result_key_itersz PageIterator.result_key_iters sX 4T%5%5!67 "%\43C3C!D !D : a ,!D s Ac i }| D ] }|}t |t rt | dk( r|d }| j D ] }|j | }||j | }|t ||j | Bt |t r|j | dt |t t t f st ||j ||z t || j | j | j |d< |S )N r NextToken)r tupler rq r r r r r* r r r r r r} )r complete_resultr r result_expression result_valueexisting_values r build_full_resultz PageIterator.build_full_result s HD (E*s8}/A { &*%5%5! 1 7 7 = ' !2!9!9/!J!)+')44$ lD1")),7 sE3.?@+')44& 51 &6 T OT%<%<= (+/+<+<OK ( r& c | j y | j } | j j | }d}d|v r|j d }|d= ||fS # t t f$ r | j \ }}Y ||fS w xY w)Nr r )re rl r getrV r _parse_starting_token_deprecated)r r indexs r r z"PageIterator._parse_starting_token s ' )) H ,,33J?JE%3"'=> 56 5 I& H $ E E G J5 Hs 5A "A<;A<c t j d| j z | j y| j j d }g }d}t | t | j dz k( r t |j }|D ]* }|dk( r|j d |j | , | j | |fS # t $ r | j g}Y Zw xY w)z| This handles parsing of old style starting tokens, and attempts to coerce them into the new style. zCAttempting to fall back to old starting token parser. For token: %sN___r r r ) logdebugre splitr r_ r r@ rV r) "_convert_deprecated_starting_token)r partsr r parts r r z-PageIterator._parse_starting_token_deprecated s .. / '$$**51 u:T . ./!3 3 /EIIK( Dv~!!$'!!$' 66zBEII / --. /s 4C C('C(c 6 t | }t | j }||kD rt d| j z ||k r9t j d t ||z D ] }|j d t t | j | S )zb This attempts to convert a deprecated starting token into the new style. r zaOld format starting token does not contain all input tokens. Setting the rest, in order, as None.N) r r_ rV re r r ranger) r r )r deprecated_tokenlen_deprecated_tokenlen_input_tokenr- s r r z/PageIterator._convert_deprecated_starting_token< s ##3 4 d / /0 / 1 58L8L LM M !O 3 II? ?-AAB ''- CC))+;<==r& N)r6 r7 r8 r9 rS propertyrq r} setterr r r r r r r r r r r r r r r r r: r& r r[ r[ s -< ! ! " " ? ? ( (M1^ 2.6 9$ #< '@" / b! J<>r& r[ c V e Zd ZeZd Zed Zd Zd Z d Z d Z d Z d Z d Zd Zy ) Paginatorc || _ || _ || _ | j | j | _ | j | j | _ | j | j | _ | j | j | _ | j | j | _ | j | j | _ y r] )_modelr^ _pagination_cfg_get_output_tokensr` _get_input_tokensr_ _get_more_results_tokenra _get_non_aggregate_keys_non_aggregate_keys_get_result_keysrb _get_limit_keyrd )r rm pagination_configmodels r rS zPaginator.__init__R s 0 ! 4 4T5I5I J 2 243G3G H ! 9 9$:N:N O#'#?#? $ ! 1 1$2F2F G --d.B.BCr& c | j S r] ry rz s r rq zPaginator.result_keys_ r{ r& c g }|j dg D ]& }|j t j | ( |S )Nrr )r r) r r )r configr r4 s r r z!Paginator._get_non_aggregate_keysc s9 :: 2B7C KK((- . 8 r& c g }|d }t |t s|g}|D ]& }|j t j | ( |S )Nro )r r r) r r )r r outputro s r r z Paginator._get_output_tokensi sH n- ,- (>L"F MM(**62 3 # r& c J | j d }t |t s|g}|S )Nrn )r r r )r r rn s r r zPaginator._get_input_tokensr s) **=9 +t,&-Kr& c T |j d }|t j | S y )Nrp )r r r )r r rp s r r z!Paginator._get_more_results_tokenx s, zz.1 ###L1 1 $r& c |j d }|7t |t s|g}|D cg c] }t j | }}|S y c c}w )Nr )r r r r r )r r r rks r r zPaginator._get_result_keys} sW ZZ - ! j$/ (\ 9CD2(**2.JD " Es A c $ |j d S )Nrs )r )r r s r r zPaginator._get_limit_key s zz+&&r& c | j | }| j | j | j | j | j | j | j | j |d |d |d | S )zCreate paginator object for an operation. This returns an iterable object. Iterating over this object will yield a single page of a response at a time. MaxItems StartingTokenPageSize) _extract_paging_paramsPAGE_ITERATOR_CLSr^ r_ r` ra rb r rd )r kwargs page_paramss r paginatezPaginator.paginate s} 11&9 %% LL $ $ OO # ( # r& c |j di }|j dd }| t | }|j dd }|| j t d | j j j }|j | j }|j dk( r t |t st | }n t | }||j dd |dS ) NPaginationConfigr r zTPageSize parameter is not supported for the pagination interface for this operation.r stringr )r r r ) r@ r r rd r r input_shapemembers type_namer r )r r r rt rv input_memberslimit_key_shapes r r z Paginator._extract_paging_params s "JJ'92 >%))*d; II%))*d; &% ? !KK 3 3 ; ;M + / / @O ((H4!)S1 #II N ! . 2 2?D I! r& N)r6 r7 r8 r[ r rS r rq r r r r r r r r r: r& r r r O sJ $ D ! ! 2 ' . r& r c e Zd ZdZd Zd Zy)r a Iterates over the results of paginated responses. Each iterator is associated with a single result key. Iterating over this object will give you each element in the result key list. :param pages_iterator: An iterator that will give you pages of results (a ``PageIterator`` class). :param result_key: The JMESPath expression representing the result key. c || _ || _ y r] )_pages_iteratorr )r pages_iteratorr s r rS zResultKeyIterator.__init__ s - $r& c # K | j D ]+ }| j j | }|g }|E d { - y 7 wr] )r r r )r r r s r r zResultKeyIterator.__iter__ sB ((Doo,,T2G ) s 4A >A N)r6 r7 r8 r9 rS r r: r& r r r s % r& r )r r logging itertoolsr r botocore.exceptionsr botocore.utilsr r getLoggerr6 r r r< rN r[ r r r: r& r <module>r sv / ?g!K> K>\A$ A$H ' ' Q> Q>h g g T r&