U EZh@sdZddlZddlZddlmZddlmZmZm Z m Z m Z da da eZdZddZdd Zd d Zd d ZddZGdddZddZddZddZdS)a6 This file contains private functionality for interacting with the AWS Common Runtime library (awscrt) in boto3. All code contained within this file is for internal usage within this project and is not intended for external consumption. All interfaces contained within are subject to abrupt breaking changes. N)Session)BotocoreCRTCredentialsWrapperBotocoreCRTRequestSerializerCRTTransferManageracquire_crt_s3_process_lockcreate_s3_crt_clientZboto3cCs|d|d}tf|S)zCreate a CRT S3 Client for file transfer. Instantiating many of these may lead to degraded performance or system resource exhaustion. T)regionZuse_sslZcrt_credentials_provider)r)sessionconfig region_name cred_providerZcreate_crt_client_kwargsr P/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/boto3/crt.py_create_crt_client*s rcCst||ddS)N)r Z endpoint_url)r)r r r r r_create_crt_request_serializer8srcKs(t|}|}tt|||||||S)zFCreate boto3 wrapper class to manage crt lock reference and S3 client.)rZto_crt_credentials_provider CRTS3Clientr)r r r credentialslockkwargsZ cred_wrapperr r r r_create_crt_s3_client>s rcCsLtt}|dkrdSt}|jj}|}t||}t|||||}||fS)N)NN)rPROCESS_LOCK_NAMErmetar _get_credentialsrr)clientr rr r r serializer s3_clientr r r#_initialize_crt_transfer_primativesLs rc Cs2t$tdkr$t||\}}|a|aW5QRXtSN)CLIENT_CREATION_LOCK CRT_S3_CLIENTrBOTOCORE_CRT_SERIALIZER)rr rrr r rget_crt_s3_client_sr!c@seZdZdZddZdS)ra This wrapper keeps track of our underlying CRT client, the lock used to acquire it and the region we've used to instantiate the client. Due to limitations in the existing CRT interfaces, we can only make calls in a single region and does not support redirects. We track the region to ensure we don't use the CRT client when a successful request cannot be made. cCs||_||_||_||_dSr) crt_client process_lockrr )selfr"r#rr r r r__init__xszCRTS3Client.__init__N)__name__ __module__ __qualname____doc__r%r r r rrns rcCsF|dkr dS|}|dkr dSt||j}|jj|jk}|oD|S)z Boto3 client must use same signing region and credentials as the CRT_S3_CLIENT singleton. Otherwise fallback to classic. NF)rcompare_identityZget_frozen_credentialsr rr r)r crt_s3_client boto3_credsZis_same_identityZis_same_regionr r ris_crt_compatible_requestsr-cCsNz |}Wntjjk r$YdSX|j|jkoH|j|jkoH|j|jk}|S)NF) botocore exceptionsZNoCredentialsErrorZ access_keyZ access_key_idZ secret_keyZsecret_access_keytokenZ session_token)r,Z crt_s3_credsZ crt_credsZis_matching_identityr r rr*s    r*cCs$t||}t||r t|jtSdS)z8Create a CRTTransferManager for optimized data transfer.N)r!r-rr"r )rr r+r r rcreate_crt_transfer_managers  r1)r) threadingZbotocore.exceptionsr.Zbotocore.sessionrZs3transfer.crtrrrrrrr Lockrrrrrrr!rr-r*r1r r r r s"