Initial commit

bin/save_io_stats.sh

+#!/bin/bash
+
+PATH=/bin:/usr/bin
+
+. /opt/snmp_stats/lib/common.sh
+
+io_stats_dir="${_spool_dir}/io"
+io_stats_timestamp="${io_stats_dir}/.timestamp"
+
+while :; do
+
+    touch "${io_stats_timestamp}"
+
+    sudo /usr/sbin/iotop -d 10 -n 2 -k -b -a -o -P | \
+        awk \
+            -v iostats_dir="${io_stats_dir}" \
+            -f "${_lib_dir}/save_io_stats.awk"
+
+    find "${io_stats_dir}" -type f ! -newer "${io_stats_timestamp}" -delete
+
+    sleep 5
+
+done

bin/snmp_io_stats.sh

+#!/bin/bash
+
+PATH=/bin
+
+. /opt/snmp_stats/lib/common.sh
+
+io_stats_dir="${_spool_dir}/io"
+io_stats_timestamp="${io_stats_dir}/.timestamp"
+mib="${_mib_root}.10"
+act="${1}"
+req="${2}"
+
+instance_number="${req#${mib}}"
+instance_number="${instance_number#.}"
+
+if [[ "${act}" = '-s' ]]; then
+    exit
+fi
+
+while [[ -f ${io_stats_timestamp} ]]; do
+    sleep 1
+done
+
+
+if [[ "${act}" = '-n' ]]; then
+    instance_number=$(
+        ls "${io_stats_dir}" | sort -n | \
+            awk \
+                -v instance_number="${instance_number}" \
+                -f "${_lib_dir}/snmp_io_stats_find_next.awk"
+    )
+fi
+
+if [[ -f "${io_stats_dir}/${instance_number}" ]]; then
+    echo "${mib}.${instance_number}"
+    io_stats="$(cat "${io_stats_dir}/${instance_number}")"
+    io_stats_r="${io_stats%:*}"
+    io_stats_w="${io_stats#*:}"
+    echo "integer"
+    echo "$(printf '%0.f' "${io_stats_w}")"
+fi
+

lib/common.sh

+_exit_status_ok=0
+_exit_status_error=2
+_exit_status="${_exit_status_ok}"
+_root_dir='/opt/snmp_stats'
+_lib_dir="${_root_dir}/lib"
+_log_dir="${_root_dir}/log"
+_var_dir="${_root_dir}/var"
+_lock_dir="${_var_dir}/run"
+_spool_dir="${_var_dir}/spool"
+_mib_root=".1.3.6.1.4.1.53033.100"

lib/save_io_stats.awk

+BEGIN {
+    pass = 0
+}
+
+/^Total / {
+    pass++
+}
+
+/ qemu-kvm -name i-[0-9]+-[0-9]+-VM / {
+    if(pass == 2) {
+        if(split($14, instance_name, "-") == 4) {
+            print ($4 ":" $6) > ( iostats_dir "/" instance_name[3] )
+        }
+    }
+}

lib/snmp_io_stats_find_next.awk

+BEGIN {
+    if(instance_number) {
+        found = 0
+    } else {
+        found = 1
+    }
+}
+
+// {
+    if(found == 1) {
+        print($0)
+        exit;
+    }
+    if(instance_number == $0) {
+        found = 1
+    }
+}

var/spool/io/1639

+0.00:128.00

var/spool/io/1651

+320.00:65.00

var/spool/io/1664

+64.00:29.00

var/spool/io/1675

+64.00:436.00

var/spool/io/1679

+0.00:24.00

var/spool/io/1692

+0.00:85.00

var/spool/io/1885

+64.00:40.00

var/spool/io/1896

+0.00:36.00

var/spool/io/1914

+0.00:264.00

var/spool/io/1916

+12728.00:1514.00

var/spool/io/1926

+656.00:373.00

var/spool/io/1938

+144.00:221.00

var/spool/io/1983

+128.00:196.00

var/spool/io/2004

+0.00:0.00

var/spool/io/2037

+0.00:288.00