inode utilisiation option is added to disk metrics.

Author: Caglar Anar

cloudwatchmon/cli/put_instance_stats.py

@@ -118,12 +118,13 @@ def __gather_loadavg_info():
 
 
 class Disk:
-    def __init__(self, mount, file_system, total, used, avail):
+    def __init__(self, mount, file_system, total, used, avail, inode_util):
         self.mount = mount
         self.file_system = file_system
         self.used = used
         self.avail = avail
         self.util = 100.0 * used / total if total > 0 else 0
+        self.inode_util = inode_util
 
 
 class Metrics:
@@ -295,13 +296,18 @@ def config_parser():
     disk_group.add_argument('--disk-space-avail',
                             action='store_true',
                             help='Reports available disk space in gigabytes.')
+    disk_group.add_argument('--disk-inode-util',
+                            action='store_true',
+                            help='Reports disk inode utilization in percentages.')
     disk_group.add_argument('--disk-space-units',
                             metavar='UNITS',
                             default='gigabytes',
                             type=to_lower,
                             choices=size_units,
                             help='Specifies units for disk space metrics.')
 
+    
+
     exclusive_group = parser.add_mutually_exclusive_group()
     exclusive_group.add_argument('--from-cron',
                                  action='store_true',
@@ -374,7 +380,20 @@ def get_disk_info(paths):
         total = int(line[1]) * 1024
         used = int(line[2]) * 1024
         avail = int(line[3]) * 1024
-        disks.append(Disk(mount, file_system, total, used, avail))
+        disks.append(Disk(mount, file_system, total, used, avail, 0))
+
+    df_inode_out = [s.split() for s in
+                    os.popen('/bin/df -i -k -P ' +
+                             ' '.join(paths)).read().splitlines()]
+    disks_inode_util = []
+    for line in df_inode_out[1:]:
+        used = float(line[2])
+        total = float(line[1])
+        inode_util_val = 100.0 * used / total if total > 0 else 0
+        disks_inode_util.append(inode_util_val) 
+
+    for index, disk in enumerate(disks):
+        disk.inode_util = disks_inode_util[index]
     return disks
 
 
@@ -394,6 +413,10 @@ def add_disk_metrics(args, metrics):
             metrics.add_metric('DiskSpaceAvailable', disk_unit_name,
                                disk.avail / disk_unit_div,
                                disk.mount, disk.file_system)
+        if args.disk_inode_util:
+            metrics.add_metric('InodeUtilization', 'Percent',
+                               disk.inode_util, disk.mount, disk.file_system)
+            
 
 
 def add_static_file_metrics(args, metrics):
@@ -433,7 +456,7 @@ def validate_args(args):
 
     if report_disk_data:
         if not args.disk_space_util and not args.disk_space_used and \
-                not args.disk_space_avail:
+                not args.disk_space_avail and not args.disk_inode_util:
             raise ValueError('Disk path is provided but metrics to report '
                              'disk space are not specified.')
 
@@ -442,7 +465,7 @@ def validate_args(args):
                 raise ValueError('Disk file path ' + path +
                                  ' does not exist or cannot be accessed.')
     elif args.disk_space_util or args.disk_space_used or \
-            args.disk_space_avail:
+            args.disk_space_avail or args.disk_inode_util:
         raise ValueError('Metrics to report disk space are provided but '
                          'disk path is not specified.')