CmtsBundle/Command/CmtsCmStatsCommand.php

<?php
# bin/console cmts:cm:stats --cmts-device-id=14 --cmts-server-id=1 --cm-ip=10.42.0.27 --cm-mac=00237406d524 --cm-community=public
# http://200.50.168.115/Provisioning/admin/cablemodem/00237406d524

# bin/console cmts:cm:stats --cmts-device-id=14 --cmts-server-id=1 --cm-ip=10.50.2.3 --cm-mac=001a6663dcde --cm-community=public

namespace CmtsBundle\Command;

use BaseStatsBundle\Command\BaseCmCommand;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use CmtsBundle\SNMP\SNMP as SNMP;

use Symfony\Bundle\FrameworkBundle\Console\Application;
use Symfony\Component\Console\Input\ArgvInput;
use Symfony\Component\Console\Output\BufferedOutput;

class CmtsCmStatsCommand extends BaseCmCommand
{

    protected function configure()
    {
        $this
            ->setName('cmts:cm:stats')
            ->setDescription('Obtener estadísticas de un CM')
            ->setHelp('Se requieren parámetros para poder realizar la correcta consulta. El comando requiere Redis.')
            ->setDefinition(array(
                new InputOption('cmts-device-id', null, InputOption::VALUE_OPTIONAL, "DeviceId del CMTS",1),
                new InputOption('cmts-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice del CMTS",1),
                new InputOption('cm-ip', false, InputOption::VALUE_OPTIONAL, "IP del CM"),
                new InputOption('cm-mac', false, InputOption::VALUE_OPTIONAL, "MAC del CM"),
                new InputOption('cm-community', false, InputOption::VALUE_OPTIONAL, "Community del CMTS",'public'),
                new InputOption('cm-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP",'OIDSBase'),
                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
            ))
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        parent::execute($input, $output);
        
        
        $key_cm_stats = "cm_stats_{$this->d_s}"; // group by cmts
        $saveHistoric = (int) $input->getOption('save-historic');
        $inicio = microtime(true);

        $SNMP = new SNMP($this->cmIp, $this->cmCommunity);
        $SNMP->setTimeout(2500000); // 2.5 seconds of timeout
        $SNMP->setRetry(1); // 1 query per metric
        $library = "use".$this->cmSnmpLibrary;
        $this->apiSNMP = $SNMP->$library();
        
        $uptime = $this->getSNMP("sysUpTimeInstance","cmUptime");
        if(!$uptime) $SNMP->setTimeout(1000000); // 1 seconds of timeout
        
        $txPower = $this->getSNMP("docsIfCmStatusTxPower","cmTxPower");
        if($txPower) $SNMP->setTimeout(2500000);

        $rxPower = $this->getSNMP("docsIfDownChannelPower","cmRxPower");

        if(!$txPower && !$rxPower) {
            $this->removeLock($this->flag);
            $fin = microtime(true);
            $time = $fin - $inicio;
            $this->output->writeln("CM no responde uptime, tx y rx => cortamos! Tiempo: $time segundos");
            return true;
        }

        $signal = $this->getSNMP("docsIfSigQSignalNoise","cmSignal");
        $microreflection = $this->getSNMP("docsIfSigQMicroreflections","cmMicroreflection");
        $unerroreds = $this->getSNMP("docsIfSigQUnerroreds","cmUnerroreds");
        $correcteds = $this->getSNMP("docsIfSigQCorrecteds","cmCorrecteds");
        $uncorrectables = $this->getSNMP("docsIfSigQUncorrectables","cmUncorrectables");

        $slaJson = $this->sla($this->cmIp);
        try{
            $sla = json_decode($slaJson,true);
        } catch(\Exception $e) {
            $sla = array();
        }
        
        $metrics = array('txPower' => 'cm_tx_', 'rxPower' => 'cm_rx_', 'signal' => 'cm_signal_', 'microreflection' => 'cm_microreflection_', 'unerroreds' => 'cm_unerroreds_', 'correcteds' => 'cm_correcteds_', 'uncorrectables' => 'cm_uncorrectables_');
        $sendData = $data = array();

        foreach($metrics as $var => $m) {

            $data[$var] = array();

            if(!is_array($$var)) continue;

            $multiplicator = 1;
            if(in_array($var, array('txPower','rxPower','signal'))) {
                $multiplicator = 0.1;
            }

            foreach($$var as $channel => $value) {
                $v = $value * $multiplicator;
                $_m = "{$m}{$this->cmMac}.{$channel}";
                $data[$var][$channel] = $v;
                $sendData[$_m] = "{$v}|g";
            }
        }

        if($uptime) {
            foreach($uptime as $oid => $value) {
                $data['uptime'] = $this->convertSysUpTimeInstance($value);
            }
        }

        if(isset($sla['latency'])) {
            $data['latency'] = $sla['latency'];
            $sendData["cm_latency_{$this->cmMac}"] = "{$sla['latency']}|g";
        }
        
        if(isset($sla['jitter'])) {
            $data['jitter'] = $sla['jitter'];
            $sendData["cm_jitter_{$this->cmMac}"] = "{$sla['jitter']}|g";
        }

        if(isset($sla['loss'])) {
            $data['loss'] = $sla['loss'];
            $sendData["cm_loss_{$this->cmMac}"] = "{$sla['loss']}|g";
        }

        $this->hset($key_cm_stats, $this->cmMac, $data, true);

        //$data = $this->collector->hgetall($key_cm_stats);

        if($sendData && $saveHistoric) {
            $t_start_script = microtime(true); 
            $statsdService = $this->getContainer()->get('statsd');
            $statsdService->send($sendData);
            $t_end_script = microtime(true); 
            $time = $t_end_script - $t_start_script;
            $this->output->writeln("Tiempo de envío al StatsD: {$time} ms / Cantidad: ".count($sendData));
        }

        /* End Of Blockout */
        $this->removeLock($this->flag);

        $fin = microtime(true);
        $time = $fin - $inicio;
        $this->output->writeln("Tiempo: $time segundos");
    }

    private function sla($ip)
    {
        $kernel = $this->getContainer()->get('kernel');

        $application = new Application($kernel);
        $application->setAutoExit(false);

        $args = ['','ping',$ip];
        
        $input = new ArgvInput($args);

        $output = new BufferedOutput();

        $application->run($input, $output);

        return $output->fetch();
    }

}