fix: duplicated debug output

Author: bednar

influxdb_client/configuration.py

@@ -171,7 +171,10 @@ def debug(self, value):
             for name, logger in self.loggers.items():
                 logger.setLevel(logging.DEBUG)
                 if name == 'influxdb_client.client.http':
-                    logger.addHandler(logging.StreamHandler(sys.stdout))
+                    # makes sure to do not duplicate stdout handler
+                    if not any(map(lambda h: isinstance(h, logging.StreamHandler) and h.stream == sys.stdout,
+                                   logger.handlers)):
+                        logger.addHandler(logging.StreamHandler(sys.stdout))
             # we use 'influxdb_client.client.http' logger instead of this
             # httplib.HTTPConnection.debuglevel = 1
         else:

tests/test_InfluxDBClient.py

@@ -391,6 +391,20 @@ def test_redacted_auth_header(self):
 
         self.assertIn("Authorization: ***", log_stream.getvalue())
 
+    def test_duplicate_debug_logging_handler(self):
+        logging.getLogger('influxdb_client.client.http').handlers.clear()
+        self.influxdb_client = InfluxDBClient("http://localhost", "my-token", debug=True)
+        self.influxdb_client = InfluxDBClient("http://localhost", "my-token", debug=True)
+        logger = logging.getLogger('influxdb_client.client.http')
+        self.assertEqual(1, len(logger.handlers))
+
+    def test_custom_debug_logging_handler(self):
+        logging.getLogger('influxdb_client.client.http').addHandler(logging.FileHandler('logs.log'))
+        self.influxdb_client = InfluxDBClient("http://localhost", "my-token", debug=True)
+        self.influxdb_client = InfluxDBClient("http://localhost", "my-token", debug=True)
+        logger = logging.getLogger('influxdb_client.client.http')
+        self.assertEqual(2, len(logger.handlers))
+
 
 class ServerWithSelfSingedSSL(http.server.SimpleHTTPRequestHandler):
     def _set_headers(self):