Exemple de script influx

[jeanfabrice]

Exemple de script influx

[jeanfabrice]

Bonjour,

Oui :)
Voici le code nodeJS que j'utilisais pour pousser les données dans influxDB, avant de passer sur Prometheus.

#!/usr/bin/env node
var commander    = require( 'commander' );
var debug        = require( 'debug' )( 'app:main' );
var async        = require( 'async' );
var package      = require( './package.json' );
var config       = require( './config.json' );
var influx       = require( 'influx' );
var flatten      = require( 'flat' );
var Livebox      = require( 'livebox-collect' );
var livebox      = new Livebox( config.hostname, config.login, config.password );

var client = influx({
  host     : config.influxdb.host || 'localhost',
  port     : config.influxdb.port || 8086,
  username : config.influxdb.user || 'user',
  password : config.influxdb.password || 'password',
  database : config.influxdb.db || 'db'
})

commander
  .version( package.version )
  .parse( process.argv );
debug( 'Parsed command-line options: %s', JSON.stringify( commander, null, 2 ));

livebox.connect( function( err ) {
  if( err ) {
    console.error( 'Auth error:', err );
    process.exit( 1 );
  }
  async.parallel({
    'deviceInfo' : function( callback ) {
      livebox.deviceInfo( function( err, data ) {
        client.writePoint( 'deviceInfo', flatten( data.status), {}, function(err, data1) {
          callback( err, flatten( data.status ) );
        })
      });
    },
    'getDSLStats' : function( callback ) {
      livebox.getDSLStats( function( err, data ) {
        client.writePoint( 'getDSLStats', flatten( data.status), {}, function(err, data1) {
          callback( err, flatten( data.status ) );
        })
      });
    },
    'getMibs-dsl' : function( callback ) {
      livebox.getMibs( 'dsl', function( err, data ) {
        client.writePoint( 'getMibs-dsl', flatten( data.status.dsl ), {}, function(err, data1) {
          callback( err, flatten( data.status.dsl ) );
        })
      });
    }
  }, function( err, result ) {
    if( err ) {
        console.error( err );
        return;
    }
    debug( result );
  })
})

[AnthoDingo]

Super, merci beaucoup :)