21aac960a6
Add routing with waypoints functions to client and server. Includes signature checks tests for the Postgresql functions and unit and integration tests for the Python library. Add client v0.6.0 and server v0.9.0
64 lines
2.4 KiB
PL/PgSQL
64 lines
2.4 KiB
PL/PgSQL
CREATE TYPE cdb_dataservices_server.simple_route AS (
|
|
shape geometry(LineString,4326),
|
|
length real,
|
|
duration integer
|
|
);
|
|
|
|
CREATE OR REPLACE FUNCTION cdb_dataservices_server._cdb_mapzen_route_with_waypoints(
|
|
username TEXT,
|
|
orgname TEXT,
|
|
waypoints geometry(Point, 4326)[],
|
|
mode TEXT,
|
|
options text[] DEFAULT ARRAY[]::text[],
|
|
units text DEFAULT 'kilometers')
|
|
RETURNS cdb_dataservices_server.simple_route AS $$
|
|
import json
|
|
from cartodb_services.mapzen import MapzenRouting, MapzenRoutingResponse
|
|
from cartodb_services.mapzen.types import polyline_to_linestring
|
|
from cartodb_services.metrics import QuotaService
|
|
from cartodb_services.tools import Coordinate
|
|
|
|
redis_conn = GD["redis_connection_{0}".format(username)]['redis_metrics_connection']
|
|
user_routing_config = GD["user_routing_config_{0}".format(username)]
|
|
|
|
quota_service = QuotaService(user_routing_config, redis_conn)
|
|
if not quota_service.check_user_quota():
|
|
plpy.error('You have reached the limit of your quota')
|
|
|
|
try:
|
|
client = MapzenRouting(user_routing_config.mapzen_api_key)
|
|
|
|
if not waypoints or len(waypoints) < 2:
|
|
plpy.notice("Empty origin or destination")
|
|
quota_service.increment_empty_service_use()
|
|
return [None, None, None]
|
|
|
|
waypoint_coords = []
|
|
for waypoint in waypoints:
|
|
lat = plpy.execute("SELECT ST_Y('%s') AS lat" % waypoint)[0]['lat']
|
|
lon = plpy.execute("SELECT ST_X('%s') AS lon" % waypoint)[0]['lon']
|
|
waypoint_coords.append(Coordinate(lon,lat))
|
|
|
|
resp = client.calculate_route_point_to_point(waypoint_coords, mode, options, units)
|
|
if resp and resp.shape:
|
|
shape_linestring = polyline_to_linestring(resp.shape)
|
|
if shape_linestring:
|
|
quota_service.increment_success_service_use()
|
|
return [shape_linestring, resp.length, resp.duration]
|
|
else:
|
|
quota_service.increment_empty_service_use()
|
|
return [None, None, None]
|
|
else:
|
|
quota_service.increment_empty_service_use()
|
|
return [None, None, None]
|
|
except BaseException as e:
|
|
import sys, traceback
|
|
type_, value_, traceback_ = sys.exc_info()
|
|
quota_service.increment_failed_service_use()
|
|
error_msg = 'There was an error trying to obtain route using mapzen provider: {0}'.format(e)
|
|
plpy.notice(traceback.format_tb(traceback_))
|
|
plpy.error(error_msg)
|
|
finally:
|
|
quota_service.increment_total_service_use()
|
|
$$ LANGUAGE plpythonu SECURITY DEFINER;
|