mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
switch all salt.utils.boto* calls to __utils__ calls
This commit is contained in:
Daniel Wallace
parent
7e30f459c9
commit
59180e09a8
13 changed files with 178 additions and 194 deletions
|
|
@ -53,7 +53,6 @@ import time
|
|||
|
||||
# Import Salt libs
|
||||
from salt.exceptions import SaltInvocationError, CommandExecutionError
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.versions
|
||||
|
||||
|
|
|
|||
|
|
@ -54,7 +54,6 @@ import logging
|
|||
import time
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.versions
|
||||
from salt.exceptions import SaltInvocationError
|
||||
|
|
|
|||
|
|
@ -82,7 +82,6 @@ import datetime
|
|||
|
||||
# Import Salt libs
|
||||
from salt.ext import six
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.json
|
||||
import salt.utils.versions
|
||||
|
|
@ -182,7 +181,7 @@ def _find_apis_by_name(name, description=None,
|
|||
apis = _filter_apis_desc(description, apis)
|
||||
return {'restapi': [_convert_datetime_str(api) for api in apis]}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_apis(name=None, description=None, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -251,7 +250,7 @@ def create_api(name, description, cloneFrom=None,
|
|||
api = _convert_datetime_str(api)
|
||||
return {'created': True, 'restapi': api} if api else {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api(name, description=None, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -282,7 +281,7 @@ def delete_api(name, description=None, region=None, key=None, keyid=None, profil
|
|||
else:
|
||||
return {'deleted': False}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_resources(restApiId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -303,7 +302,7 @@ def describe_api_resources(restApiId, region=None, key=None, keyid=None, profile
|
|||
|
||||
return {'resources': resources}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_resource(restApiId, path,
|
||||
|
|
@ -364,7 +363,7 @@ def create_api_resources(restApiId, path,
|
|||
else:
|
||||
return {'created': False, 'error': 'unexpected error.'}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_resources(restApiId, path,
|
||||
|
|
@ -393,7 +392,7 @@ def delete_api_resources(restApiId, path,
|
|||
else:
|
||||
return {'deleted': False, 'error': 'no resource found by {0}'.format(path)}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_resource_method(restApiId, resourcePath, httpMethod,
|
||||
|
|
@ -421,7 +420,7 @@ def describe_api_resource_method(restApiId, resourcePath, httpMethod,
|
|||
method = conn.get_method(restApiId=restApiId, resourceId=resource['id'], httpMethod=httpMethod)
|
||||
return {'method': method}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -440,7 +439,7 @@ def describe_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
|||
response = conn.get_api_key(apiKey=apiKey)
|
||||
return {'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_keys(region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -460,7 +459,7 @@ def describe_api_keys(region=None, key=None, keyid=None, profile=None):
|
|||
|
||||
return {'apiKeys': [_convert_datetime_str(apikey) for apikey in apikeys]}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_key(name, description, enabled=True, stageKeys=None,
|
||||
|
|
@ -498,7 +497,7 @@ def create_api_key(name, description, enabled=True, stageKeys=None,
|
|||
|
||||
return {'created': True, 'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -517,7 +516,7 @@ def delete_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
|||
conn.delete_api_key(apiKey=apiKey)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _api_key_patch_replace(conn, apiKey, path, value):
|
||||
|
|
@ -570,7 +569,7 @@ def update_api_key_description(apiKey, description, region=None, key=None, keyid
|
|||
response = _api_key_patch_replace(conn, apiKey, '/description', description)
|
||||
return {'updated': True, 'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'updated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'updated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def enable_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -589,7 +588,7 @@ def enable_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
|||
response = _api_key_patch_replace(conn, apiKey, '/enabled', 'True')
|
||||
return {'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def disable_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -608,7 +607,7 @@ def disable_api_key(apiKey, region=None, key=None, keyid=None, profile=None):
|
|||
response = _api_key_patch_replace(conn, apiKey, '/enabled', 'False')
|
||||
return {'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def associate_api_key_stagekeys(apiKey, stagekeyslist, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -629,7 +628,7 @@ def associate_api_key_stagekeys(apiKey, stagekeyslist, region=None, key=None, ke
|
|||
response = _api_key_patch_add(conn, apiKey, pvlist)
|
||||
return {'associated': True, 'apiKey': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'associated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'associated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def disassociate_api_key_stagekeys(apiKey, stagekeyslist, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -650,7 +649,7 @@ def disassociate_api_key_stagekeys(apiKey, stagekeyslist, region=None, key=None,
|
|||
response = _api_key_patch_remove(conn, apiKey, pvlist)
|
||||
return {'disassociated': True}
|
||||
except ClientError as e:
|
||||
return {'disassociated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'disassociated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_deployments(restApiId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -678,7 +677,7 @@ def describe_api_deployments(restApiId, region=None, key=None, keyid=None, profi
|
|||
|
||||
return {'deployments': [_convert_datetime_str(deployment) for deployment in deployments]}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_deployment(restApiId, deploymentId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -697,7 +696,7 @@ def describe_api_deployment(restApiId, deploymentId, region=None, key=None, keyi
|
|||
deployment = conn.get_deployment(restApiId=restApiId, deploymentId=deploymentId)
|
||||
return {'deployment': _convert_datetime_str(deployment)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def activate_api_deployment(restApiId, stageName, deploymentId,
|
||||
|
|
@ -720,7 +719,7 @@ def activate_api_deployment(restApiId, stageName, deploymentId,
|
|||
'value': deploymentId}])
|
||||
return {'set': True, 'response': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'set': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'set': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_deployment(restApiId, stageName, stageDescription='', description='', cacheClusterEnabled=False,
|
||||
|
|
@ -747,7 +746,7 @@ def create_api_deployment(restApiId, stageName, stageDescription='', description
|
|||
variables=variables)
|
||||
return {'created': True, 'deployment': _convert_datetime_str(deployment)}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_deployment(restApiId, deploymentId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -766,7 +765,7 @@ def delete_api_deployment(restApiId, deploymentId, region=None, key=None, keyid=
|
|||
conn.delete_deployment(restApiId=restApiId, deploymentId=deploymentId)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def overwrite_api_stage_variables(restApiId, stageName, variables, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -812,7 +811,7 @@ def overwrite_api_stage_variables(restApiId, stageName, variables, region=None,
|
|||
|
||||
return {'overwrite': True, 'stage': _convert_datetime_str(stage)}
|
||||
except ClientError as e:
|
||||
return {'overwrite': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'overwrite': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_stage(restApiId, stageName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -831,7 +830,7 @@ def describe_api_stage(restApiId, stageName, region=None, key=None, keyid=None,
|
|||
stage = conn.get_stage(restApiId=restApiId, stageName=stageName)
|
||||
return {'stage': _convert_datetime_str(stage)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_stages(restApiId, deploymentId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -850,7 +849,7 @@ def describe_api_stages(restApiId, deploymentId, region=None, key=None, keyid=No
|
|||
stages = conn.get_stages(restApiId=restApiId, deploymentId=deploymentId)
|
||||
return {'stages': [_convert_datetime_str(stage) for stage in stages['item']]}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_stage(restApiId, stageName, deploymentId, description='',
|
||||
|
|
@ -876,7 +875,7 @@ def create_api_stage(restApiId, stageName, deploymentId, description='',
|
|||
cacheClusterSize=cacheClusterSize, variables=variables)
|
||||
return {'created': True, 'stage': _convert_datetime_str(stage)}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_stage(restApiId, stageName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -895,7 +894,7 @@ def delete_api_stage(restApiId, stageName, region=None, key=None, keyid=None, pr
|
|||
conn.delete_stage(restApiId=restApiId, stageName=stageName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def flush_api_stage_cache(restApiId, stageName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -914,7 +913,7 @@ def flush_api_stage_cache(restApiId, stageName, region=None, key=None, keyid=Non
|
|||
conn.flush_stage_cache(restApiId=restApiId, stageName=stageName)
|
||||
return {'flushed': True}
|
||||
except ClientError as e:
|
||||
return {'flushed': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'flushed': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_method(restApiId, resourcePath, httpMethod, authorizationType,
|
||||
|
|
@ -946,7 +945,7 @@ def create_api_method(restApiId, resourcePath, httpMethod, authorizationType,
|
|||
return {'created': False, 'error': 'Failed to create method'}
|
||||
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_method(restApiId, resourcePath, httpMethod, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -969,7 +968,7 @@ def describe_api_method(restApiId, resourcePath, httpMethod, region=None, key=No
|
|||
return {'method': _convert_datetime_str(method)}
|
||||
return {'error': 'get API method failed: no such resource'}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_method(restApiId, resourcePath, httpMethod, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -992,7 +991,7 @@ def delete_api_method(restApiId, resourcePath, httpMethod, region=None, key=None
|
|||
return {'deleted': True}
|
||||
return {'deleted': False, 'error': 'get API method failed: no such resource'}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_method_response(restApiId, resourcePath, httpMethod, statusCode, responseParameters=None,
|
||||
|
|
@ -1022,7 +1021,7 @@ def create_api_method_response(restApiId, resourcePath, httpMethod, statusCode,
|
|||
return {'created': True, 'response': response}
|
||||
return {'created': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_method_response(restApiId, resourcePath, httpMethod, statusCode,
|
||||
|
|
@ -1047,7 +1046,7 @@ def delete_api_method_response(restApiId, resourcePath, httpMethod, statusCode,
|
|||
return {'deleted': True}
|
||||
return {'deleted': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_method_response(restApiId, resourcePath, httpMethod, statusCode,
|
||||
|
|
@ -1072,7 +1071,7 @@ def describe_api_method_response(restApiId, resourcePath, httpMethod, statusCode
|
|||
return {'response': _convert_datetime_str(response)}
|
||||
return {'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_models(restApiId, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1091,7 +1090,7 @@ def describe_api_models(restApiId, region=None, key=None, keyid=None, profile=No
|
|||
models = _multi_call(conn.get_models, 'items', restApiId=restApiId)
|
||||
return {'models': [_convert_datetime_str(model) for model in models]}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_model(restApiId, modelName, flatten=True, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1110,7 +1109,7 @@ def describe_api_model(restApiId, modelName, flatten=True, region=None, key=None
|
|||
model = conn.get_model(restApiId=restApiId, modelName=modelName, flatten=flatten)
|
||||
return {'model': _convert_datetime_str(model)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def api_model_exists(restApiId, modelName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1154,7 +1153,7 @@ def update_api_model_schema(restApiId, modelName, schema, region=None, key=None,
|
|||
response = _api_model_patch_replace(conn, restApiId, modelName, '/schema', schema_json)
|
||||
return {'updated': True, 'model': _convert_datetime_str(response)}
|
||||
except ClientError as e:
|
||||
return {'updated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'updated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_model(restApiId, modelName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1173,7 +1172,7 @@ def delete_api_model(restApiId, modelName, region=None, key=None, keyid=None, pr
|
|||
conn.delete_model(restApiId=restApiId, modelName=modelName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_model(restApiId, modelName, modelDescription, schema, contentType='application/json',
|
||||
|
|
@ -1196,7 +1195,7 @@ def create_api_model(restApiId, modelName, modelDescription, schema, contentType
|
|||
schema=schema_json, contentType=contentType)
|
||||
return {'created': True, 'model': _convert_datetime_str(model)}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_integration(restApiId, resourcePath, httpMethod, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1219,7 +1218,7 @@ def describe_api_integration(restApiId, resourcePath, httpMethod, region=None, k
|
|||
return {'integration': _convert_datetime_str(integration)}
|
||||
return {'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_api_integration_response(restApiId, resourcePath, httpMethod, statusCode,
|
||||
|
|
@ -1244,7 +1243,7 @@ def describe_api_integration_response(restApiId, resourcePath, httpMethod, statu
|
|||
return {'response': _convert_datetime_str(response)}
|
||||
return {'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_integration(restApiId, resourcePath, httpMethod, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1267,7 +1266,7 @@ def delete_api_integration(restApiId, resourcePath, httpMethod, region=None, key
|
|||
return {'deleted': True}
|
||||
return {'deleted': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_api_integration_response(restApiId, resourcePath, httpMethod, statusCode,
|
||||
|
|
@ -1292,7 +1291,7 @@ def delete_api_integration_response(restApiId, resourcePath, httpMethod, statusC
|
|||
return {'deleted': True}
|
||||
return {'deleted': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _get_role_arn(name, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1349,7 +1348,7 @@ def create_api_integration(restApiId, resourcePath, httpMethod, integrationType,
|
|||
return {'created': True, 'integration': integration}
|
||||
return {'created': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_api_integration_response(restApiId, resourcePath, httpMethod, statusCode, selectionPattern,
|
||||
|
|
@ -1382,7 +1381,7 @@ def create_api_integration_response(restApiId, resourcePath, httpMethod, statusC
|
|||
return {'created': True, 'response': response}
|
||||
return {'created': False, 'error': 'no such resource'}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _filter_plans(attr, name, plans):
|
||||
|
|
@ -1418,7 +1417,7 @@ def describe_usage_plans(name=None, plan_id=None, region=None, key=None, keyid=N
|
|||
return {'plans': [_convert_datetime_str(plan) for plan in plans]}
|
||||
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _validate_throttle(throttle):
|
||||
|
|
@ -1497,7 +1496,7 @@ def create_usage_plan(name, description=None, throttle=None, quota=None, region=
|
|||
res = conn.create_usage_plan(**values)
|
||||
return {'created': True, 'result': res}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
except (TypeError, ValueError) as e:
|
||||
return {'error': six.text_type(e)}
|
||||
|
||||
|
|
@ -1571,7 +1570,7 @@ def update_usage_plan(plan_id, throttle=None, quota=None, region=None, key=None,
|
|||
return {'updated': False}
|
||||
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
except (TypeError, ValueError) as e:
|
||||
return {'error': six.text_type(e)}
|
||||
|
||||
|
|
@ -1600,7 +1599,7 @@ def delete_usage_plan(plan_id, region=None, key=None, keyid=None, profile=None):
|
|||
res = conn.delete_usage_plan(usagePlanId=plan_id)
|
||||
return {'deleted': True, 'usagePlanId': plan_id}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _update_usage_plan_apis(plan_id, apis, op, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -1634,7 +1633,7 @@ def _update_usage_plan_apis(plan_id, apis, op, region=None, key=None, keyid=None
|
|||
patchOperations=patchOperations)
|
||||
return {'success': True, 'result': res}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
except Exception as e:
|
||||
return {'error': e}
|
||||
|
||||
|
|
|
|||
|
|
@ -74,7 +74,6 @@ except ImportError:
|
|||
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.json
|
||||
import salt.utils.odict as odict
|
||||
|
|
@ -885,7 +884,7 @@ def enter_standby(name, instance_ids, should_decrement_desired_capacity=False,
|
|||
AutoScalingGroupName=name,
|
||||
ShouldDecrementDesiredCapacity=should_decrement_desired_capacity)
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': err}
|
||||
|
|
@ -911,7 +910,7 @@ def exit_standby(name, instance_ids, should_decrement_desired_capacity=False,
|
|||
InstanceIds=instance_ids,
|
||||
AutoScalingGroupName=name)
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': err}
|
||||
|
|
|
|||
|
|
@ -55,7 +55,6 @@ import logging
|
|||
|
||||
# Import Salt libs
|
||||
from salt.ext import six
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.versions
|
||||
|
||||
|
|
@ -117,7 +116,7 @@ def exists(Name,
|
|||
conn.get_trail_status(Name=Name)
|
||||
return {'exists': True}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'TrailNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': err}
|
||||
|
|
@ -167,7 +166,7 @@ def create(Name,
|
|||
log.warning('Trail was not created')
|
||||
return {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete(Name,
|
||||
|
|
@ -191,7 +190,7 @@ def delete(Name,
|
|||
conn.delete_trail(Name=Name)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe(Name,
|
||||
|
|
@ -224,10 +223,10 @@ def describe(Name,
|
|||
else:
|
||||
return {'trail': None}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'TrailNotFoundException':
|
||||
return {'trail': None}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def status(Name,
|
||||
|
|
@ -265,10 +264,10 @@ def status(Name,
|
|||
else:
|
||||
return {'trail': None}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'TrailNotFoundException':
|
||||
return {'trail': None}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list(region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -293,7 +292,7 @@ def list(region=None, key=None, keyid=None, profile=None):
|
|||
log.warning('No trails found')
|
||||
return {'trails': trails.get('trailList', [])}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def update(Name,
|
||||
|
|
@ -340,7 +339,7 @@ def update(Name,
|
|||
log.warning('Trail was not created')
|
||||
return {'updated': False}
|
||||
except ClientError as e:
|
||||
return {'updated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'updated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def start_logging(Name,
|
||||
|
|
@ -364,7 +363,7 @@ def start_logging(Name,
|
|||
conn.start_logging(Name=Name)
|
||||
return {'started': True}
|
||||
except ClientError as e:
|
||||
return {'started': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'started': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def stop_logging(Name,
|
||||
|
|
@ -388,7 +387,7 @@ def stop_logging(Name,
|
|||
conn.stop_logging(Name=Name)
|
||||
return {'stopped': True}
|
||||
except ClientError as e:
|
||||
return {'stopped': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'stopped': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _get_trail_arn(name, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -433,7 +432,7 @@ def add_tags(Name,
|
|||
profile=profile), TagsList=tagslist)
|
||||
return {'tagged': True}
|
||||
except ClientError as e:
|
||||
return {'tagged': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'tagged': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def remove_tags(Name,
|
||||
|
|
@ -464,7 +463,7 @@ def remove_tags(Name,
|
|||
profile=profile), TagsList=tagslist)
|
||||
return {'tagged': True}
|
||||
except ClientError as e:
|
||||
return {'tagged': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'tagged': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_tags(Name,
|
||||
|
|
@ -497,4 +496,4 @@ def list_tags(Name,
|
|||
tagdict[tag.get('Key')] = tag.get('Value')
|
||||
return {'tags': tagdict}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
|
|
|||
|
|
@ -81,7 +81,6 @@ from __future__ import absolute_import, print_function, unicode_literals
|
|||
import logging
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.versions
|
||||
|
||||
|
|
@ -131,7 +130,7 @@ def _find_identity_pool_ids(name, pool_id, conn):
|
|||
'''
|
||||
ids = []
|
||||
if pool_id is None:
|
||||
for pools in salt.utils.boto3.paged_call(conn.list_identity_pools,
|
||||
for pools in __utils__['boto3.paged_call'](conn.list_identity_pools,
|
||||
marker_flag='NextToken', marker_arg='NextToken', MaxResults=25):
|
||||
for pool in pools['IdentityPools']:
|
||||
if pool['IdentityPoolName'] == name:
|
||||
|
|
@ -174,7 +173,7 @@ def describe_identity_pools(IdentityPoolName, IdentityPoolId=None,
|
|||
else:
|
||||
return {'identity_pools': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_identity_pool(IdentityPoolName,
|
||||
|
|
@ -216,7 +215,7 @@ def create_identity_pool(IdentityPoolName,
|
|||
|
||||
return {'created': True, 'identity_pool': response}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_identity_pools(IdentityPoolName, IdentityPoolId=None,
|
||||
|
|
@ -250,7 +249,7 @@ def delete_identity_pools(IdentityPoolName, IdentityPoolId=None,
|
|||
else:
|
||||
return {'deleted': False, 'count': count}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def get_identity_pool_roles(IdentityPoolName, IdentityPoolId=None,
|
||||
|
|
@ -284,7 +283,7 @@ def get_identity_pool_roles(IdentityPoolName, IdentityPoolId=None,
|
|||
else:
|
||||
return {'identity_pool_roles': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _get_role_arn(name, **conn_params):
|
||||
|
|
@ -349,7 +348,7 @@ def set_identity_pool_roles(IdentityPoolId, AuthenticatedRole=None, Unauthentica
|
|||
|
||||
return {'set': True, 'roles': Roles}
|
||||
except ClientError as e:
|
||||
return {'set': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'set': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def update_identity_pool(IdentityPoolId,
|
||||
|
|
@ -420,4 +419,4 @@ def update_identity_pool(IdentityPoolId,
|
|||
|
||||
return {'updated': True, 'identity_pool': response}
|
||||
except ClientError as e:
|
||||
return {'updated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'updated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
|
|
|||
|
|
@ -80,7 +80,6 @@ import logging
|
|||
|
||||
# Import Salt libs
|
||||
from salt.ext import six
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.json
|
||||
import salt.utils.versions
|
||||
|
|
@ -148,7 +147,7 @@ def exists(DomainName,
|
|||
except ClientError as e:
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def status(DomainName,
|
||||
|
|
@ -179,7 +178,7 @@ def status(DomainName,
|
|||
else:
|
||||
return {'domain': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe(DomainName,
|
||||
|
|
@ -208,7 +207,7 @@ def describe(DomainName,
|
|||
else:
|
||||
return {'domain': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create(DomainName, ElasticsearchClusterConfig=None, EBSOptions=None,
|
||||
|
|
@ -262,7 +261,7 @@ def create(DomainName, ElasticsearchClusterConfig=None, EBSOptions=None,
|
|||
log.warning('Domain was not created')
|
||||
return {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete(DomainName, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -285,7 +284,7 @@ def delete(DomainName, region=None, key=None, keyid=None, profile=None):
|
|||
conn.delete_elasticsearch_domain(DomainName=DomainName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def update(DomainName, ElasticsearchClusterConfig=None, EBSOptions=None,
|
||||
|
|
@ -335,7 +334,7 @@ def update(DomainName, ElasticsearchClusterConfig=None, EBSOptions=None,
|
|||
return {'updated': False}
|
||||
return {'updated': True}
|
||||
except ClientError as e:
|
||||
return {'updated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'updated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def add_tags(DomainName=None, ARN=None,
|
||||
|
|
@ -378,7 +377,7 @@ def add_tags(DomainName=None, ARN=None,
|
|||
conn.add_tags(ARN=ARN, TagList=tagslist)
|
||||
return {'tagged': True}
|
||||
except ClientError as e:
|
||||
return {'tagged': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'tagged': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def remove_tags(TagKeys, DomainName=None, ARN=None,
|
||||
|
|
@ -417,7 +416,7 @@ def remove_tags(TagKeys, DomainName=None, ARN=None,
|
|||
TagKeys=TagKeys)
|
||||
return {'tagged': True}
|
||||
except ClientError as e:
|
||||
return {'tagged': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'tagged': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_tags(DomainName=None, ARN=None,
|
||||
|
|
@ -462,4 +461,4 @@ def list_tags(DomainName=None, ARN=None,
|
|||
tagdict[tag.get('Key')] = tag.get('Value')
|
||||
return {'tags': tagdict}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
|
|
|||
|
|
@ -54,7 +54,6 @@ import salt.utils.versions
|
|||
# Import third-party libs
|
||||
try:
|
||||
# pylint: disable=unused-import
|
||||
import salt.utils.boto3
|
||||
import boto3
|
||||
import botocore
|
||||
# pylint: enable=unused-import
|
||||
|
|
|
|||
|
|
@ -55,7 +55,6 @@ import logging
|
|||
import datetime
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.json
|
||||
import salt.utils.versions
|
||||
|
|
@ -125,7 +124,7 @@ def thing_type_exists(thingTypeName,
|
|||
else:
|
||||
return {'exists': False}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': err}
|
||||
|
|
@ -162,7 +161,7 @@ def describe_thing_type(thingTypeName,
|
|||
else:
|
||||
return {'thing_type': None}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'thing_type': None}
|
||||
return {'error': err}
|
||||
|
|
@ -207,7 +206,7 @@ def create_thing_type(thingTypeName, thingTypeDescription,
|
|||
log.warning('thing type was not created')
|
||||
return {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def deprecate_thing_type(thingTypeName, undoDeprecate=False,
|
||||
|
|
@ -238,7 +237,7 @@ def deprecate_thing_type(thingTypeName, undoDeprecate=False,
|
|||
deprecated = True if undoDeprecate is False else False
|
||||
return {'deprecated': deprecated}
|
||||
except ClientError as e:
|
||||
return {'deprecated': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deprecated': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_thing_type(thingTypeName,
|
||||
|
|
@ -264,7 +263,7 @@ def delete_thing_type(thingTypeName,
|
|||
conn.delete_thing_type(thingTypeName=thingTypeName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'deleted': True}
|
||||
return {'deleted': False, 'error': err}
|
||||
|
|
@ -291,7 +290,7 @@ def policy_exists(policyName,
|
|||
conn.get_policy(policyName=policyName)
|
||||
return {'exists': True}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': err}
|
||||
|
|
@ -331,7 +330,7 @@ def create_policy(policyName, policyDocument,
|
|||
log.warning('Policy was not created')
|
||||
return {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_policy(policyName,
|
||||
|
|
@ -355,7 +354,7 @@ def delete_policy(policyName,
|
|||
conn.delete_policy(policyName=policyName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_policy(policyName,
|
||||
|
|
@ -383,10 +382,10 @@ def describe_policy(policyName,
|
|||
else:
|
||||
return {'policy': None}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'policy': None}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def policy_version_exists(policyName, policyVersionId,
|
||||
|
|
@ -411,10 +410,10 @@ def policy_version_exists(policyName, policyVersionId,
|
|||
policyversionId=policyVersionId)
|
||||
return {'exists': bool(policy)}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'exists': False}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_policy_version(policyName, policyDocument, setAsDefault=False,
|
||||
|
|
@ -449,7 +448,7 @@ def create_policy_version(policyName, policyDocument, setAsDefault=False,
|
|||
log.warning('Policy version was not created')
|
||||
return {'created': False}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_policy_version(policyName, policyVersionId,
|
||||
|
|
@ -474,7 +473,7 @@ def delete_policy_version(policyName, policyVersionId,
|
|||
policyVersionId=policyVersionId)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_policy_version(policyName, policyVersionId,
|
||||
|
|
@ -503,10 +502,10 @@ def describe_policy_version(policyName, policyVersionId,
|
|||
else:
|
||||
return {'policy': None}
|
||||
except ClientError as e:
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'ResourceNotFoundException':
|
||||
return {'policy': None}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_policies(region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -533,7 +532,7 @@ def list_policies(region=None, key=None, keyid=None, profile=None):
|
|||
try:
|
||||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
policies = []
|
||||
for ret in salt.utils.boto3.paged_call(conn.list_policies,
|
||||
for ret in __utils__['boto3.paged_call'](conn.list_policies,
|
||||
marker_flag='nextMarker',
|
||||
marker_arg='marker'):
|
||||
policies.extend(ret['policies'])
|
||||
|
|
@ -541,7 +540,7 @@ def list_policies(region=None, key=None, keyid=None, profile=None):
|
|||
log.warning('No policies found')
|
||||
return {'policies': policies}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_policy_versions(policyName,
|
||||
|
|
@ -567,7 +566,7 @@ def list_policy_versions(policyName,
|
|||
try:
|
||||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
vers = []
|
||||
for ret in salt.utils.boto3.paged_call(conn.list_policy_versions,
|
||||
for ret in __utils__['boto3.paged_call'](conn.list_policy_versions,
|
||||
marker_flag='nextMarker',
|
||||
marker_arg='marker',
|
||||
policyName=policyName):
|
||||
|
|
@ -576,7 +575,7 @@ def list_policy_versions(policyName,
|
|||
log.warning('No versions found')
|
||||
return {'policyVersions': vers}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def set_default_policy_version(policyName, policyVersionId,
|
||||
|
|
@ -603,7 +602,7 @@ def set_default_policy_version(policyName, policyVersionId,
|
|||
policyVersionId=str(policyVersionId)) # future lint: disable=blacklisted-function
|
||||
return {'changed': True}
|
||||
except ClientError as e:
|
||||
return {'changed': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'changed': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_principal_policies(principal,
|
||||
|
|
@ -629,7 +628,7 @@ def list_principal_policies(principal,
|
|||
try:
|
||||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
vers = []
|
||||
for ret in salt.utils.boto3.paged_call(conn.list_principal_policies,
|
||||
for ret in __utils__['boto3.paged_call'](conn.list_principal_policies,
|
||||
principal=principal,
|
||||
marker_flag='nextMarker',
|
||||
marker_arg='marker'):
|
||||
|
|
@ -638,7 +637,7 @@ def list_principal_policies(principal,
|
|||
log.warning('No policies found')
|
||||
return {'policies': vers}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def attach_principal_policy(policyName, principal,
|
||||
|
|
@ -664,7 +663,7 @@ def attach_principal_policy(policyName, principal,
|
|||
principal=principal)
|
||||
return {'attached': True}
|
||||
except ClientError as e:
|
||||
return {'attached': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'attached': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def detach_principal_policy(policyName, principal,
|
||||
|
|
@ -689,7 +688,7 @@ def detach_principal_policy(policyName, principal,
|
|||
principal=principal)
|
||||
return {'detached': True}
|
||||
except ClientError as e:
|
||||
return {'detached': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'detached': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def topic_rule_exists(ruleName,
|
||||
|
|
@ -718,10 +717,10 @@ def topic_rule_exists(ruleName,
|
|||
# use, it's more useful to assume lack of existence than to assume a
|
||||
# genuine authorization problem; authorization problems should not be
|
||||
# the common case.
|
||||
err = salt.utils.boto3.get_error(e)
|
||||
err = __utils__['boto3.get_error'](e)
|
||||
if e.response.get('Error', {}).get('Code') == 'UnauthorizedException':
|
||||
return {'exists': False}
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_topic_rule(ruleName, sql, actions, description,
|
||||
|
|
@ -754,7 +753,7 @@ def create_topic_rule(ruleName, sql, actions, description,
|
|||
})
|
||||
return {'created': True}
|
||||
except ClientError as e:
|
||||
return {'created': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def replace_topic_rule(ruleName, sql, actions, description,
|
||||
|
|
@ -787,7 +786,7 @@ def replace_topic_rule(ruleName, sql, actions, description,
|
|||
})
|
||||
return {'replaced': True}
|
||||
except ClientError as e:
|
||||
return {'replaced': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'replaced': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_topic_rule(ruleName,
|
||||
|
|
@ -811,7 +810,7 @@ def delete_topic_rule(ruleName,
|
|||
conn.delete_topic_rule(ruleName=ruleName)
|
||||
return {'deleted': True}
|
||||
except ClientError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto3.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_topic_rule(ruleName,
|
||||
|
|
@ -840,7 +839,7 @@ def describe_topic_rule(ruleName,
|
|||
else:
|
||||
return {'rule': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def list_topic_rules(topic=None, ruleDisabled=None,
|
||||
|
|
@ -873,7 +872,7 @@ def list_topic_rules(topic=None, ruleDisabled=None,
|
|||
if ruleDisabled is not None:
|
||||
kwargs['ruleDisabled'] = ruleDisabled
|
||||
rules = []
|
||||
for ret in salt.utils.boto3.paged_call(conn.list_topic_rules,
|
||||
for ret in __utils__['boto3.paged_call'](conn.list_topic_rules,
|
||||
marker_flag='nextToken',
|
||||
marker_arg='nextToken',
|
||||
**kwargs):
|
||||
|
|
@ -882,4 +881,4 @@ def list_topic_rules(topic=None, ruleDisabled=None,
|
|||
log.warning('No rules found')
|
||||
return {'rules': rules}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
|
|
|||
|
|
@ -53,7 +53,6 @@ import logging
|
|||
import time
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.odict as odict
|
||||
import salt.utils.versions
|
||||
|
|
@ -153,7 +152,7 @@ def exists(name, tags=None, region=None, key=None, keyid=None, profile=None):
|
|||
rds = conn.describe_db_instances(DBInstanceIdentifier=name)
|
||||
return {'exists': bool(rds)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def option_group_exists(name, tags=None, region=None, key=None, keyid=None,
|
||||
|
|
@ -171,7 +170,7 @@ def option_group_exists(name, tags=None, region=None, key=None, keyid=None,
|
|||
rds = conn.describe_option_groups(OptionGroupName=name)
|
||||
return {'exists': bool(rds)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def parameter_group_exists(name, tags=None, region=None, key=None, keyid=None,
|
||||
|
|
@ -193,7 +192,7 @@ def parameter_group_exists(name, tags=None, region=None, key=None, keyid=None,
|
|||
resp = {}
|
||||
if e.response['Error']['Code'] == 'DBParameterGroupNotFound':
|
||||
resp['exists'] = False
|
||||
resp['error'] = salt.utils.boto3.get_error(e)
|
||||
resp['error'] = __utils__['boto3.get_error'](e)
|
||||
return resp
|
||||
|
||||
|
||||
|
|
@ -218,7 +217,7 @@ def subnet_group_exists(name, tags=None, region=None, key=None, keyid=None,
|
|||
if "DBSubnetGroupNotFoundFault" in e.message:
|
||||
return {'exists': False}
|
||||
else:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create(name, allocated_storage, db_instance_class, engine,
|
||||
|
|
@ -317,7 +316,7 @@ def create(name, allocated_storage, db_instance_class, engine,
|
|||
log.info('Instance status after 10 seconds is: %s', stat)
|
||||
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_read_replica(name, source_name, db_instance_class=None,
|
||||
|
|
@ -375,7 +374,7 @@ def create_read_replica(name, source_name, db_instance_class=None,
|
|||
|
||||
return {'exists': bool(rds_replica)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_option_group(name, engine_name, major_engine_version,
|
||||
|
|
@ -408,7 +407,7 @@ def create_option_group(name, engine_name, major_engine_version,
|
|||
|
||||
return {'exists': bool(rds)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_parameter_group(name, db_parameter_group_family, description,
|
||||
|
|
@ -444,7 +443,7 @@ def create_parameter_group(name, db_parameter_group_family, description,
|
|||
return {'exists': bool(rds), 'message':
|
||||
'Created RDS parameter group {0}'.format(name)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def create_subnet_group(name, description, subnet_ids, tags=None,
|
||||
|
|
@ -475,7 +474,7 @@ def create_subnet_group(name, description, subnet_ids, tags=None,
|
|||
|
||||
return {'created': bool(rds)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def update_parameter_group(name, parameters, apply_method="pending-reboot",
|
||||
|
|
@ -520,7 +519,7 @@ def update_parameter_group(name, parameters, apply_method="pending-reboot",
|
|||
Parameters=param_list)
|
||||
return {'results': bool(res)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe(name, tags=None, region=None, key=None, keyid=None,
|
||||
|
|
@ -568,7 +567,7 @@ def describe(name, tags=None, region=None, key=None, keyid=None,
|
|||
else:
|
||||
return {'rds': None}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
except IndexError:
|
||||
return {'rds': None}
|
||||
|
||||
|
|
@ -597,7 +596,7 @@ def describe_db_instances(name=None, filters=None, jmespath='DBInstances',
|
|||
except ClientError as e:
|
||||
code = getattr(e, 'response', {}).get('Error', {}).get('Code')
|
||||
if code != 'DBInstanceNotFound':
|
||||
log.error(salt.utils.boto3.get_error(e))
|
||||
log.error(__utils__['boto3.get_error'](e))
|
||||
return []
|
||||
|
||||
|
||||
|
|
@ -647,7 +646,7 @@ def get_endpoint(name, tags=None, region=None, key=None, keyid=None,
|
|||
return endpoint
|
||||
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
return endpoint
|
||||
|
||||
|
|
@ -706,7 +705,7 @@ def delete(name, skip_final_snapshot=None, final_db_snapshot_identifier=None,
|
|||
'deleted.', timeout, name)
|
||||
time.sleep(10)
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_option_group(name, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -731,7 +730,7 @@ def delete_option_group(name, region=None, key=None, keyid=None, profile=None):
|
|||
return {'deleted': bool(res), 'message':
|
||||
'Deleted RDS option group {0}.'.format(name)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_parameter_group(name, region=None, key=None, keyid=None,
|
||||
|
|
@ -753,7 +752,7 @@ def delete_parameter_group(name, region=None, key=None, keyid=None,
|
|||
return {'deleted': bool(r), 'message':
|
||||
'Deleted RDS parameter group {0}.'.format(name)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def delete_subnet_group(name, region=None, key=None, keyid=None,
|
||||
|
|
@ -775,7 +774,7 @@ def delete_subnet_group(name, region=None, key=None, keyid=None,
|
|||
return {'deleted': bool(r), 'message':
|
||||
'Deleted RDS subnet group {0}.'.format(name)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_parameter_group(name, Filters=None, MaxRecords=None, Marker=None,
|
||||
|
|
@ -817,7 +816,7 @@ def describe_parameter_group(name, Filters=None, MaxRecords=None, Marker=None,
|
|||
return {'results': bool(info), 'message':
|
||||
'Got RDS descrition for group {0}.'.format(name)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def describe_parameters(name, Source=None, MaxRecords=None, Marker=None,
|
||||
|
|
@ -873,7 +872,7 @@ def describe_parameters(name, Source=None, MaxRecords=None, Marker=None,
|
|||
ret['parameters'] = parameters
|
||||
return ret
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def modify_db_instance(name,
|
||||
|
|
@ -950,7 +949,7 @@ def modify_db_instance(name,
|
|||
'Modified RDS db instance {0}.'.format(name),
|
||||
'results': dict(info)}
|
||||
except ClientError as e:
|
||||
return {'error': salt.utils.boto3.get_error(e)}
|
||||
return {'error': __utils__['boto3.get_error'](e)}
|
||||
|
||||
|
||||
def _tag_doc(tags):
|
||||
|
|
|
|||
|
|
@ -134,8 +134,6 @@ import time
|
|||
import random
|
||||
|
||||
# Import Salt libs
|
||||
import salt.utils.boto
|
||||
import salt.utils.boto3
|
||||
import salt.utils.compat
|
||||
import salt.utils.versions
|
||||
from salt.exceptions import SaltInvocationError, CommandExecutionError
|
||||
|
|
@ -279,7 +277,7 @@ def _create_resource(resource, name=None, tags=None, region=None, key=None,
|
|||
log.warning(e)
|
||||
return {'created': False, 'error': {'message': e}}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _delete_resource(resource, name=None, resource_id=None, region=None,
|
||||
|
|
@ -323,7 +321,7 @@ def _delete_resource(resource, name=None, resource_id=None, region=None,
|
|||
e = '{0} was not deleted.'.format(resource)
|
||||
return {'deleted': False, 'error': {'message': e}}
|
||||
except BotoServerError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _get_resource(resource, name=None, resource_id=None, region=None,
|
||||
|
|
@ -451,7 +449,7 @@ def get_resource_id(resource, name=None, resource_id=None, region=None,
|
|||
return {'id': _get_resource_id(resource, name, region=region, key=key,
|
||||
keyid=keyid, profile=profile)}
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def resource_exists(resource, name=None, resource_id=None, tags=None,
|
||||
|
|
@ -478,7 +476,7 @@ def resource_exists(resource, name=None, resource_id=None, tags=None,
|
|||
key=key, keyid=keyid,
|
||||
profile=profile))}
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _find_vpcs(vpc_id=None, vpc_name=None, cidr=None, tags=None,
|
||||
|
|
@ -570,7 +568,7 @@ def get_id(name=None, cidr=None, tags=None, region=None, key=None, keyid=None,
|
|||
return {'id': _get_id(vpc_name=name, cidr=cidr, tags=tags, region=region,
|
||||
key=key, keyid=keyid, profile=profile)}
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def exists(vpc_id=None, name=None, cidr=None, tags=None, region=None, key=None,
|
||||
|
|
@ -593,7 +591,7 @@ def exists(vpc_id=None, name=None, cidr=None, tags=None, region=None, key=None,
|
|||
vpc_ids = _find_vpcs(vpc_id=vpc_id, vpc_name=name, cidr=cidr, tags=tags,
|
||||
region=region, key=key, keyid=keyid, profile=profile)
|
||||
except BotoServerError as err:
|
||||
boto_err = salt.utils.boto.get_error(err)
|
||||
boto_err = __utils__['boto.get_error'](err)
|
||||
if boto_err.get('aws', {}).get('code') == 'InvalidVpcID.NotFound':
|
||||
# VPC was not found: handle the error and return False.
|
||||
return {'exists': False}
|
||||
|
|
@ -643,7 +641,7 @@ def create(cidr_block, instance_tenancy=None, vpc_name=None,
|
|||
log.warning('VPC was not created')
|
||||
return {'created': False}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def delete(vpc_id=None, name=None, vpc_name=None, tags=None,
|
||||
|
|
@ -693,7 +691,7 @@ def delete(vpc_id=None, name=None, vpc_name=None, tags=None,
|
|||
log.warning('VPC %s was not deleted.', vpc_id)
|
||||
return {'deleted': False}
|
||||
except BotoServerError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def describe(vpc_id=None, vpc_name=None, region=None, key=None,
|
||||
|
|
@ -722,7 +720,7 @@ def describe(vpc_id=None, vpc_name=None, region=None, key=None,
|
|||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
vpc_id = check_vpc(vpc_id, vpc_name, region, key, keyid, profile)
|
||||
except BotoServerError as err:
|
||||
boto_err = salt.utils.boto.get_error(err)
|
||||
boto_err = __utils__['boto.get_error'](err)
|
||||
if boto_err.get('aws', {}).get('code') == 'InvalidVpcID.NotFound':
|
||||
# VPC was not found: handle the error and return None.
|
||||
return {'vpc': None}
|
||||
|
|
@ -736,7 +734,7 @@ def describe(vpc_id=None, vpc_name=None, region=None, key=None,
|
|||
try:
|
||||
vpcs = conn.get_all_vpcs(**filter_parameters)
|
||||
except BotoServerError as err:
|
||||
return {'error': salt.utils.boto.get_error(err)}
|
||||
return {'error': __utils__['boto.get_error'](err)}
|
||||
|
||||
if vpcs:
|
||||
vpc = vpcs[0] # Found!
|
||||
|
|
@ -806,7 +804,7 @@ def describe_vpcs(vpc_id=None, name=None, cidr=None, tags=None,
|
|||
return {'vpcs': []}
|
||||
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _find_subnets(subnet_name=None, vpc_id=None, cidr=None, tags=None, conn=None):
|
||||
|
|
@ -871,7 +869,7 @@ def create_subnet(vpc_id=None, cidr_block=None, vpc_name=None,
|
|||
if not vpc_id:
|
||||
return {'created': False, 'error': {'message': 'VPC {0} does not exist.'.format(vpc_name or vpc_id)}}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
return _create_resource('subnet', name=subnet_name, tags=tags, vpc_id=vpc_id,
|
||||
availability_zone=availability_zone,
|
||||
|
|
@ -934,7 +932,7 @@ def subnet_exists(subnet_id=None, name=None, subnet_name=None, cidr=None,
|
|||
try:
|
||||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
except BotoServerError as err:
|
||||
return {'error': salt.utils.boto.get_error(err)}
|
||||
return {'error': __utils__['boto.get_error'](err)}
|
||||
|
||||
filter_parameters = {'filters': {}}
|
||||
if subnet_id:
|
||||
|
|
@ -952,7 +950,7 @@ def subnet_exists(subnet_id=None, name=None, subnet_name=None, cidr=None,
|
|||
try:
|
||||
subnets = conn.get_all_subnets(**filter_parameters)
|
||||
except BotoServerError as err:
|
||||
boto_err = salt.utils.boto.get_error(err)
|
||||
boto_err = __utils__['boto.get_error'](err)
|
||||
if boto_err.get('aws', {}).get('code') == 'InvalidSubnetID.NotFound':
|
||||
# Subnet was not found: handle the error and return False.
|
||||
return {'exists': False}
|
||||
|
|
@ -995,7 +993,7 @@ def get_subnet_association(subnets, region=None, key=None, keyid=None,
|
|||
# subnet_ids=subnets can accept either a string or a list
|
||||
subnets = conn.get_all_subnets(subnet_ids=subnets)
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
# using a set to store vpc_ids - the use of set prevents duplicate
|
||||
# vpc_id values
|
||||
|
|
@ -1035,7 +1033,7 @@ def describe_subnet(subnet_id=None, subnet_name=None, region=None,
|
|||
subnet = _get_resource('subnet', name=subnet_name, resource_id=subnet_id,
|
||||
region=region, key=key, keyid=keyid, profile=profile)
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
if not subnet:
|
||||
return {'subnet': None}
|
||||
|
|
@ -1116,7 +1114,7 @@ def describe_subnets(subnet_ids=None, subnet_names=None, vpc_id=None, cidr=None,
|
|||
return {'subnets': subnets_list}
|
||||
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def create_internet_gateway(internet_gateway_name=None, vpc_id=None,
|
||||
|
|
@ -1158,7 +1156,7 @@ def create_internet_gateway(internet_gateway_name=None, vpc_id=None,
|
|||
)
|
||||
return r
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def delete_internet_gateway(internet_gateway_id=None,
|
||||
|
|
@ -1212,7 +1210,7 @@ def delete_internet_gateway(internet_gateway_id=None,
|
|||
region=region, key=key, keyid=keyid,
|
||||
profile=profile)
|
||||
except BotoServerError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _find_nat_gateways(nat_gateway_id=None, subnet_id=None, subnet_name=None, vpc_id=None, vpc_name=None,
|
||||
|
|
@ -1253,7 +1251,7 @@ def _find_nat_gateways(nat_gateway_id=None, subnet_id=None, subnet_name=None, vp
|
|||
|
||||
conn3 = _get_conn3(region=region, key=key, keyid=keyid, profile=profile)
|
||||
nat_gateways = []
|
||||
for ret in salt.utils.boto3.paged_call(conn3.describe_nat_gateways,
|
||||
for ret in __utils__['boto3.paged_call'](conn3.describe_nat_gateways,
|
||||
marker_flag='NextToken', marker_arg='NextToken',
|
||||
**filter_parameters):
|
||||
for gw in ret.get('NatGateways', []):
|
||||
|
|
@ -1376,7 +1374,7 @@ def create_nat_gateway(subnet_id=None,
|
|||
r = conn3.create_nat_gateway(SubnetId=subnet_id, AllocationId=allocation_id)
|
||||
return {'created': True, 'id': r.get('NatGateway', {}).get('NatGatewayId')}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def delete_nat_gateway(nat_gateway_id,
|
||||
|
|
@ -1452,7 +1450,7 @@ def delete_nat_gateway(nat_gateway_id,
|
|||
conn3.release_address(AllocationId=addr.get('AllocationId'))
|
||||
return {'deleted': True}
|
||||
except BotoServerError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def create_customer_gateway(vpn_connection_type, ip_address, bgp_asn,
|
||||
|
|
@ -1573,7 +1571,7 @@ def create_dhcp_options(domain_name=None, domain_name_servers=None, ntp_servers=
|
|||
)
|
||||
return r
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def get_dhcp_options(dhcp_options_name=None, dhcp_options_id=None,
|
||||
|
|
@ -1604,7 +1602,7 @@ def get_dhcp_options(dhcp_options_name=None, dhcp_options_id=None,
|
|||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
r = conn.get_all_dhcp_options(dhcp_options_ids=[dhcp_options_id])
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
if not r:
|
||||
return {'dhcp_options': None}
|
||||
|
|
@ -1667,7 +1665,7 @@ def associate_dhcp_options_to_vpc(dhcp_options_id, vpc_id=None, vpc_name=None,
|
|||
dhcp_options_id, vpc_id)
|
||||
return {'associated': False, 'error': {'message': 'DHCP options could not be associated.'}}
|
||||
except BotoServerError as e:
|
||||
return {'associated': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'associated': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def dhcp_options_exists(dhcp_options_id=None, name=None, dhcp_options_name=None,
|
||||
|
|
@ -1720,7 +1718,7 @@ def create_network_acl(vpc_id=None, vpc_name=None, network_acl_name=None,
|
|||
try:
|
||||
vpc_id = check_vpc(vpc_id, vpc_name, region, key, keyid, profile)
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
if not vpc_id:
|
||||
return {'created': False,
|
||||
|
|
@ -1751,7 +1749,7 @@ def create_network_acl(vpc_id=None, vpc_name=None, network_acl_name=None,
|
|||
conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
|
||||
association_id = conn.associate_network_acl(r['id'], subnet_id)
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
r['association_id'] = association_id
|
||||
return r
|
||||
|
||||
|
|
@ -1866,7 +1864,7 @@ def associate_network_acl_to_subnet(network_acl_id=None, subnet_id=None,
|
|||
network_acl_id, subnet_id)
|
||||
return {'associated': False, 'error': {'message': 'ACL could not be assocaited.'}}
|
||||
except BotoServerError as e:
|
||||
return {'associated': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'associated': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def disassociate_network_acl(subnet_id=None, vpc_id=None, subnet_name=None, vpc_name=None,
|
||||
|
|
@ -1905,7 +1903,7 @@ def disassociate_network_acl(subnet_id=None, vpc_id=None, subnet_name=None, vpc_
|
|||
association_id = conn.disassociate_network_acl(subnet_id, vpc_id=vpc_id)
|
||||
return {'disassociated': True, 'association_id': association_id}
|
||||
except BotoServerError as e:
|
||||
return {'disassociated': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'disassociated': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _create_network_acl_entry(network_acl_id=None, rule_number=None, protocol=None,
|
||||
|
|
@ -1958,7 +1956,7 @@ def _create_network_acl_entry(network_acl_id=None, rule_number=None, protocol=No
|
|||
log.warning('Network ACL entry was not %s', rkey)
|
||||
return {rkey: created}
|
||||
except BotoServerError as e:
|
||||
return {rkey: False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {rkey: False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def create_network_acl_entry(network_acl_id=None, rule_number=None, protocol=None,
|
||||
|
|
@ -2041,7 +2039,7 @@ def delete_network_acl_entry(network_acl_id=None, rule_number=None, egress=None,
|
|||
log.warning('Network ACL was not deleted')
|
||||
return {'deleted': deleted}
|
||||
except BotoServerError as e:
|
||||
return {'deleted': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'deleted': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def create_route_table(vpc_id=None, vpc_name=None, route_table_name=None,
|
||||
|
|
@ -2177,7 +2175,7 @@ def route_exists(destination_cidr_block, route_table_name=None, route_table_id=N
|
|||
log.warning('Route %s does not exist.', destination_cidr_block)
|
||||
return {'exists': False}
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def associate_route_table(route_table_id=None, subnet_id=None,
|
||||
|
|
@ -2229,7 +2227,7 @@ def associate_route_table(route_table_id=None, subnet_id=None,
|
|||
route_table_id, subnet_id)
|
||||
return {'association_id': association_id}
|
||||
except BotoServerError as e:
|
||||
return {'associated': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'associated': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def disassociate_route_table(association_id, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -2256,7 +2254,7 @@ def disassociate_route_table(association_id, region=None, key=None, keyid=None,
|
|||
log.warning('Route table with association id %s has not been disassociated.', association_id)
|
||||
return {'disassociated': False}
|
||||
except BotoServerError as e:
|
||||
return {'disassociated': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'disassociated': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def replace_route_table_association(association_id, route_table_id, region=None, key=None, keyid=None, profile=None):
|
||||
|
|
@ -2278,7 +2276,7 @@ def replace_route_table_association(association_id, route_table_id, region=None,
|
|||
route_table_id, association_id)
|
||||
return {'replaced': True, 'association_id': association_id}
|
||||
except BotoServerError as e:
|
||||
return {'replaced': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'replaced': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def create_route(route_table_id=None, destination_cidr_block=None,
|
||||
|
|
@ -2359,7 +2357,7 @@ def create_route(route_table_id=None, destination_cidr_block=None,
|
|||
nat_gateway_id = gws[0]['NatGatewayId']
|
||||
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
if not nat_gateway_id:
|
||||
return _create_resource('route', route_table_id=route_table_id,
|
||||
|
|
@ -2375,7 +2373,7 @@ def create_route(route_table_id=None, destination_cidr_block=None,
|
|||
NatGatewayId=nat_gateway_id)
|
||||
return {'created': True, 'id': ret.get('NatGatewayId')}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def delete_route(route_table_id=None, destination_cidr_block=None,
|
||||
|
|
@ -2408,7 +2406,7 @@ def delete_route(route_table_id=None, destination_cidr_block=None,
|
|||
return {'created': False,
|
||||
'error': {'message': 'route table {0} does not exist.'.format(route_table_name)}}
|
||||
except BotoServerError as e:
|
||||
return {'created': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'created': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
return _delete_resource(resource='route', resource_id=route_table_id,
|
||||
destination_cidr_block=destination_cidr_block,
|
||||
|
|
@ -2464,7 +2462,7 @@ def replace_route(route_table_id=None, destination_cidr_block=None,
|
|||
)
|
||||
return {'replaced': False}
|
||||
except BotoServerError as e:
|
||||
return {'replaced': False, 'error': salt.utils.boto.get_error(e)}
|
||||
return {'replaced': False, 'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def describe_route_table(route_table_id=None, route_table_name=None,
|
||||
|
|
@ -2525,7 +2523,7 @@ def describe_route_table(route_table_id=None, route_table_name=None,
|
|||
return route_table
|
||||
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def describe_route_tables(route_table_id=None, route_table_name=None,
|
||||
|
|
@ -2611,7 +2609,7 @@ def describe_route_tables(route_table_id=None, route_table_name=None,
|
|||
return tables
|
||||
|
||||
except BotoServerError as e:
|
||||
return {'error': salt.utils.boto.get_error(e)}
|
||||
return {'error': __utils__['boto.get_error'](e)}
|
||||
|
||||
|
||||
def _create_dhcp_options(conn, domain_name=None, domain_name_servers=None, ntp_servers=None, netbios_name_servers=None,
|
||||
|
|
@ -2821,7 +2819,7 @@ def request_vpc_peering_connection(requester_vpc_id=None, requester_vpc_name=Non
|
|||
return {'msg': msg}
|
||||
except botocore.exceptions.ClientError as err:
|
||||
log.error('Got an error while trying to request vpc peering')
|
||||
return {'error': salt.utils.boto.get_error(err)}
|
||||
return {'error': __utils__['boto.get_error'](err)}
|
||||
|
||||
|
||||
def _get_peering_connection_ids(name, conn):
|
||||
|
|
@ -2948,7 +2946,7 @@ def accept_vpc_peering_connection( # pylint: disable=too-many-arguments
|
|||
return {'msg': 'VPC peering connection accepted.'}
|
||||
except botocore.exceptions.ClientError as err:
|
||||
log.error('Got an error while trying to accept vpc peering')
|
||||
return {'error': salt.utils.boto.get_error(err)}
|
||||
return {'error': __utils__['boto.get_error'](err)}
|
||||
|
||||
|
||||
def _vpc_peering_conn_id_for_name(name, conn):
|
||||
|
|
@ -3026,7 +3024,7 @@ def delete_vpc_peering_connection(conn_id=None, conn_name=None, region=None,
|
|||
conn.delete_vpc_peering_connection(DryRun=dry_run, VpcPeeringConnectionId=conn_id)
|
||||
return {'msg': 'VPC peering connection deleted.'}
|
||||
except botocore.exceptions.ClientError as err:
|
||||
e = salt.utils.boto.get_error(err)
|
||||
e = __utils__['boto.get_error'](err)
|
||||
log.error('Failed to delete VPC peering %s: %s', conn_name or conn_id, e)
|
||||
return {'error': e}
|
||||
|
||||
|
|
|
|||
|
|
@ -19,8 +19,6 @@ Example Usage:
|
|||
|
||||
.. code-block:: python
|
||||
|
||||
import salt.utils.boto3
|
||||
|
||||
def __virtual__():
|
||||
# only required in 2015.2
|
||||
salt.utils.compat.pack_dunder(__name__)
|
||||
|
|
|
|||
|
|
@ -19,8 +19,6 @@ Example Usage:
|
|||
|
||||
.. code-block:: python
|
||||
|
||||
import salt.utils.boto
|
||||
|
||||
def __virtual__():
|
||||
# only required in 2015.2
|
||||
salt.utils.compat.pack_dunder(__name__)
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue