summaryrefslogtreecommitdiff
path: root/scripts/queue_splitter.py
diff options
context:
space:
mode:
Diffstat (limited to 'scripts/queue_splitter.py')
-rwxr-xr-xscripts/queue_splitter.py23
1 files changed, 21 insertions, 2 deletions
diff --git a/scripts/queue_splitter.py b/scripts/queue_splitter.py
index 0a949dfc..29ee0db0 100755
--- a/scripts/queue_splitter.py
+++ b/scripts/queue_splitter.py
@@ -1,11 +1,30 @@
#! /usr/bin/env python
-"""Puts events into queue specified by field from 'queue_field' config parameter"""
+"""Puts events into queue specified by field from 'queue_field' config parameter.
+
+Config template::
+
+ [queue_splitter]
+ job_name = queue_splitter_test
+
+ src_db = dbname=sourcedb_test
+ dst_db = dbname=destdb_test
+
+ pgq_queue_name = source_queue
+
+ # event fields from where target queue name is read
+ #queue_field = extra1
+
+ logfile = ~/log/%(job_name)s.log
+ pidfile = ~/pid/%(job_name)s.pid
+ use_skylog = 0
+"""
import sys, pgq
class QueueSplitter(pgq.SerialConsumer):
- """Split events from one queue into several."""
+ __doc__ = __doc__
+
def __init__(self, args):
pgq.SerialConsumer.__init__(self, "queue_splitter", "src_db", "dst_db", args)