From ea9d3a5525b67718d74d3a5d3a12acfef687521a Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Fri, 11 Feb 2011 15:34:44 +0200 Subject: [PATCH] londiste: new qtable handler --- python/londiste/handlers/__init__.py | 5 ++++- python/londiste/handlers/qtable.py | 22 ++++++++++++++++++++++ 2 files changed, 26 insertions(+), 1 deletion(-) create mode 100644 python/londiste/handlers/qtable.py diff --git a/python/londiste/handlers/__init__.py b/python/londiste/handlers/__init__.py index c5de83c6..8dd6b7fc 100644 --- a/python/londiste/handlers/__init__.py +++ b/python/londiste/handlers/__init__.py @@ -1,4 +1,7 @@ # handlers module -DEFAULT_HANDLERS = ['londiste.handlers.bulk'] +DEFAULT_HANDLERS = [ + 'londiste.handlers.bulk', + 'londiste.handlers.qtable', +] diff --git a/python/londiste/handlers/qtable.py b/python/londiste/handlers/qtable.py new file mode 100644 index 00000000..f32bb1eb --- /dev/null +++ b/python/londiste/handlers/qtable.py @@ -0,0 +1,22 @@ +""" +Dummy handler to setup queue tables. All events are ignored. +""" + +from londiste.handler import BaseHandler + +__all__ = ['QueueTableHandler'] + +class QueueTableHandler(BaseHandler): + """Queue table handler. Do nothing""" + handler_name = 'qtable' + + def add(self, trigger_arg_list): + """Create SKIP and BEFORE INSERT trigger""" + trigger_arg_list.append('tgflags=BI') + trigger_arg_list.append('SKIP') + + def process_event(self, ev, sql_queue_func, arg): + """Ignore events for this table""" + +__londiste_handlers__ = [QueueTableHandler] + -- 2.39.5