StatsDBundle/Command/EndpointMysqlCommand.php

<?php

namespace StatsDBundle\Command;

use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class EndpointMysqlCommand extends ContainerAwareCommand
{

    protected function configure()
    {
        $this
                ->setName('endpoint:mysql')
                ->setDescription('Test jsonendpoint mysql')
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $endpoint = $this->getContainer()->get('endpoint.mysql');

        $json = '{"range":{"from":"2017-11-13T14:09:25.307Z","to":"2017-11-13T17:09:25.308Z"},"intervalMs":0,"targets":[{"target":"d_3_s_1_snmp_ponRxPower"}],"format":"json","maxDataPoints":10}';
        

        $subName = "d_1_s_1";
        $targets = array();
        $targets["in_bandwidth"] = array("target" => "{$subName}_inbandwidth_olt");
        $targets["out_bandwidth"] = array("target" => "{$subName}_outbandwidth_olt");
        
        foreach($targets as $t) {

            $data = array('targets' => array(0 => $t), 'maxDataPoints' => 10);
            
            $json = json_encode($data);
            
            $result = $endpoint->get($json,'last');
            
            print_r($result);
        }
        
        print_r(PHP_EOL);
        print_r(date("Y-m-d H:i:s"));
        print_r(PHP_EOL);
    }

}