Congegni
/
libretime
mirror of https://github.com/libretime/libretime.git
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added retrying mechanism to ApiRequest

This commit is contained in:
Rudi Grinberg 2012-10-31 12:20:00 -04:00
parent 4ef38cbc91
commit 83211698a4
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
python_apps/api_clients/api_client.py
View File

@ -76,6 +76,7 @@ class ApiRequest(object):
def __init__(self, name, url): def __init__(self, name, url):
self.name = name self.name = name
self.url = url self.url = url
self.__req = None
def __call__(self,_post_data=None, **kwargs): def __call__(self,_post_data=None, **kwargs):
# TODO : get rid of god damn urllib and replace everything with # TODO : get rid of god damn urllib and replace everything with
# grequests or requests at least # grequests or requests at least
@ -88,13 +89,17 @@ class ApiRequest(object):
try: return json.loads(response) try: return json.loads(response)
except ValueError: return response except ValueError: return response
def retry(self, n): def req(self, *args, **kwargs):
self.__req = lambda : self(*args, **kwargs)
return self
def retry(self, n, delay=5):
"""Try to send request n times. If after n times it fails then """Try to send request n times. If after n times it fails then
we finally raise exception""" we finally raise exception"""
for i in range(0,n-1): for i in range(0,n-1):
try: return self() try: return self.__req()
except Exception: pass except Exception: time.sleep(delay)
return self() return self.__req()
class RequestProvider(object): class RequestProvider(object):
""" Creates the available ApiRequest instance that can be read from """ Creates the available ApiRequest instance that can be read from
@ -174,9 +179,9 @@ class AirtimeApiClient(object):
else: else:
logger.debug(url) logger.debug(url)
#If the user passed in a positive attempts number then that means #If the user passed in a positive attempts number then that
#attempts will roll over 0 and we stop. If attempts was initially negative, #means attempts will roll over 0 and we stop. If attempts
#then we have unlimited attempts #was initially negative, then we have unlimited attempts
if attempts > 0: if attempts > 0:
attempts = attempts - 1 attempts = attempts - 1
if attempts == 0: if attempts == 0:
@ -377,14 +382,9 @@ class AirtimeApiClient(object):
def notify_liquidsoap_status(self, msg, stream_id, time): def notify_liquidsoap_status(self, msg, stream_id, time):
logger = self.logger logger = self.logger
try: try:
url = self.construct_url("update_liquidsoap_status")
msg = msg.replace('/', ' ')
encoded_msg = urllib.quote(msg, '') encoded_msg = urllib.quote(msg, '')
url = url.replace("%%msg%%", encoded_msg) self.update_liquidsoap_status.req(msg=encoded_msg, stream_id=stream_id,
url = url.replace("%%stream_id%%", stream_id) boot_time=time).retry(5)
url = url.replace("%%boot_time%%", time)
self.get_response_from_server(url, attempts = 5)
except Exception, e: except Exception, e:
logger.error("Exception: %s", e) logger.error("Exception: %s", e)