1 files changed, 69 insertions, 0 deletions
diff --git a/src/consolidation_run b/src/consolidation_run
new file mode 100755
index 0000000..7ef1a5c
--- /dev/null
+++ b/src/consolidation_run
@@ -0,0 +1,69 @@
+#!/usr/bin/env  python
+
+# Copyright (C) 2012, Gustavo Duarte
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+import argparse
+import logging
+
+from sugar_stats_consolidation.db import *
+from sugar_stats_consolidation.rrd_files import *
+from sugar_stats_consolidation.consolidation import *
+	
+parser = argparse.ArgumentParser()	
+parser.add_argument('--db_user',required=True)
+parser.add_argument('--db_pass',required=True)
+parser.add_argument('--db_name',required=True)
+parser.add_argument('--rrd_path',required=True)
+parser.add_argument('--log_path',required=True)
+
+args = parser.parse_args()
+
+
+_LOG_FORMAT='[%(asctime)s]-%(levelname)s-\'%(name)s\': %(message)s'
+
+logging.basicConfig(filename=os.path.join(args.log_path,'sugar-stats-consolidation.log'), format=_LOG_FORMAT, level=logging.DEBUG)
+log = logging.getLogger(__name__)
+
+def main():
+
+	
+	log.info('**************************************')
+	log.info('       Starting consolidation         ')
+	log.info('**************************************')
+	
+	
+	try:
+		db = DB_Stats (args.db_name, args.db_user, args.db_pass)
+		db.create()
+	except Exception as e:
+		log.warning('Creating DB: %s', str(e))
+
+
+	try:
+		con = Consolidation(args.rrd_path, db)
+		con.process_rrds()
+		db.close()
+	
+		log.info('**************************************')
+		log.info('       Finish consolidation           ')
+		log.info('**************************************')
+	except Exception as e:
+		log.warning('Processing rrd file: %s', str(e))
+
+
+
+if __name__ == '__main__':
+    main()