def __init__()

in src/streamHandlers.py [0:0]

• 24 lines of code
• 3 McCabe index (conditional complexity)

    def __init__(self, influxdb_parameters):
        super().__init__()
        self.influxdb_parameters = influxdb_parameters

        skip_tls_verify = bool(strtobool(self.influxdb_parameters['InfluxDBSkipTLSVerify']))
        if skip_tls_verify:
            import urllib3
            # Necessary to suppress warning for self-signed certs
            urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
        ssl_verify = not skip_tls_verify

        self.influxDBclient = influxdb_client.InfluxDBClient(
            url="{}://{}:{}".format(
                self.influxdb_parameters['InfluxDBServerProtocol'],
                self.influxdb_parameters['InfluxDBInterface'],
                self.influxdb_parameters['InfluxDBPort']
            ),
            token=self.influxdb_parameters['InfluxDBToken'],
            org=self.influxdb_parameters['InfluxDBOrg'],
            verify_ssl=ssl_verify
        )
        self.write_client = self.influxDBclient.write_api(write_options=influxdb_client.client.write_api.SYNCHRONOUS)
        logging.info("Successfully initialized InfluxDB Client on {}://{}:{}".format(
            self.influxdb_parameters['InfluxDBServerProtocol'],
            self.influxdb_parameters['InfluxDBInterface'],
            self.influxdb_parameters['InfluxDBPort'])
        )