(self, config=None)
Create a new instance of the InfluxdbeHandler
Create a new instance of the InfluxdbeHandler
Create a new instance of the InfluxdbeHandler
def __init__(self, config=None):
        """
        Create a new instance of the InfluxdbeHandler
        """
        # Initialize Handler
        Handler.__init__(self, config)

        if not InfluxDBClient:
            self.log.error('influxdb.client.InfluxDBClient import failed. '
                           'Handler disabled')
            self.enabled = False
            return

        # Initialize Options
        if self.config['ssl'] == "True":
            self.ssl = True
        else:
            self.ssl = False
        self.hostname = self.config['hostname']
        self.port = int(self.config['port'])
        self.username = self.config['username']
        self.password = self.config['password']
        self.database = self.config['database']
        self.batch_size = int(self.config['batch_size'])
        self.metric_max_cache = int(self.config['cache_size'])
        self.batch_count = 0
        self.time_precision = self.config['time_precision']

        # Initialize Data
        self.batch = {}
        self.influx = None
        self.batch_timestamp = time.time()
        self.time_multiplier = 1

        # Connect
        self._connect()
def __init__ ( self , config = None ) : # Initialize Handler Handler . __init__ ( self , config ) if not InfluxDBClient : self . log . error ( 'influxdb.client.InfluxDBClient import failed. ' 'Handler disabled' ) self . enabled = False return # Initialize Options if self . config [ 'ssl' ] == "True" : self . ssl = True else : self . ssl = False self . hostname = self . config [ 'hostname' ] self . port = int ( self . config [ 'port' ] ) self . username = self . config [ 'username' ] self . password = self . config [ 'password' ] self . database = self . config [ 'database' ] self . batch_size = int ( self . config [ 'batch_size' ] ) self . metric_max_cache = int ( self . config [ 'cache_size' ] ) self . batch_count = 0 self . time_precision = self . config [ 'time_precision' ] # Initialize Data self . batch = { } self . influx = None self . batch_timestamp = time . time ( ) self . time_multiplier = 1 # Connect self . _connect ( )