(self)
Connect to the influxdb server
Connect to the influxdb server
Connect to the influxdb server
def _connect(self):
        """
        Connect to the influxdb server
        """

        try:
            # Open Connection
            self.influx = InfluxDBClient(self.hostname, self.port,
                                         self.username, self.password,
                                         self.database, self.ssl)
            # Log
            self.log.debug("InfluxdbHandler: Established connection to "
                           "%s:%d/%s.",
                           self.hostname, self.port, self.database)
        except Exception as ex:
            # Log Error
            self._throttle_error("InfluxdbHandler: Failed to connect to "
                                 "%s:%d/%s. %s",
                                 self.hostname, self.port, self.database, ex)
            # Close Socket
            self._close()
            return
def _connect ( self ) : try : # Open Connection self . influx = InfluxDBClient ( self . hostname , self . port , self . username , self . password , self . database , self . ssl ) # Log self . log . debug ( "InfluxdbHandler: Established connection to " "%s:%d/%s." , self . hostname , self . port , self . database ) except Exception as ex : # Log Error self . _throttle_error ( "InfluxdbHandler: Failed to connect to " "%s:%d/%s. %s" , self . hostname , self . port , self . database , ex ) # Close Socket self . _close ( ) return