cartodb4/dataservices-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Log a failed one if any

Browse Source
This commit is contained in:
Juan Ignacio Sánchez Lara 2018-07-23 17:23:08 +02:00
parent 07f5be9207
commit 5d2303e1de
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/lib/python/cartodb_services/cartodb_services/geocoder.py
View File

@ -51,6 +51,7 @@ def run_street_point_geocoder(plpy, GD, geocoder, service_manager, username, org
service_manager.assert_within_limits(quota=False) service_manager.assert_within_limits(quota=False)
geocode_results = geocoder.bulk_geocode(searches) geocode_results = geocoder.bulk_geocode(searches)
results = [] results = []
a_failed_one = None
if not geocode_results == EMPTY_BATCH_RESPONSE: if not geocode_results == EMPTY_BATCH_RESPONSE:
for result in geocode_results: for result in geocode_results:
if len(result) > 2: if len(result) > 2:
@ -64,6 +65,7 @@ def run_street_point_geocoder(plpy, GD, geocoder, service_manager, username, org
logger.warning('Geocoding error', logger.warning('Geocoding error',
data={"username": username, "orgname": orgname, "error": metadata['error']}) data={"username": username, "orgname": orgname, "error": metadata['error']})
results.append([result[0], None, json.dumps(metadata)]) results.append([result[0], None, json.dumps(metadata)])
a_failed_one = result
failed_count += 1 failed_count += 1
elif result[1] and len(result[1]) == 2: elif result[1] and len(result[1]) == 2:
plan = plpy.prepare("SELECT ST_SetSRID(ST_MakePoint($1, $2), 4326) as the_geom; ", ["double precision", "double precision"]) plan = plpy.prepare("SELECT ST_SetSRID(ST_MakePoint($1, $2), 4326) as the_geom; ", ["double precision", "double precision"])
@ -75,6 +77,13 @@ def run_street_point_geocoder(plpy, GD, geocoder, service_manager, username, org
empty_count = len(searches) - success_count - failed_count empty_count = len(searches) - success_count - failed_count
logger.debug("--> Success: {}; empty: {}; failed: {}".format(success_count, empty_count, failed_count)) logger.debug("--> Success: {}; empty: {}; failed: {}".format(success_count, empty_count, failed_count))
if a_failed_one:
logger.warning("failed geocoding",
data={
"username": username,
"orgname": orgname,
"failed": str(a_failed_one)
})
service_manager.quota_service.increment_success_service_use(success_count) service_manager.quota_service.increment_success_service_use(success_count)
service_manager.quota_service.increment_empty_service_use(empty_count) service_manager.quota_service.increment_empty_service_use(empty_count)
service_manager.quota_service.increment_failed_service_use(failed_count) service_manager.quota_service.increment_failed_service_use(failed_count)