diff options
Diffstat (limited to 'python/londiste')
| -rw-r--r-- | python/londiste/playback.py | 4 | ||||
| -rw-r--r-- | python/londiste/setup.py | 2 | ||||
| -rw-r--r-- | python/londiste/syncer.py | 6 | ||||
| -rw-r--r-- | python/londiste/util.py | 2 |
4 files changed, 9 insertions, 5 deletions
diff --git a/python/londiste/playback.py b/python/londiste/playback.py index f264363d..1c60c97b 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -276,6 +276,10 @@ class Replicator(CascadedWorker): # target database db = dbname=somedb host=127.0.0.1 + # extra connect string parameters to add to node public connect strings. + # useful values: user= sslmode= + #remote_extra_connstr = + # how many tables can be copied in parallel #parallel_copies = 1 diff --git a/python/londiste/setup.py b/python/londiste/setup.py index c764d49b..a7dbb13e 100644 --- a/python/londiste/setup.py +++ b/python/londiste/setup.py @@ -537,7 +537,7 @@ class LondisteSetup(CascadeAdmin): q = 'select * from pgq_node.get_node_info(%s)' res = self.exec_cmd(db, q, [self.queue_name], quiet = True) self.provider_location = res[0]['provider_location'] - return self.get_database('provider_db', connstr = self.provider_location) + return self.get_database('provider_db', connstr = self.provider_location, profile = 'remote') def expand_arg_list(self, db, kind, existing, args, needs_tbl=True): curs = db.cursor() diff --git a/python/londiste/syncer.py b/python/londiste/syncer.py index 1713f6e9..9837696c 100644 --- a/python/londiste/syncer.py +++ b/python/londiste/syncer.py @@ -166,10 +166,10 @@ class Syncer(skytools.DBScript): def process_one_table(self, tbl, t2, dst_db, provider_node, provider_loc): - lock_db = self.get_database('lock_db', connstr = provider_loc) - setup_db = self.get_database('setup_db', autocommit = 1, connstr = provider_loc) + lock_db = self.get_database('lock_db', connstr = provider_loc, profile = 'remote') + setup_db = self.get_database('setup_db', autocommit = 1, connstr = provider_loc, profile = 'remote') - src_db = self.get_database('provider_db', connstr = provider_loc, + src_db = self.get_database('provider_db', connstr = provider_loc, profile = 'remote', isolation_level = skytools.I_REPEATABLE_READ) setup_curs = setup_db.cursor() diff --git a/python/londiste/util.py b/python/londiste/util.py index c01ebdcf..cba18f62 100644 --- a/python/londiste/util.py +++ b/python/londiste/util.py @@ -28,7 +28,7 @@ def find_copy_source(script, queue_name, copy_table_name, node_name, node_locati worker_name = None while 1: - src_db = script.get_database('_source_db', connstr = node_location, autocommit = 1) + src_db = script.get_database('_source_db', connstr = node_location, autocommit = 1, profile = 'remote') src_curs = src_db.cursor() q = "select * from pgq_node.get_node_info(%s)" |