Merge pull request #351 from CartoDB/remove_default_tis_config
Remove default TIS config in Ghost Table function
This commit is contained in:
@@ -12,9 +12,13 @@ AS $$
|
|||||||
json = GD['json']
|
json = GD['json']
|
||||||
|
|
||||||
tis_config = plpy.execute("select cartodb.CDB_Conf_GetConf('invalidation_service');")[0]['cdb_conf_getconf']
|
tis_config = plpy.execute("select cartodb.CDB_Conf_GetConf('invalidation_service');")[0]['cdb_conf_getconf']
|
||||||
tis_config_dict = json.loads(tis_config) if tis_config else {}
|
if not tis_config:
|
||||||
tis_host = tis_config_dict.get('host', '127.0.0.1')
|
plpy.warning('Invalidation service configuration not found. Skipping Ghost Tables linking.')
|
||||||
tis_port = tis_config_dict.get('port', 3142)
|
return
|
||||||
|
|
||||||
|
tis_config_dict = json.loads(tis_config)
|
||||||
|
tis_host = tis_config_dict.get('host')
|
||||||
|
tis_port = tis_config_dict.get('port')
|
||||||
tis_timeout = tis_config_dict.get('timeout', 5)
|
tis_timeout = tis_config_dict.get('timeout', 5)
|
||||||
tis_retry = tis_config_dict.get('retry', 5)
|
tis_retry = tis_config_dict.get('retry', 5)
|
||||||
|
|
||||||
@@ -30,7 +34,7 @@ AS $$
|
|||||||
except Exception as err:
|
except Exception as err:
|
||||||
error = "client_error - %s" % str(err)
|
error = "client_error - %s" % str(err)
|
||||||
# NOTE: no retries on connection error
|
# NOTE: no retries on connection error
|
||||||
plpy.warning('Invalidation Service connection error: ' + str(err))
|
plpy.warning('Error trying to connect to Invalidation Service to link Ghost Tables: ' + str(err))
|
||||||
break
|
break
|
||||||
|
|
||||||
try:
|
try:
|
||||||
@@ -40,7 +44,7 @@ AS $$
|
|||||||
error = "request_error - %s" % str(err)
|
error = "request_error - %s" % str(err)
|
||||||
client = GD['invalidation'] = None # force reconnect
|
client = GD['invalidation'] = None # force reconnect
|
||||||
if not tis_retry:
|
if not tis_retry:
|
||||||
plpy.warning('Invalidation Service error: ' + str(err))
|
plpy.warning('Error calling Invalidation Service to link Ghost Tables: ' + str(err))
|
||||||
break
|
break
|
||||||
tis_retry -= 1 # try reconnecting
|
tis_retry -= 1 # try reconnecting
|
||||||
$$ LANGUAGE 'plpythonu' VOLATILE PARALLEL UNSAFE;
|
$$ LANGUAGE 'plpythonu' VOLATILE PARALLEL UNSAFE;
|
||||||
|
|||||||
@@ -7,12 +7,21 @@ GRANT ALL ON SCHEMA cartodb TO "fulano";
|
|||||||
GRANT SELECT ON cartodb.cdb_ddl_execution TO "fulano";
|
GRANT SELECT ON cartodb.cdb_ddl_execution TO "fulano";
|
||||||
GRANT EXECUTE ON FUNCTION CDB_Username() TO "fulano";
|
GRANT EXECUTE ON FUNCTION CDB_Username() TO "fulano";
|
||||||
GRANT EXECUTE ON FUNCTION CDB_LinkGhostTables(text) TO "fulano";
|
GRANT EXECUTE ON FUNCTION CDB_LinkGhostTables(text) TO "fulano";
|
||||||
INSERT INTO cdb_conf (key, value) VALUES ('api_keys_fulano', '{"username": "fulanito", "permissions":[]}');
|
SELECT cartodb.CDB_Conf_SetConf('api_keys_fulano', '{"username": "fulanito", "permissions":[]}');
|
||||||
INSERT INTO cdb_conf (key, value) VALUES ('invalidation_service', '{"host": "fake-tis-host"}');
|
DELETE FROM cdb_conf WHERE key = 'invalidation_service';
|
||||||
SET SESSION AUTHORIZATION "fulano";
|
SET SESSION AUTHORIZATION "fulano";
|
||||||
SET client_min_messages TO notice;
|
SET client_min_messages TO notice;
|
||||||
\set QUIET off
|
\set QUIET off
|
||||||
|
|
||||||
|
SELECT CDB_LinkGhostTables(); -- _CDB_LinkGhostTables called (configuration not found)
|
||||||
|
|
||||||
|
-- Add TIS configuration
|
||||||
|
\set QUIET on
|
||||||
|
SET SESSION AUTHORIZATION postgres;
|
||||||
|
SELECT cartodb.CDB_Conf_SetConf('invalidation_service', '{"host": "fake-tis-host", "port": 3142}');
|
||||||
|
SET SESSION AUTHORIZATION "fulano";
|
||||||
|
\set QUIET off
|
||||||
|
|
||||||
SELECT CDB_LinkGhostTables(); -- _CDB_LinkGhostTables called
|
SELECT CDB_LinkGhostTables(); -- _CDB_LinkGhostTables called
|
||||||
|
|
||||||
BEGIN;
|
BEGIN;
|
||||||
|
|||||||
@@ -1,5 +1,10 @@
|
|||||||
|
|
||||||
WARNING: Invalidation Service error: Error -2 connecting fake-tis-host:3142. Name or service not known.
|
|
||||||
|
WARNING: Invalidation service configuration not found. Skipping Ghost Tables linking.
|
||||||
|
NOTICE: _CDB_LinkGhostTables() called with username=fulanito, event_name=USER
|
||||||
|
|
||||||
|
|
||||||
|
WARNING: Error calling Invalidation Service to link Ghost Tables: Error -2 connecting fake-tis-host:3142. Name or service not known.
|
||||||
NOTICE: _CDB_LinkGhostTables() called with username=fulanito, event_name=USER
|
NOTICE: _CDB_LinkGhostTables() called with username=fulanito, event_name=USER
|
||||||
|
|
||||||
BEGIN
|
BEGIN
|
||||||
@@ -7,7 +12,7 @@ cdb_ddl_execution
|
|||||||
0
|
0
|
||||||
CREATE TABLE
|
CREATE TABLE
|
||||||
1
|
1
|
||||||
WARNING: Invalidation Service error: Error -2 connecting fake-tis-host:3142. Name or service not known.
|
WARNING: Error calling Invalidation Service to link Ghost Tables: Error -2 connecting fake-tis-host:3142. Name or service not known.
|
||||||
NOTICE: _CDB_LinkGhostTables() called with username=fulanito, event_name=CREATE TABLE
|
NOTICE: _CDB_LinkGhostTables() called with username=fulanito, event_name=CREATE TABLE
|
||||||
COMMIT
|
COMMIT
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user