Index: tools/telemetry/third_party/gsutil/third_party/boto/boto/roboto/awsqueryservice.py |
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/boto/roboto/awsqueryservice.py b/tools/telemetry/third_party/gsutil/third_party/boto/boto/roboto/awsqueryservice.py |
deleted file mode 100644 |
index 9bf95ac2be01ca8a611857f3cefc15371d077d0b..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/third_party/gsutil/third_party/boto/boto/roboto/awsqueryservice.py |
+++ /dev/null |
@@ -1,122 +0,0 @@ |
-from __future__ import print_function |
-import os |
-import urlparse |
-import boto |
-import boto.connection |
-import boto.jsonresponse |
-import boto.exception |
-from boto.roboto import awsqueryrequest |
- |
-class NoCredentialsError(boto.exception.BotoClientError): |
- |
- def __init__(self): |
- s = 'Unable to find credentials' |
- super(NoCredentialsError, self).__init__(s) |
- |
-class AWSQueryService(boto.connection.AWSQueryConnection): |
- |
- Name = '' |
- Description = '' |
- APIVersion = '' |
- Authentication = 'sign-v2' |
- Path = '/' |
- Port = 443 |
- Provider = 'aws' |
- EnvURL = 'AWS_URL' |
- |
- Regions = [] |
- |
- def __init__(self, **args): |
- self.args = args |
- self.check_for_credential_file() |
- self.check_for_env_url() |
- if 'host' not in self.args: |
- if self.Regions: |
- region_name = self.args.get('region_name', |
- self.Regions[0]['name']) |
- for region in self.Regions: |
- if region['name'] == region_name: |
- self.args['host'] = region['endpoint'] |
- if 'path' not in self.args: |
- self.args['path'] = self.Path |
- if 'port' not in self.args: |
- self.args['port'] = self.Port |
- try: |
- super(AWSQueryService, self).__init__(**self.args) |
- self.aws_response = None |
- except boto.exception.NoAuthHandlerFound: |
- raise NoCredentialsError() |
- |
- def check_for_credential_file(self): |
- """ |
- Checks for the existence of an AWS credential file. |
- If the environment variable AWS_CREDENTIAL_FILE is |
- set and points to a file, that file will be read and |
- will be searched credentials. |
- Note that if credentials have been explicitelypassed |
- into the class constructor, those values always take |
- precedence. |
- """ |
- if 'AWS_CREDENTIAL_FILE' in os.environ: |
- path = os.environ['AWS_CREDENTIAL_FILE'] |
- path = os.path.expanduser(path) |
- path = os.path.expandvars(path) |
- if os.path.isfile(path): |
- fp = open(path) |
- lines = fp.readlines() |
- fp.close() |
- for line in lines: |
- if line[0] != '#': |
- if '=' in line: |
- name, value = line.split('=', 1) |
- if name.strip() == 'AWSAccessKeyId': |
- if 'aws_access_key_id' not in self.args: |
- value = value.strip() |
- self.args['aws_access_key_id'] = value |
- elif name.strip() == 'AWSSecretKey': |
- if 'aws_secret_access_key' not in self.args: |
- value = value.strip() |
- self.args['aws_secret_access_key'] = value |
- else: |
- print('Warning: unable to read AWS_CREDENTIAL_FILE') |
- |
- def check_for_env_url(self): |
- """ |
- First checks to see if a url argument was explicitly passed |
- in. If so, that will be used. If not, it checks for the |
- existence of the environment variable specified in ENV_URL. |
- If this is set, it should contain a fully qualified URL to the |
- service you want to use. |
- Note that any values passed explicitly to the class constructor |
- will take precedence. |
- """ |
- url = self.args.get('url', None) |
- if url: |
- del self.args['url'] |
- if not url and self.EnvURL in os.environ: |
- url = os.environ[self.EnvURL] |
- if url: |
- rslt = urlparse.urlparse(url) |
- if 'is_secure' not in self.args: |
- if rslt.scheme == 'https': |
- self.args['is_secure'] = True |
- else: |
- self.args['is_secure'] = False |
- |
- host = rslt.netloc |
- port = None |
- l = host.split(':') |
- if len(l) > 1: |
- host = l[0] |
- port = int(l[1]) |
- if 'host' not in self.args: |
- self.args['host'] = host |
- if port and 'port' not in self.args: |
- self.args['port'] = port |
- |
- if rslt.path and 'path' not in self.args: |
- self.args['path'] = rslt.path |
- |
- def _required_auth_capability(self): |
- return [self.Authentication] |
- |