feature: Send collected data to graphite server

doc/Extensions/Graphite.md

@@ -0,0 +1,23 @@
+source: Extensions/Graphite.md
+# Enabling support for Graphite.
+
+This module sends all metrics to a remote graphite service. You need something like Grafana for graphing.
+
+### What you don't get
+ - Pretty graphs, this is why at present you need Grafana. You need to build your own graphs within Grafana.
+
+RRD will continue to function as normal so LibreNMS itself should continue to function as normal.
+
+### Configuration
+```php
+$config['graphite']['enable'] = true;
+$config['graphite']['host'] = 'your.graphite.server';
+$config['graphite']['port'] = 2003; // this defaults to 2003 and is usually not needed
+$config['graphite']['prefix'] = 'your.metric.prefix';
+```
+
+Your metric path can be prefixed if required, otherwise the metric path for Graphite will be in the form of
+`hostname.measurement.fieldname`, interfaces will be stored as `hostname.ports.ifName.fieldname`. 
+
+The same data then stored within rrd will be sent to Graphite and recorded. You can then create graphs within Grafana
+to display the information you need.

includes/datastore.inc.php

@@ -67,4 +67,5 @@ function data_update($device, $measurement, $tags, $fields)
 
     rrdtool_data_update($device, $measurement, $tags, $fields);
     influx_update($device, $measurement, rrd_array_filter($tags), $fields);
+    graphite_update($device, $measurement, $tags, $fields);
 } // data_update

includes/graphite.inc.php

@@ -0,0 +1,33 @@
+<?php
+
+/*
+ * LibreNMS
+ *
+ * Copyright (c) 2017 Falk Stern <https://github.com/fstern/ >
+ *
+ * This program is free software: you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation, either version 3 of the License, or (at your
+ * option) any later version.  Please see LICENSE.txt at the top level of
+ * the source code distribution for details.
+ */
+
+function graphite_update($device, $measurement, $tags, $fields)
+{
+    global $graphite, $config;
+    if ($graphite !== false) {
+        $timestamp = time();
+        $graphite_prefix = $config['graphite']['prefix'];
+        // metrics will be built as prefix.hostname.measurement.field value timestamp
+        // metric fields can not contain . as this is used by graphite as a field separator
+        $hostname = preg_replace('/\./', '_', $device['hostname']);
+        $measurement = preg_replace(array('/\./', '/\//'), '_', $measurement);
+        $measurement = preg_replace('/\|/', '.', $measurement);
+        foreach ($fields as $k => $v) {
+            $metric = implode(".", array_filter(array($graphite_prefix, $hostname, $measurement, $k)));
+            $line = implode(" ", array($metric, $v, $timestamp));
+            d_echo("Sending $line\n");
+            fwrite($graphite, $line . "\n");
+        }
+    }
+}

includes/init.php

@@ -47,6 +47,7 @@
 require $install_dir . '/includes/dbFacile.php';
 require $install_dir . '/includes/rrdtool.inc.php';
 require $install_dir . '/includes/influxdb.inc.php';
+require $install_dir . '/includes/graphite.inc.php';
 require $install_dir . '/includes/datastore.inc.php';
 require $install_dir . '/includes/billing.php';
 require $install_dir . '/includes/syslog.php';

includes/polling/ports.inc.php

@@ -753,6 +753,7 @@
         $fields['ifOutOctets_rate'] = $port['ifOutOctets_rate'];
 
         influx_update($device, 'ports', rrd_array_filter($tags), $fields);
+        graphite_update($device, 'ports|' . $ifName, $tags, $fields);
 
         // End Update IF-MIB
         // Update PAgP

poller.php

@@ -110,12 +110,27 @@
     $config['noinfluxdb'] = true;
 }
 
+if (isset($options['g'])) {
+    $config['nographite'] = true;
+}
+
 if ($config['noinfluxdb'] !== true && $config['influxdb']['enable'] === true) {
     $influxdb = influxdb_connect();
 } else {
     $influxdb = false;
 }
 
+if ($config['nographite'] !== true && $config['graphite']['enable'] === true) {
+    if (isset($config['graphite']['port'])) {
+        $graphite_port = $config['graphite']['port'];
+    } else {
+        $graphite_port = '2003';
+    }
+    $graphite = fsockopen($config['graphite']['host'], $graphite_port);
+} else {
+    $graphite = false;
+}
+
 rrdtool_initialize();
 
 echo "Starting polling run:\n\n";
@@ -141,6 +156,10 @@
 $poller_run  = ($poller_end - $poller_start);
 $poller_time = substr($poller_run, 0, 5);
 
+if ($graphite !== false) {
+    fclose($graphite);
+}
+
 if ($polled_devices) {
     dbInsert(array('type' => 'poll', 'doing' => $doing, 'start' => $poller_start, 'duration' => $poller_time, 'devices' => $polled_devices, 'poller' => $config['distributed_poller_name'] ), 'perf_times');
 }