diff options
| author | Gustavo Duarte <gduarte@activitycentral.com> | 2012-12-27 01:42:33 (GMT) |
|---|---|---|
| committer | Gustavo Duarte <gduarte@activitycentral.com> | 2012-12-27 01:42:33 (GMT) |
| commit | 8557dda9f33c0a7cc27b8254ca8250ee246b7713 (patch) | |
| tree | 71efbb8e592e3b8e3c5847e770fd30931861d92c /build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py | |
| parent | 084262ea16b2b352251065dc63a5bb19fcba93f7 (diff) | |
add queries
Diffstat (limited to 'build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py')
| -rw-r--r-- | build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py | 39 |
1 files changed, 21 insertions, 18 deletions
diff --git a/build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py b/build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py index 01d8b84..a1fd79a 100644 --- a/build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py +++ b/build/lib.linux-x86_64-2.7/stats_consolidation/consolidation.py @@ -1,3 +1,4 @@ +from __future__ import print_function import os import argparse @@ -14,22 +15,24 @@ class Consolidation: self.db = db def process_rrds (self): id_hash_list = os.listdir(unicode(self.base_path)) - if id_hash_list: - for id_hash in id_hash_list: - user_hash_list = os.listdir( unicode( os.path.join(self.base_path, id_hash) ) ) - if user_hash_list: - for user_hash in user_hash_list: - rrd_list = os.listdir( unicode(os.path.join(self.base_path, id_hash, user_hash)) ) - if rrd_list: - for rrd in rrd_list: - rrd_path = unicode (os.path.join(self.base_path, id_hash, user_hash) ) - rrd_obj = RRD (path=rrd_path, name=rrd, date_start=self.date_start, date_end=None) - self.db.store_activity_uptime(rrd_obj) - else: - print "None rrd file found" + os.path.join(self.base_path, id_hash, user_hash) - else: - print "None hash user found on: " + os.path.join(self.base_path, id_hash) - else: - print "None hash ids found on: " + self.base_path - + try: + if id_hash_list: + for id_hash in id_hash_list: + user_hash_list = os.listdir( unicode( os.path.join(self.base_path, id_hash) ) ) + if user_hash_list: + for user_hash in user_hash_list: + rrd_list = os.listdir( unicode(os.path.join(self.base_path, id_hash, user_hash)) ) + if rrd_list: + for rrd in rrd_list: + rrd_path = unicode (os.path.join(self.base_path, id_hash, user_hash) ) + rrd_obj = RRD (path=rrd_path, name=rrd, date_start=self.date_start, date_end=None) + self.db.store_activity_uptime(rrd_obj) + else: + print ("RRD file not found: {}".format(os.path.join(self.base_path, id_hash, user_hash))) + else: + print ("None hash user found on: {}".format(os.path.join(self.base_path, id_hash))) + else: + print ("None hash ids found on: {}" + format(self.base_path)) + except Exception as e: + print ("Error: {}".format(str(e))) |