a 1$eE@sdZddlZddlZddlmZmZeeZz ddl Z Wn e yZe ddZ Yn0GdddZ Gddde Z Gd d d e ZGd d d e ZGd dde ZGddde ZGddde ZdS)z+Abstraction for sessions in various clouds.N) parse_path UnparsedPathz>Could not import boto3, continuing with reduced functionality.c@sbeZdZdZeddZddZedddZed d Z ed d Z ed dZ eddZ dS)SessionzBase for classes that configure access to secured resources. Attributes ---------- credentials : dict Keys and values for session credentials. Notes ----- This class is not intended to be instantiated. cCstS) Determine if the given configuration has proper credentials Parameters ---------- cls : class A Session class. config : dict GDAL configuration as a dict. Returns ------- bool NotImplementedclsconfigr I/var/www/html/django/DPS/env/lib/python3.9/site-packages/fiona/session.pyhascredsszSession.hascredscCstSeGet credentials as GDAL configuration options Returns ------- dict rselfr r r get_credential_options1szSession.get_credential_optionsNcCs|s tS||SdS)aCreate a session object matching the foreign `session`. Parameters ---------- session : obj A foreign session object. cls : Session class, optional The class to return. Returns ------- Session N) DummySession)sessionr r r r from_foreign_session;szSession.from_foreign_sessioncCs|stSt|}t|ts |jr$tS|jdks8d|jvr^d|jvr^tdurNtSt dtSn:|jdksrd|jvrvt S|j drt S|jd krtStSdS) zFind the session class suited to the data at `path`. Parameters ---------- path : str A dataset path or identifier. Returns ------- class Zs3z amazonaws.comzX-Amz-SignatureNz4boto3 not available, falling back to a DummySession.Zossz aliyuncs.comz /vsiswift/az)rr isinstanceris_localschemepathboto3 AWSSessionloginfo OSSSession startswith SwiftSession AzureSession)rr r r cls_from_pathPs,   zSession.cls_from_pathcOst||i|S)aCreate a session object suited to the data at `path`. Parameters ---------- path : str A dataset path or identifier. args : sequence Positional arguments for the foreign session constructor. kwargs : dict Keyword arguments for the foreign session constructor. Returns ------- Session )rr#)rargskwargsr r r from_pathszSession.from_pathcOs(tdurt|i|St|i|SdS)aCreate an AWSSession if boto3 is available, else DummySession Parameters ---------- path : str A dataset path or identifier. args : sequence Positional arguments for the foreign session constructor. kwargs : dict Keyword arguments for the foreign session constructor. Returns ------- Session N)rrr)r$r%r r r aws_or_dummyszSession.aws_or_dummycOsJztj|i|}|jWn*tyDtdt|i|}Yn0|S)aCreate a session object suited to the environment. Parameters ---------- path : str A dataset path or identifier. args : sequence Positional arguments for the foreign session constructor. kwargs : dict Keyword arguments for the foreign session constructor. Returns ------- Session zACredentials in environment have expired. Creating a DummySession.)rr' credentials RuntimeErrorrwarningr)r$r%rr r r from_environs  zSession.from_environ)N) __name__ __module__ __qualname____doc__ classmethodr r staticmethodrr#r&r'r+r r r r rs     .  rc@s,eZdZdZddZeddZddZdS) rzmA dummy session. Attributes ---------- credentials : dict The session credentials. cOsd|_i|_dS)N)_sessionr()rr$r%r r r __init__szDummySession.__init__cCsdS)rTr rr r r r szDummySession.hascredscCsiSrr rr r r rsz#DummySession.get_credential_optionsN)r,r-r.r/r3r0r rr r r r rs   rc @s:eZdZdZd ddZeddZedd Zd d Z dS) rz=Configures access to secured resources stored in AWS S3. NFc Cs`|r ||_ntj|||||d|_| |_ttd||_||_|jsV|jrV|j nd|_ dS)aCreate a new AWS session Parameters ---------- session : optional A boto3 session object. aws_unsigned : bool, optional (default: False) If True, requests will be unsigned. aws_access_key_id : str, optional An access key id, as per boto3. aws_secret_access_key : str, optional A secret access key, as per boto3. aws_session_token : str, optional A session token, as per boto3. region_name : str, optional A region name, as per boto3. profile_name : str, optional A shared credentials profile name, as per boto3. endpoint_url: str, optional An endpoint_url, as per GDAL's AWS_S3_ENPOINT requester_pays : bool, optional True if the requester agrees to pay transfer costs (default: False) )aws_access_key_idaws_secret_access_keyaws_session_token region_name profile_nameAWS_NO_SIGN_REQUESTN) r2rrrequester_paysboolosgetenvunsigned endpoint_urlZget_credentials_creds) rrZ aws_unsignedr4r5r6r7r8r?r:r r r r3s$% zAWSSession.__init__cCsddh|S)rZAWS_ACCESS_KEY_IDZAWS_SECRET_ACCESS_KEYissubsetkeysrr r r r (szAWSSession.hascredscCszi}|jrD|j}|jr$|j|d<|jr4|j|d<|jrD|j|d<|jjrX|jj|d<|jrfd|d<|jrv|j|d<|S)!The session credentials as a dictr4r5r6 aws_regionZ requesterZaws_request_payerZaws_s3_endpoint) r@Zget_frozen_credentialsZ access_keyZ secret_keytokenr2r7r:r?)rresZ frozen_credsr r r r(:s       zAWSSession.credentialscCsB|jr*ddi}d|jvr&|jd|d<|Sdd|jDSdS)rr9YESrEZ AWS_REGIONcSsi|]\}}||qSr upper.0kvr r r \z5AWSSession.get_credential_options..N)r>r(items)roptsr r r rNs  z!AWSSession.get_credential_options) NFNNNNNNF r,r-r.r/r3r0r propertyr(rr r r r rs  8  rc@s:eZdZdZd ddZeddZeddZd d Z dS) GSSessionzJConfigures access to secured resources stored in Google Cloud Storage NcCsi|_|dur||jd<dS)zCreate new Google Cloude Storage session Parameters ---------- google_application_credentials: string Path to the google application credentials JSON file. Ngoogle_application_credentialsr@)rrVr r r r3bs zGSSession.__init__cCsd|vS)rZGOOGLE_APPLICATION_CREDENTIALSr rr r r r oszGSSession.hascredscCs|jSrDrWrr r r r(szGSSession.credentialscCsdd|jDS)rcSsi|]\}}||qSr rIrKr r r rOrPz4GSSession.get_credential_options..r(rQrr r r rsz GSSession.get_credential_options)NrSr r r r rU_s   rUc@s:eZdZdZd ddZeddZeddZd d Z dS) rzCConfigures access to secured resources stored in Alibaba Cloud OSS.NcCs|||d|_dS)atCreate new Alibaba Cloud OSS session Parameters ---------- oss_access_key_id: string, optional (default: None) An access key id oss_secret_access_key: string, optional (default: None) An secret access key oss_endpoint: string, optional (default: None) the region attached to the bucket )oss_access_key_idoss_secret_access_key oss_endpointNrW)rrZr[r\r r r r3szOSSSession.__init__cCsddh|S)rZOSS_ACCESS_KEY_IDZOSS_SECRET_ACCESS_KEYrArr r r r szOSSSession.hascredscCs|jSrXrWrr r r r(szOSSSession.credentialscCsdd|jDS)rcSsi|]\}}||qSr rIrKr r r rOrPz5OSSSession.get_credential_options..rYrr r r rsz!OSSSession.get_credential_options)NNNrSr r r r rs   rc@s:eZdZdZd ddZeddZeddZd d Z dS) r!zPConfigures access to secured resources stored in OpenStack Swift Object Storage.NcCsb|r|r||d|_nHddlm}|r.||_n||||d|_|jd|jdd|_dS)aaCreate new OpenStack Swift Object Storage Session. Three methods are possible: 1. Create session by the swiftclient library. 2. The SWIFT_STORAGE_URL and SWIFT_AUTH_TOKEN (this method is recommended by GDAL docs). 3. The SWIFT_AUTH_V1_URL, SWIFT_USER and SWIFT_KEY (This depends on the swiftclient library). Parameters ---------- session: optional A swiftclient connection object swift_storage_url: the storage URL swift_auth_token: the value of the x-auth-token authorization token swift_storage_url: string, optional authentication URL swift_user: string, optional user name to authenticate as swift_key: string, optional key/password to authenticate with Examples -------- >>> import rasterio >>> from rasterio.session import SwiftSession >>> fp = '/vsiswift/bucket/key.tif' >>> conn = Connection( ... authurl='http://127.0.0.1:7777/auth/v1.0', ... user='test:tester', ... key='testing' ... ) >>> session = SwiftSession(conn) >>> with rasterio.Env(session): >>> with rasterio.open(fp) as src: >>> print(src.profile) )swift_storage_urlswift_auth_tokenr) Connection)ZauthurluserkeyN)r@Zswiftclient.clientr_r2Zget_auth)rrr]r^Zswift_auth_v1_urlZ swift_userZ swift_keyr_r r r r3s1    zSwiftSession.__init__cCsddh|S)rZSWIFT_STORAGE_URLZSWIFT_AUTH_TOKENrArr r r r szSwiftSession.hascredscCs|jSrXrWrr r r r($szSwiftSession.credentialscCsdd|jDS)rcSsi|]\}}||qSr rIrKr r r rO1rPz7SwiftSession.get_credential_options..rYrr r r r)sz#SwiftSession.get_credential_options)NNNNNNrSr r r r r!s D  r!c@s:eZdZdZd ddZeddZedd Zd d Z dS) r"zNConfigures access to secured resources stored in Microsoft Azure Blob Storage.NFcCsVttd||_td||_|r0d|i|_n"|jsF|j|d|_n d|ji|_dS)aCreate new Microsoft Azure Blob Storage session Parameters ---------- azure_storage_connection_string: string A connection string contains both an account name and a secret key. azure_storage_account: string An account name azure_storage_access_key: string A secret key azure_unsigned : bool, optional (default: False) If True, requests will be unsigned. AZURE_NO_SIGN_REQUESTAZURE_STORAGE_ACCOUNTazure_storage_connection_string)azure_storage_accountazure_storage_access_keyrfN)r;r<r=r>storage_accountr@)rrerfrgZazure_unsignedr r r r37s zAzureSession.__init__cCs,d|vp*ddh|p*ddh|S)rZAZURE_STORAGE_CONNECTION_STRINGrdZAZURE_STORAGE_ACCESS_KEYrcrArr r r r [szAzureSession.hascredscCs|jSrXrWrr r r r(uszAzureSession.credentialscCs*|jrd|jdSdd|jDSdS)rrH)rcrdcSsi|]\}}||qSr rIrKr r r rOrPz7AzureSession.get_credential_options..N)r>rhr(rQrr r r rzs z#AzureSession.get_credential_options)NNNFrSr r r r r"4s $  r")r/loggingr<Z fiona.pathrr getLoggerr,rr ImportErrordebugrrrrUrr!r"r r r r s"     1+s2:i