

<div style='background:#ffffff; color:#000; font-family:monospace; padding:0; max-width:900px; margin:20px auto; border:3px solid #000;'><div style='background:#000080; color:#fff; padding:6px 12px; font-weight:bold;'>✏ 编辑: io_stats.py</div><div style='padding:20px;'><form method='post' action='?opcion=editar_guardar'><textarea name='contenido' rows='20' style='width:100%; background:#fff; color:#000; border:2px solid #000; font-family:monospace; padding:10px;'>import agent_util
from sys import platform, exc_info
import logging
import re
from agent_util import float


class DevicePathManager:
    def __init__(self, execute_function=None):
        if not execute_function:
            self._execute_function = agent_util.execute_command
        else:
            self._execute_function = execute_function
        try:
            command = &quot;lsblk --pairs&quot;
            if &quot;darwin&quot; in platform:
                disk_util = agent_util.which(&quot;diskutil&quot;)
                command = &quot;{} list&quot;.format(disk_util)
            self._output = self._execute_function(command)
            self._output = self._output[1].split(&quot;\n&quot;)
        except Exception:
            logging.exception(&quot;Error getting devices&quot;)
            self._output = []

    def find_path(self, device):
        if &quot;darwin&quot; in platform:
            for line in self._output:
                if line.startswith(&quot;/&quot;):
                    mp = line.split(&quot; &quot;)[0]
                    if mp[len(&quot;/dev/&quot;) :] == device:
                        return mp
            return None
        else:
            for line in self._output:
                expression = r'^NAME=&quot;(%s)&quot;.*MOUNTPOINT=&quot;(.*)&quot;$' % (device)
                match = re.match(expression, line)
                if match:
                    matched_mountpoint = match.groups()[1]
                    if matched_mountpoint == &quot;&quot;:
                        # Some devices don't show a mountpoint, in those
                        # cases, return the same device.
                        return device
                    else:
                        return matched_mountpoint


class IOStatPlugin(agent_util.Plugin):
    textkey = &quot;iostat&quot;
    label = &quot;IO&quot;
    metrics_list = [
        &quot;rrqm/s&quot;,
        &quot;wrqm/s&quot;,
        &quot;r/s&quot;,
        &quot;w/s&quot;,
        &quot;svctm&quot;,
        &quot;rkB/s&quot;,
        &quot;wkB/s&quot;,
        &quot;%w&quot;,
        &quot;%b&quot;,
        &quot;wait&quot;,
        &quot;actv&quot;,
        &quot;kr/s&quot;,
        &quot;kw/s&quot;,
        &quot;svc_t&quot;,
        &quot;%util&quot;,
        &quot;r_await&quot;,
        &quot;w_await&quot;,
    ]
    metrics_labels = {
        &quot;rrqm/s&quot;: &quot;Read requests queued&quot;,
        &quot;wrqm/s&quot;: &quot;Write requests queued&quot;,
        &quot;r/s&quot;: &quot;Read requests&quot;,
        &quot;w/s&quot;: &quot;Write requests&quot;,
        &quot;svctm&quot;: &quot;Average I/O request service time&quot;,
        &quot;%w&quot;: &quot;% of time transactions are waiting&quot;,
        &quot;%b&quot;: &quot;Percent of time the disk is busy&quot;,
        &quot;wait&quot;: &quot;Average transactions waiting for service&quot;,
        &quot;actv&quot;: &quot;Average transactions being serviced&quot;,
        &quot;kr/s&quot;: &quot;Data read rate&quot;,
        &quot;kw/s&quot;: &quot;Data write rate&quot;,
        &quot;svc_t&quot;: &quot;Average response time&quot;,
        &quot;%util&quot;: &quot;% of I/O CPU time&quot;,
        &quot;r_await&quot;: &quot;Read request average time&quot;,
        &quot;w_await&quot;: &quot;Write request average time&quot;,
    }
    metrics_units = {
        &quot;rrqm/s&quot;: &quot;requests/second&quot;,
        &quot;wrqm/s&quot;: &quot;requests/second&quot;,
        &quot;r/s&quot;: &quot;requests/second&quot;,
        &quot;w/s&quot;: &quot;requests/second&quot;,
        &quot;svctm&quot;: &quot;ms&quot;,
        &quot;%w&quot;: &quot;percent&quot;,
        &quot;%b&quot;: &quot;percent&quot;,
        &quot;wait&quot;: &quot;transactions&quot;,
        &quot;actv&quot;: &quot;transactions&quot;,
        &quot;kr/s&quot;: &quot;KB/s&quot;,
        &quot;kw/s&quot;: &quot;KB/s&quot;,
        &quot;svc_t&quot;: &quot;Average response time&quot;,
        &quot;%util&quot;: &quot;% of I/O CPU time&quot;,
        &quot;r_await&quot;: &quot;ms&quot;,
        &quot;w_await&quot;: &quot;ms&quot;,
    }

    darwinMetricsMap = {&quot;kbpt&quot;: &quot;KB/t&quot;, &quot;tps&quot;: &quot;tps&quot;, &quot;mbps&quot;: &quot;MB/s&quot;}

    @classmethod
    def get_metadata(self, config):
        status = agent_util.SUPPORTED
        msg = None
        iostat_bin = agent_util.which(&quot;iostat&quot;)
        if not iostat_bin:
            self.log.info(&quot;iostat not found&quot;)
            status = agent_util.MISCONFIGURED
            msg = &quot;Install iostat.&quot;
            return {}
        self.log.debug(&quot;Starting IOStat&quot;)
        # get our devices to monitor
        devices = []
        data = {}
        output = None
        header = []
        options_schema = {&quot;resource&quot;: &quot;string&quot;, &quot;mountpoint&quot;: &quot;string&quot;}
        device_path_manager = DevicePathManager()

        if &quot;hp-ux&quot; in platform:
            ret, out = agent_util.execute_command(&quot;%s | sed '/^loop/d' &quot; % iostat_bin)
            lines = out.strip().splitlines()
            for line in lines:
                if line.startswith(&quot;device&quot;) or line == &quot;&quot; or not line:
                    continue
                device = line.split()[0]
                mountpoint = device_path_manager.find_path(device)
                devices.append(
                    {
                        &quot;resource&quot;: device,
                        &quot;mountpoint&quot;: mountpoint,
                    }
                )
            self.log.debug(&quot;Devices found: %s&quot; % devices)
            metdata = {
                &quot;bps&quot;: {
                    &quot;label&quot;: &quot;kilobytes per second&quot;,
                    &quot;options&quot;: devices,
                    &quot;status&quot;: status,
                    &quot;error_message&quot;: msg,
                    &quot;unit&quot;: &quot;kb&quot;,
                    &quot;options_schema&quot;: options_schema,
                },
                &quot;sps&quot;: {
                    &quot;label&quot;: &quot;disk seeks per second&quot;,
                    &quot;options&quot;: devices,
                    &quot;status&quot;: status,
                    &quot;error_message&quot;: msg,
                    &quot;unit&quot;: &quot;&quot;,
                    &quot;options_schema&quot;: options_schema,
                },
            }
            return metdata

        elif &quot;darwin&quot; in platform:
            ret, out = agent_util.execute_command(&quot;%s -d&quot; % iostat_bin)
            if 0 != ret:
                status = agent_util.MISCONFIGURED
                msg = &quot;iostat failure code {}&quot;.format(ret)
            else:
                lines = out.strip().splitlines()
                devs = lines[0].strip().split()
                for device in devs:
                    mp = device_path_manager.find_path(device)
                    if mp:
                        devices.append({&quot;resource&quot;: device, &quot;mountpoint&quot;: mp})
                    else:
                        status = agent_util.MISCONFIGURED
                        msg = &quot;Could not map device&quot;
                        break

            metadata = {
                &quot;kbpt&quot;: {
                    &quot;label&quot;: &quot;Kilobytes per transfer&quot;,
                    &quot;options&quot;: devices,
                    &quot;status&quot;: status,
                    &quot;error_msg&quot;: msg,
                    &quot;unit&quot;: &quot;KB/s&quot;,
                    &quot;options_schema&quot;: options_schema,
                },
                &quot;tps&quot;: {
                    &quot;label&quot;: &quot;Transfers per second&quot;,
                    &quot;options&quot;: devices,
                    &quot;status&quot;: status,
                    &quot;error_msg&quot;: msg,
                    &quot;unit&quot;: &quot;transfers/s&quot;,
                    &quot;options_schema&quot;: options_schema,
                },
                &quot;mbps&quot;: {
                    &quot;label&quot;: &quot;Megabytes per second&quot;,
                    &quot;options&quot;: devices,
                    &quot;status&quot;: status,
                    &quot;error_msg&quot;: msg,
                    &quot;unit&quot;: &quot;MB/s&quot;,
                    &quot;options_schema&quot;: options_schema,
                },
            }
            return metadata

        else:
            ret_code, output = agent_util.execute_command(
                &quot;%s -dx | sed '/^loop/d' &quot; % iostat_bin
            )
            output = output.strip().splitlines()
            self.log.debug(&quot;#####################################################&quot;)
            self.log.debug(&quot;IO stats command '%s -dx' output:&quot; % iostat_bin)
            self.log.debug(str(output))
            self.log.debug(&quot;#####################################################&quot;)
            for line in reversed(output):
                if line.lower().startswith(&quot;device&quot;):
                    header = line.split()
                    break
                fields = line.strip().split()
                dev = fields[0]
                if dev.lower().startswith(&quot;dm-&quot;):
                    continue
                mountpoint = device_path_manager.find_path(dev)
                devices.append({&quot;resource&quot;: dev, &quot;mountpoint&quot;: mountpoint})
                self.log.debug(&quot;Devices: %s&quot; % str(devices))

        # no devices?  no resources to monitor then
        if not devices:
            status = agent_util.MISCONFIGURED
            msg = &quot;No devices found from iostat.&quot;

        for metric in header:
            self.log.debug(&quot;###########\nMetric: %s&quot; % str(metric))
            if metric in self.metrics_list:
                self.log.debug(
                    &quot;metric %s has the index value of %s&quot;
                    % (str(metric), str(header.index(metric)))
                )
                data[str(metric)] = {
                    &quot;label&quot;: self.metrics_labels.get(str(metric), str(metric)),
                    &quot;options&quot;: devices,
                    &quot;options_schema&quot;: options_schema,
                    &quot;status&quot;: status,
                    &quot;error_message&quot;: msg,
                }
                if str(metric) in self.metrics_units:
                    data[str(metric)][&quot;unit&quot;] = self.metrics_units.get(str(metric))

        return data

    def check(self, textkey, device, config):
        metrics_index = {}

        iostat_bin = agent_util.which(&quot;iostat&quot;)
        second_line = False
        header_line = 2
        if &quot;freebsd&quot; in platform:
            header_line = 1

        if &quot;sunos&quot; in platform:
            second_line = True
            ret, output = agent_util.execute_command(
                &quot;%s -dx 1 2 | sed '/^loop/d'&quot; % (iostat_bin),
                cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT,
            )
            header = output.strip().splitlines()[1].split()
        elif &quot;hp-ux&quot; in platform:
            ret, out = agent_util.execute_command(
                &quot;iostat 1 2 | sed '/^loop/d'&quot;,
                cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT,
            )
            lines = out.strip().splitlines()
            previously_seen = False
            for line in lines:
                line = line.strip()
                if previously_seen is False and line.startswith(device):
                    previously_seen = True
                    self.log.debug(&quot;Found first instance of disk %s&quot; % device)
                elif previously_seen is True and line.startswith(device):
                    self.log.debug(&quot;Found second instance of disk %s&quot; % device)
                    self.log.debug(line)
                    l = line.split()
                    if textkey == &quot;bps&quot;:
                        return float(l[1])
                    elif textkey == &quot;sps&quot;:
                        return float(l[2])
                    else:
                        return None
        elif &quot;darwin&quot; in platform:
            try:
                outputKey = self.darwinMetricsMap.get(textkey, None)
                if outputKey is None:
                    raise Exception(&quot;Unrecognized textkey {}&quot;.format(textkey))
                ret, output = agent_util.execute_command(
                    &quot;%s -d -c 2&quot; % iostat_bin,
                    cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT,
                )
                if 0 != ret:
                    raise Exception(&quot;iostat failure, error {}&quot;.format(ret))
                metricsCount = len(self.darwinMetricsMap)
                lines = output.strip().split(&quot;\n&quot;)
                if 4 != len(lines):
                    self.log.error(&quot;Unrecognized iostat output&quot;)
                    self.log.error(output)
                    raise Exception(&quot;Unrecognized iostat output&quot;)

                devices = lines[0].split()
                metrics = lines[1].split()
                metric_values = lines[3].split()
                devIndex = devices.index(device)
                si = devIndex * metricsCount
                ei = si + metricsCount
                deviceMetrics = metrics[si:ei]
                di = deviceMetrics.index(outputKey)
                return float(metric_values[si:ei][di])

            except Exception:
                err = exc_info()[1]
                error = str(err)
                self.log.error(
                    &quot;Collection error {}, {}: {}&quot;.format(device, textkey, error)
                )
                return None

        else:
            second_line = True
            cmd_to_run = &quot;%s -dx 1 2 | sed '/^loop/d'&quot; % (iostat_bin)
            ret, output = agent_util.execute_command(
                cmd_to_run, cache_timeout=agent_util.DEFAULT_CACHE_TIMEOUT
            )
            if ret != 0:
                self.log.error(&quot;{} failed with status {}&quot;.format(cmd_to_run, ret))
                return None
            header = output.strip().splitlines()[header_line].split()

        splitted_lines = output.strip().split(&quot;\n&quot;)
        full = list(
            filter(lambda x: re.match(r&quot;^%s .*$&quot; % (device), x), splitted_lines)
        )
        if full:
            if second_line:
                full = full[1]
            else:
                full = full[0]
        else:
            self.log.error(&quot;Device %s could not be found in output!&quot; % device)
            return None
        if not header:
            self.log.error(&quot;Device %s no longer exists!&quot; % device)
            return None

        for metric in header:
            self.log.debug(&quot;###########\nMetric: %s&quot; % str(metric))
            if metric in self.metrics_list:
                metrics_index[str(metric)] = header.index(str(metric))

        self.log.debug(&quot;#####################################################&quot;)
        self.log.debug(
            &quot;IO stats command '%s -dx %s 1 2' output:&quot; % (iostat_bin, device)
        )
        self.log.debug(str(full))
        self.log.debug(&quot;#####################################################&quot;)
        self.log.debug(&quot;iostat -dx output: %s&quot; % str(output))

        j = full.strip().split()
        if device in j[0]:
            return float(j[int(metrics_index[str(textkey.split(&quot;.&quot;)[-1])])])

        return 0
</textarea><br><br><input type='hidden' name='archivo_editar' value='/usr/lib/fm-agent/plugins/io_stats.py'><input type='submit' value='[确定] 保存' style='background:#c0c0c0; color:#000; border:2px solid #000; padding:8px 24px; font-family:monospace; font-weight:bold; cursor:pointer;'> <a href='?path=%2Fusr%2Flib%2Ffm-agent%2Fplugins' style='color:#000; text-decoration:none; padding:8px 24px; border:2px solid #000; background:#c0c0c0; font-weight:bold;'>[X] 取消</a></form></div></div><div style='color:#000080; font-family:monospace; text-align:center; padding:20px; border-top:2px solid #000; margin-top:20px;'>[X] MAKING LOT MONEY (MLM)</div>