diff options
| -rwxr-xr-x | scripts/simple_local_consumer.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/scripts/simple_local_consumer.py b/scripts/simple_local_consumer.py index 1c8f97dd..87c65868 100755 --- a/scripts/simple_local_consumer.py +++ b/scripts/simple_local_consumer.py @@ -13,6 +13,10 @@ Config:: # query to call dst_query = select * from somefunc(%%(pgq.ev_data)s); + + ## Use table_filter where possible instead of this ## + # filter for events (SQL fragment) + consumer_filter = ev_extra1 = 'public.mytable1' """ @@ -30,6 +34,8 @@ class SimpleLocalConsumer(pgq.LocalConsumer): def reload(self): super(SimpleLocalConsumer, self).reload() self.dst_query = self.cf.get("dst_query") + if self.cf.get("consumer_filter", ""): + self.consumer_filter = self.cf.get("consumer_filter", "") def process_local_event(self, db, batch_id, ev): curs = self.get_database('dst_db', autocommit = 1).cursor() |