ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

fix for issue #10422. outputs informative error message when AWS credentials are not available

Browse source
This commit is contained in:
Steve Gargan 2015-03-15 12:20:34 +00:00
parent 22304afd1d
commit fbff0449ce
1 changed files with 35 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
plugins/inventory/ec2.py
View file

@ -334,23 +334,24 @@ class Ec2Inventory(object):
self.write_to_cache(self.inventory, self.cache_path_cache) self.write_to_cache(self.inventory, self.cache_path_cache)
self.write_to_cache(self.index, self.cache_path_index) self.write_to_cache(self.index, self.cache_path_index)
def connect(self, region):
''' create connection to api server'''
if self.eucalyptus:
conn = boto.connect_euca(host=self.eucalyptus_host)
conn.APIVersion = '2010-08-31'
else:
conn = ec2.connect_to_region(region)
# connect_to_region will fail "silently" by returning None if the region name is wrong or not supported
if conn is None:
raise Exception("region name: %s likely not supported, or AWS is down. connection to region failed." % region)
return conn
def get_instances_by_region(self, region): def get_instances_by_region(self, region):
''' Makes an AWS EC2 API call to the list of instances in a particular ''' Makes an AWS EC2 API call to the list of instances in a particular
region ''' region '''
try: try:
if self.eucalyptus: conn = self.connect(region)
conn = boto.connect_euca(host=self.eucalyptus_host)
conn.APIVersion = '2010-08-31'
else:
conn = ec2.connect_to_region(region)
# connect_to_region will fail "silently" by returning None if the region name is wrong or not supported
if conn is None:
print("region name: %s likely not supported, or AWS is down. connection to region failed." % region)
sys.exit(1)
reservations = [] reservations = []
if self.ec2_instance_filters: if self.ec2_instance_filters:
for filter_key, filter_values in self.ec2_instance_filters.iteritems(): for filter_key, filter_values in self.ec2_instance_filters.iteritems():
@ -363,6 +364,9 @@ class Ec2Inventory(object):
self.add_instance(instance, region) self.add_instance(instance, region)
except boto.exception.BotoServerError, e: except boto.exception.BotoServerError, e:
if e.error_code == 'AuthFailure':
self.display_auth_error()
if not self.eucalyptus: if not self.eucalyptus:
print "Looks like AWS is down again:" print "Looks like AWS is down again:"
print e print e
@ -379,23 +383,33 @@ class Ec2Inventory(object):
for instance in instances: for instance in instances:
self.add_rds_instance(instance, region) self.add_rds_instance(instance, region)
except boto.exception.BotoServerError, e: except boto.exception.BotoServerError, e:
if e.error_code == 'AuthFailure':
self.display_auth_error()
if not e.reason == "Forbidden": if not e.reason == "Forbidden":
print "Looks like AWS RDS is down: " print "Looks like AWS RDS is down: "
print e print e
sys.exit(1) sys.exit(1)
def get_instance(self, region, instance_id): def display_auth_error(self):
''' Gets details about a specific instance ''' ''' Raise an error with an informative message if there is an issue authenticating'''
if self.eucalyptus: errors = ["Authentication error retrieving ec2 inventory."]
conn = boto.connect_euca(self.eucalyptus_host) if None in [os.environ.get('AWS_ACCESS_KEY_ID'), os.environ.get('AWS_SECRET_ACCESS_KEY')]:
conn.APIVersion = '2010-08-31' errors.append(' - No AWS_ACCESS_KEY_ID or AWS_SECRET_ACCESS_KEY environment vars found')
else: else:
conn = ec2.connect_to_region(region) errors.append(' - AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY environment vars found but may not be correct')
# connect_to_region will fail "silently" by returning None if the region name is wrong or not supported boto_paths = ['/etc/boto.cfg', '~/.boto', '~/.aws/credentials']
if conn is None: boto_config_found = list(p for p in boto_paths if os.path.isfile(os.path.expanduser(p)))
print("region name: %s likely not supported, or AWS is down. connection to region failed." % region) if len(boto_config_found) > 0:
sys.exit(1) errors.append(" - Boto configs found at '%s', but the credentials contained may not be correct" % ', '.join(boto_config_found))
else:
errors.append(" - No Boto config found at any expected location '%s'" % ', '.join(boto_paths))
raise Exception('\n'.join(errors))
def get_instance(self, region, instance_id):
conn = self.connect(region)
reservations = conn.get_all_instances([instance_id]) reservations = conn.get_all_instances([instance_id])
for reservation in reservations: for reservation in reservations:
@ -785,4 +799,3 @@ class Ec2Inventory(object):
# Run the script # Run the script
Ec2Inventory() Ec2Inventory()