{kfKdZddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl mZdd lmZ dd lZdd lmZn#e$rd xZZYnwxYwd Zed dZeeZGddeZd S)z"AWS DynamoDB result store backend.) namedtuple)sleeptime)AnyDict) _parse_url)ImproperlyConfigured) get_logger)KeyValueStoreBackendN) ClientError)DynamoDBBackendDynamoDBAttributename data_typeceZdZdZdZdZdZdZdZdZ dZ e ddZ e d d Z e d d Ze d d Ze dd ZdZdZd(fd Zd(dZdZdZdZdZdZdZdZd)dZdZdZdede ee!ffdZ"dede ee!ffdZ#d Z$e%d!Z&d"Z'd#Z(d$Z)d%Z*de+de,fd&Z-fd'Z.xZ/S)*rzAWS DynamoDB result backend. Raises: celery.exceptions.ImproperlyConfigured: if module :pypi:`boto3` is not available. celeryr NTidSrresultB chord_countN timestampttlctj|i|||_|p|j|_tst dd}d}d}|t |\}} } } } } }| }| }|du}|du}||krt d|}| dkrDd| |_d|_t d |jn| |_|j j j}|d}|r||_t|d |j|_t|d |j|_|d |j}|rJ t||_n4#t&$r'}td |d ||d}~wwxYw| p|j|_|j|j|jf|_d|_|r|||dSdS)NzBYou need to install the boto3 library to use the DynamoDB backend.Fz6You need to specify both the Access Key ID and Secret. localhostzhttp://localhost:z us-east-1z*Using local-only DynamoDB endpoint URL: {}dynamodb_endpoint_urlreadwrite ttl_secondszTTL must be a number; got "")exc_info) access_key_idsecret_access_key)super__init__url table_nameboto3r parse_url endpoint_url aws_regionloggerwarningformatappconfgetintread_capacity_unitswrite_capacity_unitstime_to_live_seconds ValueErrorerror _key_field _value_field_timestamp_field_available_fields_client _get_client)selfr)r*argskwargsaws_credentials_givenaws_access_key_idaws_secret_access_keyschemeregionportusernamepasswordtablequeryaccess_key_givensecret_key_given_getconfig_endpoint_urlre __class__s X/var/www/html/nettyfy-visnx/env/lib/python3.11/site-packages/celery/backends/dynamodb.pyr(zDynamoDBBackend.__init__Cs$)&)))$7 %&$%% %!&  $ ?# CFFD(HeU!) $, !0< 4D@ #333*"###%5 !$$$>$>$>!"-@GG) #)8=$D"&$'>"?"? " 8$7!'* ,((D $ ), -))D %))M4+DEEC 03CD--!LL**  ,484E!.1 <#DL  % % ' ' '}}***,,,##%%%|c|jj|jjdg|j|jjddg|j|jddS)z=Get the boto3 structure describing the DynamoDB table schema.) AttributeName AttributeTypeHASH)raKeyType)ReadCapacityUnitsWriteCapacityUnits)AttributeDefinitions TableName KeySchemaProvisionedThroughput)r;rrr*r6r7rAs rT_get_table_schemaz!DynamoDBBackend._get_table_schemasm &*_%9%)_%>% &*_%9%&*%=&*&?&&   r_c|} |j|jS#t$r}|jddd}|dkr|jjd i|}t d |j| dt d |j|cYd }~S|d }~wwxYw) z=Create table if not exists, otherwise return the description.rhErrorCodeUnknownResourceNotFoundExceptionz*DynamoDB Table {} did not exist, creating.ACTIVEz#DynamoDB Table {} is now available.N) rlr?describe_tabler*r responser4 create_tabler/infor1_wait_for_table_status)rA table_schemarR error_codetable_descriptions rTrZz$DynamoDBBackend._get_or_create_tables#--//  <...II I   G,00CCJ888$=DL$=$M$M $M$M! @GG ++H555 9@@ )((((((' s"6 DB3C;3D9C;;Dc*|jdn |jdkS)zReturn the desired Time to Live config. - True: Enable TTL on the table; use expiry. - False: Disable TTL on the table; don't use expiry. - None: Ignore TTL on the table; don't use expiry. Nr)r8rks rTr[zDynamoDBBackend._has_ttls!08tt*a/ 0r_cxd}g}t|D],}t|j|s||-|rwtdd|tdd|dS)z:Verify boto support for the DynamoDB Time to Live methods.)update_time_to_livedescribe_time_to_livezdboto3 method(s) {methods} not found; ensure that boto3>=1.9.178 and botocore>=1.12.178 are installed,)methodsz#boto3 method(s) {methods} not foundN) listhasattrr?appendr/r:r1joinAttributeError)rArequired_methodsmissing_methodsmethods rTr\z%DynamoDBBackend._validate_ttl_methodss  +,, / /F4<00 /&&v...   LLJ&HH_55    !5<<HH_55=   r_c@|j||ddS)zBGet the boto3 structure describing the DynamoDB TTL specification.)Enabledra)rhTimeToLiveSpecification)r*r[)rA ttl_attr_names rT_get_ttl_specificationz&DynamoDBBackend._get_ttl_specifications0==??!.((   r_c` |j|j}n#t$r~}|jddd}|jddd}t d|j|||d}~wwxYw|S)NrnrorprqMessagezJError describing Time to Live on DynamoDB table {table}: {code}: {message})rLcodemessage) r?rr*r rvr4r/r:r1)rA descriptionrRr{ error_messages rT_get_table_ttl_descriptionz*DynamoDBBackend._get_table_ttl_descriptions ,<</=KK   G,00CCJJw/33IyIIM LL$fo%   G s # B+A9B&&B+c |}|dd}|dvrq|dd}|rN||jjkr>td|dkrdnd|j |Sn|d vrS|s>td|d krd nd |j |Sn4td||j|dkr|n |jj} |j j di| |}t d|j||jj|S#t$r}|jddd}|jddd}td|rdnd|j|||d}~wwxYw)z,Enable or disable Time to Live on the table.TimeToLiveDescriptionTimeToLiveStatus)ENABLEDENABLINGraz5DynamoDB Time to Live is {situation} on table {table}rzalready enabledzcurrently being enabled) situationrL)DISABLED DISABLINGrzalready disabledzcurrently being disabledzWUnknown DynamoDB Time to Live status {status} on table {table}. Attempting to continue.)statusrL)rzUDynamoDB table Time to Live updated: table={table} enabled={enabled} attribute={attr})rLenabledattrrorprqrzHError {action} Time to Live on DynamoDB table {table}: {code}: {message}enabling disabling)actionrLrrNrt)rr[ _ttl_fieldrr/debugr1r*r0r?rrrxr rvr4r:) rArr cur_attr_name attr_name specificationrRr{rs rTr]zDynamoDBBackend._set_table_ttl-s5577 456HI , , ,34_E }} ' DO$888LL+f!Y..#4"36"o '& 0 0 0==?? # '&++103/ #" #$ NN<fo   L$y00MMdo6J  z1DynamoDBBackend._item_to_dict..s@    J V,UZ8I   r_)r>)rArs `rT _item_to_dictzDynamoDBBackend._item_to_dictsA  % %I    /    r_c*|S)N)r@rks rTrYzDynamoDBBackend.clients!!!r_ct|}||}|jjdi|}||}||jjSNrt)rrrYget_itemrr4r<r)rArrequest_parameters item_responseitems rTr4zDynamoDBBackend.getsg#hh!66s;;, ,BB/ABB !!-00xx).///r_ctt|}|||}|jjdi|dSr)rrrYput_item)rArrrs rTsetzDynamoDBBackend.set sE#hh!66sEBB 22122222r_c fd|DS)Nc:g|]}|Srt)r4)rrrAs rT z(DynamoDBBackend.mget..s#...# ...r_rt)rAkeyss` rTmgetzDynamoDBBackend.mgets........r_crt|}||}|jjdi|dSr)rrrY delete_item)rArrs rTdeletezDynamoDBBackend.deletesC#hh!66s;; 55"455555r_ct|}||}|jjdi|}|d|jj|jj}t|S)zimplements_incrr(r@rlrZr[r\rrr]ryrrrrrrrrpropertyrYr4rrrbytesr5rr __classcell__)rSs@rTrrsJJL ""<<rsL((""""""333333222222''''''&&&&&&LLL///////EKKK J24IJJ H  G0G0G0G0G0*G0G0G0G0G0s = A A