Mario de Frutos
2f6d067b4e
If we pass JSON as string, with scape characters and so on, we are going to have problems parsing that metrics in ES
40 lines
2.0 KiB
PL/PgSQL
40 lines
2.0 KiB
PL/PgSQL
--DO NOT MODIFY THIS FILE, IT IS GENERATED AUTOMATICALLY FROM SOURCES
|
|
-- Complain if script is sourced in psql, rather than via CREATE EXTENSION
|
|
\echo Use "ALTER EXTENSION cdb_dataservices_server UPDATE TO '0.34.0'" to load this file. \quit
|
|
|
|
-- HERE goes your code to upgrade/downgrade
|
|
CREATE OR REPLACE FUNCTION cdb_dataservices_server._cdb_bulk_geocode_street_point(username TEXT, orgname TEXT, searches jsonb)
|
|
RETURNS SETOF cdb_dataservices_server.geocoding AS $$
|
|
from cartodb_services.metrics import metrics
|
|
from cartodb_services.tools import Logger
|
|
import json
|
|
|
|
plpy.execute("SELECT cdb_dataservices_server._connect_to_redis('{0}')".format(username))
|
|
redis_conn = GD["redis_connection_{0}".format(username)]['redis_metrics_connection']
|
|
|
|
plpy.execute("SELECT cdb_dataservices_server._get_geocoder_config({0}, {1})".format(plpy.quote_nullable(username), plpy.quote_nullable(orgname)))
|
|
user_geocoder_config = GD["user_geocoder_config_{0}".format(username)]
|
|
|
|
plpy.execute("SELECT cdb_dataservices_server._get_logger_config()")
|
|
logger_config = GD["logger_config"]
|
|
logger = Logger(logger_config)
|
|
|
|
params = {'username': username, 'orgname': orgname, 'searches': searches}
|
|
|
|
with metrics('cdb_bulk_geocode_street_point', user_geocoder_config, logger, params):
|
|
if user_geocoder_config.google_geocoder:
|
|
provider_function = "_cdb_bulk_google_geocode_street_point";
|
|
elif user_geocoder_config.heremaps_geocoder:
|
|
provider_function = "_cdb_bulk_heremaps_geocode_street_point";
|
|
elif user_geocoder_config.tomtom_geocoder:
|
|
provider_function = "_cdb_bulk_tomtom_geocode_street_point";
|
|
elif user_geocoder_config.mapbox_geocoder:
|
|
provider_function = "_cdb_bulk_mapbox_geocode_street_point";
|
|
else:
|
|
raise Exception('Requested geocoder is not available')
|
|
|
|
plan = plpy.prepare("SELECT * FROM cdb_dataservices_server.{}($1, $2, $3); ".format(provider_function), ["text", "text", "jsonb"])
|
|
return plpy.execute(plan, [username, orgname, searches])
|
|
|
|
$$ LANGUAGE plpythonu STABLE PARALLEL RESTRICTED;
|