commit
885c7c50fb
5
NEWS.md
5
NEWS.md
@ -1,3 +1,8 @@
|
|||||||
|
Mar 4th, 2019
|
||||||
|
==============
|
||||||
|
* Version `0.21.2` of the python library
|
||||||
|
* Fixed TomTom Qps respondes (#546)
|
||||||
|
|
||||||
Feb 25th, 2019
|
Feb 25th, 2019
|
||||||
==============
|
==============
|
||||||
* Version `0.26.2` of the client extension
|
* Version `0.26.2` of the client extension
|
||||||
|
@ -2,13 +2,17 @@ import time
|
|||||||
import random
|
import random
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from exceptions import TimeoutException
|
from exceptions import TimeoutException
|
||||||
|
import re
|
||||||
|
|
||||||
DEFAULT_RETRY_TIMEOUT = 60
|
DEFAULT_RETRY_TIMEOUT = 60
|
||||||
DEFAULT_QUERIES_PER_SECOND = 10
|
DEFAULT_QUERIES_PER_SECOND = 10
|
||||||
|
|
||||||
TOMTOM_403_RATE_LIMIT_HEADER = 'Account Over Queries Per Second Limit'
|
TOMTOM_403_RATE_LIMIT_HEADERS = [
|
||||||
|
'Account Over Queries Per Second Limit',
|
||||||
|
'Developer Over Qps'
|
||||||
|
]
|
||||||
TOMTOM_DETAIL_HEADER = 'X-Error-Detail-Header'
|
TOMTOM_DETAIL_HEADER = 'X-Error-Detail-Header'
|
||||||
|
TOMTOM_403_RATE_LIMIT_HEADER_PATTERN = re.compile('|'.join(TOMTOM_403_RATE_LIMIT_HEADERS), re.IGNORECASE)
|
||||||
|
|
||||||
def qps_retry(original_function=None, **options):
|
def qps_retry(original_function=None, **options):
|
||||||
""" Query Per Second retry decorator
|
""" Query Per Second retry decorator
|
||||||
@ -49,9 +53,11 @@ class QPSService:
|
|||||||
response = getattr(e, 'response', None)
|
response = getattr(e, 'response', None)
|
||||||
if response is not None:
|
if response is not None:
|
||||||
if self._provider is not None and self._provider == 'tomtom' and (response.status_code == 403):
|
if self._provider is not None and self._provider == 'tomtom' and (response.status_code == 403):
|
||||||
if response.headers.get(TOMTOM_DETAIL_HEADER) != TOMTOM_403_RATE_LIMIT_HEADER:
|
detail_header = response.headers.get(TOMTOM_DETAIL_HEADER)
|
||||||
|
if detail_header and TOMTOM_403_RATE_LIMIT_HEADER_PATTERN.search(detail_header):
|
||||||
|
self.retry(start_time, attempt_number)
|
||||||
|
else:
|
||||||
raise e
|
raise e
|
||||||
self.retry(start_time, attempt_number)
|
|
||||||
elif response.status_code == 429:
|
elif response.status_code == 429:
|
||||||
self.retry(start_time, attempt_number)
|
self.retry(start_time, attempt_number)
|
||||||
else:
|
else:
|
||||||
|
@ -10,7 +10,7 @@ from setuptools import setup, find_packages
|
|||||||
setup(
|
setup(
|
||||||
name='cartodb_services',
|
name='cartodb_services',
|
||||||
|
|
||||||
version='0.21.1',
|
version='0.21.2',
|
||||||
|
|
||||||
description='CartoDB Services API Python Library',
|
description='CartoDB Services API Python Library',
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user