core: fulfill requirements for PR

examples/README.md

@@ -9,6 +9,7 @@
 - [import_data_set_sync_batching.py](import_data_set_sync_batching.py) - How to use [RxPY](https://rxpy.readthedocs.io/en/latest/) to prepare batches for synchronous write into InfluxDB
 - [write_api_callbacks.py](write_api_callbacks.py) - How to handle batch events
 - [write_structured_data.py](write_structured_data.py) - How to write structured data - [NamedTuple](https://docs.python.org/3/library/collections.html#collections.namedtuple), [Data Classes](https://docs.python.org/3/library/dataclasses.html) - (_requires Python v3.8+_)
+- [logging_handler.py](logging_handler.py) - How to set up a python native logging handler that writes to influx.
 
 ## Queries
 - [query.py](query.py) - How to query data into `FluxTable`s, `Stream` and `CSV`

examples/logging_handler.py

@@ -10,6 +10,7 @@
 import time
 
 from influxdb_client import InfluxLoggingHandler, WritePrecision, Point
+from influxdb_client.client.write_api import SYNCHRONOUS
 
 DATA_LOGGER_NAME = '…'
 
@@ -20,9 +21,10 @@ def setup_logger():
 
     This can happen in your core module.
     """
-    influx_logging_handler = InfluxLoggingHandler(url="…", token="…", org="…", bucket="…",
-                                                  client_args={'arg1': '…'},
-                                                  write_api_args={'arg': '…'})
+    influx_logging_handler = InfluxLoggingHandler(
+        url="http://localhost:8086", token="my-token", org="my-org", bucket="my-bucket",
+        client_args={'timeout': 30_000},  # optional configuration of the client
+        write_api_args={'write_options': SYNCHRONOUS})  # optional configuration of the write api
     influx_logging_handler.setLevel(logging.DEBUG)
 
     data_logger = logging.getLogger(DATA_LOGGER_NAME)
@@ -45,3 +47,8 @@ def use_logger():
             .field('temperature', 25.3)
             .time(datetime.datetime.utcnow(), WritePrecision.MS)
     )
+
+
+if __name__ == "__main__":
+    setup_logger()
+    use_logger()

influxdb_client/client/write/point.py

@@ -53,8 +53,6 @@ class Point(object):
     Ref: http://bit.ly/influxdata-point
     """
 
-    __str___rep = None
-
     @staticmethod
     def measurement(measurement):
         """Create a new Point with specified measurement name."""
@@ -201,17 +199,8 @@ def set_str_rep(cls, rep_function):
         cls.__str___rep = rep_function
 
     def __str__(self):
-        """
-        Create string representation of this Point.
-
-        Can be set via `Point.set_str_rep`. Defaults to `to_line_protocol`
-        Example:
-            .. code-block:: python
-                Point.set_str_rep(lambda p: f'{p._name} - {p._tags} - {p._fields} - {p._time}')
-        """
-        if self.__str___rep is None:
-            return self.to_line_protocol()
-        return self.__str___rep()
+        """Create string representation of this Point."""
+        return self.to_line_protocol()
 
 
 def _append_tags(tags):

tests/test_point.py

@@ -13,16 +13,9 @@ class PointTest(unittest.TestCase):
 
     def test_ToStr(self):
         point = Point.measurement("h2o").tag("location", "europe").field("level", 2.2)
-        expected_str = "h2o,location=europe level=2.2"
+        expected_str = point.to_line_protocol()
         self.assertEqual(expected_str, str(point))
 
-        def my_str_rep(p: Point) -> str:
-            return f'{p._name} - {p._tags} - {p._fields} - {p._time}'
-
-        Point.set_str_rep(my_str_rep)
-
-        self.assertEqual(my_str_rep(point), str(point))
-
     def test_MeasurementEscape(self):
         point = Point.measurement("h2 o").tag("location", "europe").tag("", "warn").field("level", 2)
         self.assertEqual(point.to_line_protocol(), "h2\\ o,location=europe level=2i")