archive
/
ansible
mirror of https://github.com/ansible/ansible.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed multiline string formatting issues

Browse Source
reviewable/pr18780/r1
pascalheraud 9 years ago committed by Toshio Kuratomi
parent 9058f1fb76
commit 39f36103d7
1 changed files with 78 additions and 75 deletions
Show Stats Download Patch File Download Diff File

145
cloud/ovh/ovh_ip_loadbalancing_backend.py
Unescape Escape View File

@ -19,11 +19,11 @@ module: ovh_ip_loadbalancing_backend
short_description: Manage OVH IP LoadBalancing backends short_description: Manage OVH IP LoadBalancing backends
description: description:
- Manage OVH (French European hosting provider) LoadBalancing IP backends - Manage OVH (French European hosting provider) LoadBalancing IP backends
version_added: "2.1" version_added: "2.2"
author: Pascal HERAUD @pascalheraud author: Pascal HERAUD @pascalheraud
notes: notes:
- Uses the python OVH Api U(https://github.com/ovh/python-ovh). \ - Uses the python OVH Api U(https://github.com/ovh/python-ovh).
You have to create an application (a key and secret) with a consummer \ You have to create an application (a key and secret) with a consummer
key as described into U(https://eu.api.ovh.com/g934.first_step_with_api) key as described into U(https://eu.api.ovh.com/g934.first_step_with_api)
requirements: requirements:
- ovh > 0.3.5 - ovh > 0.3.5
@ -41,7 +41,7 @@ options:
default: present default: present
choices: ['present', 'absent'] choices: ['present', 'absent']
description: description:
- Determines wether the backend is to be created/modified \ - Determines wether the backend is to be created/modified
or deleted or deleted
probe: probe:
required: false required: false
@ -75,24 +75,24 @@ options:
type: "int" type: "int"
default: 120 default: 120
description: description:
- The timeout in seconds used to wait for a task to be \ - The timeout in seconds used to wait for a task to be
completed. Default is 120 seconds. completed. Default is 120 seconds.
''' '''
EXAMPLES = ''' EXAMPLES = '''
# Adds or modify the backend '212.1.1.1' to a \ # Adds or modify the backend '212.1.1.1' to a
loadbalancing 'ip-1.1.1.1' # loadbalancing 'ip-1.1.1.1'
- ovh_ip_loadbalancing name=ip-1.1.1.1 backend=212.1.1.1 \ - ovh_ip_loadbalancing name=ip-1.1.1.1 backend=212.1.1.1
state=present probe=none weight=8 \ state=present probe=none weight=8
endpoint=ovh-eu application_key=yourkey \ endpoint=ovh-eu application_key=yourkey
application_secret=yoursecret consumer_key=yourconsumerkey application_secret=yoursecret consumer_key=yourconsumerkey
# Removes a backend '212.1.1.1' from a loadbalancing \ # Removes a backend '212.1.1.1' from a loadbalancing
'ip-1.1.1.1' # 'ip-1.1.1.1'
- ovh_ip_loadbalancing name=ip-1.1.1.1 backend=212.1.1.1 - ovh_ip_loadbalancing name=ip-1.1.1.1 backend=212.1.1.1
state=absent endpoint=ovh-eu application_key=yourkey \ state=absent endpoint=ovh-eu application_key=yourkey
application_secret=yoursecret consumer_key=yourconsumerkey application_secret=yoursecret consumer_key=yourconsumerkey
''' '''
RETURN = ''' RETURN = '''
@ -123,7 +123,7 @@ def getOvhClient(ansibleModule):
def waitForNoTask(client, name, timeout): def waitForNoTask(client, name, timeout):
currentTimeout = timeout currentTimeout = timeout
while len(client.get('/ip/loadBalancing/{}/task'.format(name))) > 0: while len(client.get('/ip/loadBalancing/{0}/task'.format(name))) > 0:
time.sleep(1) # Delay for 1 sec time.sleep(1) # Delay for 1 sec
currentTimeout -= 1 currentTimeout -= 1
if currentTimeout < 0: if currentTimeout < 0:
@ -149,8 +149,8 @@ def main():
) )
if not HAS_OVH: if not HAS_OVH:
module.fail_json(msg='ovh-api python module\ module.fail_json(msg='ovh-api python module'
is required to run this module ') 'is required to run this module ')
# Get parameters # Get parameters
name = module.params.get('name') name = module.params.get('name')
@ -168,34 +168,34 @@ def main():
loadBalancings = client.get('/ip/loadBalancing') loadBalancings = client.get('/ip/loadBalancing')
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for getting the list of loadBalancing, \ msg='Unable to call OVH api for getting the list of loadBalancing, '
check application key, secret, consumerkey and parameters. \ 'check application key, secret, consumerkey and parameters. '
Error returned by OVH api was : {}'.format(apiError)) 'Error returned by OVH api was : {0}'.format(apiError))
if name not in loadBalancings: if name not in loadBalancings:
module.fail_json(msg='IP LoadBalancing {} does not exist'.format(name)) module.fail_json(msg='IP LoadBalancing {0} does not exist'.format(name))
# Check that no task is pending before going on # Check that no task is pending before going on
try: try:
if not waitForNoTask(client, name, timeout): if not waitForNoTask(client, name, timeout):
module.fail_json( module.fail_json(
msg='Timeout of {} seconds while waiting for no pending \ msg='Timeout of {0} seconds while waiting for no pending '
tasks before executing the module '.format(timeout)) 'tasks before executing the module '.format(timeout))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for getting the list of pending tasks \ msg='Unable to call OVH api for getting the list of pending tasks '
of the loadBalancing, check application key, secret, consumerkey \ 'of the loadBalancing, check application key, secret, consumerkey '
and parameters. Error returned by OVH api was : {}\ 'and parameters. Error returned by OVH api was : {0}'
'.format(apiError)) .format(apiError))
try: try:
backends = client.get('/ip/loadBalancing/{}/backend'.format(name)) backends = client.get('/ip/loadBalancing/{0}/backend'.format(name))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for getting the list of backends \ msg='Unable to call OVH api for getting the list of backends '
of the loadBalancing, check application key, secret, consumerkey \ 'of the loadBalancing, check application key, secret, consumerkey '
and parameters. Error returned by OVH api was : {}\ 'and parameters. Error returned by OVH api was : {0}'
'.format(apiError)) .format(apiError))
backendExists = backend in backends backendExists = backend in backends
moduleChanged = False moduleChanged = False
@ -204,47 +204,48 @@ def main():
# Remove backend # Remove backend
try: try:
client.delete( client.delete(
'/ip/loadBalancing/{}/backend/{}'.format(name, backend)) '/ip/loadBalancing/{0}/backend/{1}'.format(name, backend))
if not waitForNoTask(client, name, timeout): if not waitForNoTask(client, name, timeout):
module.fail_json( module.fail_json(
msg='Timeout of {} seconds while waiting for completion \ msg='Timeout of {0} seconds while waiting for completion '
of removing backend task'.format(timeout)) 'of removing backend task'.format(timeout))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for deleting the backend, \ msg='Unable to call OVH api for deleting the backend, '
check application key, secret, consumerkey and \ 'check application key, secret, consumerkey and '
parameters. Error returned by OVH api was : {}\ 'parameters. Error returned by OVH api was : {0}'
'.format(apiError)) .format(apiError))
moduleChanged = True moduleChanged = True
else: else:
if backendExists: if backendExists:
# Get properties # Get properties
try: try:
backendProperties = client.get( backendProperties = client.get(
'/ip/loadBalancing/{}/backend/{}'.format(name, backend)) '/ip/loadBalancing/{0}/backend/{1}'.format(name, backend))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for getting the backend properties, \ msg='Unable to call OVH api for getting the backend properties, '
check application key, secret, consumerkey and \ 'check application key, secret, consumerkey and '
parameters. Error returned by OVH api was : {}\ 'parameters. Error returned by OVH api was : {0}'
'.format(apiError)) .format(apiError))
if (backendProperties['weight'] != weight): if (backendProperties['weight'] != weight):
# Change weight # Change weight
try: try:
client.post( client.post(
'/ip/loadBalancing/{}/backend/{}/setWeight\ '/ip/loadBalancing/{0}/backend/{1}/setWeight'
'.format(name, backend), weight=weight) .format(name, backend), weight=weight)
if not waitForNoTask(client, name, timeout): if not waitForNoTask(client, name, timeout):
module.fail_json( module.fail_json(
msg='Timeout of {} seconds while waiting for completion \ msg='Timeout of {0} seconds while waiting for completion '
of setWeight to backend task'.format(timeout)) 'of setWeight to backend task'
.format(timeout))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for updating the weight of the \ msg='Unable to call OVH api for updating the weight of the '
backend, check application key, secret, consumerkey \ 'backend, check application key, secret, consumerkey '
and parameters. Error returned by OVH api was : {}\ 'and parameters. Error returned by OVH api was : {0}'
'.format(apiError)) .format(apiError))
moduleChanged = True moduleChanged = True
if (backendProperties['probe'] != probe): if (backendProperties['probe'] != probe):
@ -252,42 +253,44 @@ def main():
backendProperties['probe'] = probe backendProperties['probe'] = probe
try: try:
client.put( client.put(
'/ip/loadBalancing/{}/backend/{}\ '/ip/loadBalancing/{0}/backend/{1}'
'.format(name, backend), probe=probe) .format(name, backend), probe=probe)
if not waitForNoTask(client, name, timeout): if not waitForNoTask(client, name, timeout):
module.fail_json( module.fail_json(
msg='Timeout of {} seconds while waiting for completion of \ msg='Timeout of {0} seconds while waiting for completion of '
setProbe to backend task'.format(timeout)) 'setProbe to backend task'
.format(timeout))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for updating the propbe of \ msg='Unable to call OVH api for updating the propbe of '
the backend, check application key, secret, \ 'the backend, check application key, secret, '
consumerkey and parameters. Error returned by OVH api \ 'consumerkey and parameters. Error returned by OVH api '
was : {}\ 'was : {0}'
'.format(apiError)) .format(apiError))
moduleChanged = True moduleChanged = True
else: else:
# Creates backend # Creates backend
try: try:
try: try:
client.post('/ip/loadBalancing/{}/backend'.format(name), client.post('/ip/loadBalancing/{0}/backend'.format(name),
ipBackend=backend, probe=probe, weight=weight) ipBackend=backend, probe=probe, weight=weight)
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for creating the backend, check \ msg='Unable to call OVH api for creating the backend, check '
application key, secret, consumerkey and parameters. \ 'application key, secret, consumerkey and parameters. '
Error returned by OVH api was : {}'.format(apiError)) 'Error returned by OVH api was : {0}'
.format(apiError))
if not waitForNoTask(client, name, timeout): if not waitForNoTask(client, name, timeout):
module.fail_json( module.fail_json(
msg='Timeout of {} seconds while waiting for completion of \ msg='Timeout of {0} seconds while waiting for completion of '
backend creation task'.format(timeout)) 'backend creation task'.format(timeout))
except APIError as apiError: except APIError as apiError:
module.fail_json( module.fail_json(
msg='Unable to call OVH api for creating the backend, check \ msg='Unable to call OVH api for creating the backend, check '
application key, secret, consumerkey and parameters. \ 'application key, secret, consumerkey and parameters. '
Error returned by OVH api was : {}'.format(apiError)) 'Error returned by OVH api was : {0}'.format(apiError))
moduleChanged = True moduleChanged = True
module.exit_json(changed=moduleChanged) module.exit_json(changed=moduleChanged)

Write Preview
Loading…
Cancel
Save