From 9f868d930750f81e9bc7bc2fcbac90c3be191b68 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Bedn=C3=A1=C5=99?= Date: Wed, 9 Sep 2026 13:24:29 +0200 Subject: [PATCH 1/4] fix: remove stale influxdb_client references from v3 docs --- CHANGELOG.md | 4 +++- influxdb_client_3/query/query_api.py | 6 +++--- .../write_client/_sync/rest_client.py | 6 +++--- .../write_client/client/util/date_utils.py | 4 ++-- .../client/util/multiprocessing_helper.py | 16 ++++++++-------- .../write_client/client/warnings.py | 4 ++-- .../client/write/dataframe_serializer.py | 2 +- .../client/write/polars_dataframe_serializer.py | 2 +- .../write_client/client/write/retry.py | 2 +- 9 files changed, 24 insertions(+), 22 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index e8416bb5..9f802136 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,7 +4,9 @@ ### Bug Fixes -1. [#237](https://github.com/InfluxCommunity/influxdb3-python/pull/237): Makes the writing API simpler and more consistent with other v3 clients: +1. [#242](https://github.com/InfluxCommunity/influxdb3-python/issues/242): Remove stale `influxdb_client` references from v3 docstrings, examples, comments, and logger names. + +2. [#237](https://github.com/InfluxCommunity/influxdb3-python/pull/237): Makes the writing API simpler and more consistent with other v3 clients: - Further simplifies the `WriteApi` request path by constructing v2/v3 requests directly through `RestClient`, while preserving existing write behavior. ## 0.21.0 [2026-08-27] diff --git a/influxdb_client_3/query/query_api.py b/influxdb_client_3/query/query_api.py index 7dc615fe..c913f32b 100644 --- a/influxdb_client_3/query/query_api.py +++ b/influxdb_client_3/query/query_api.py @@ -140,12 +140,12 @@ class QueryApi(object): .. code-block:: python - from influxdb_client import InfluxDBClient + from influxdb_client_3 import InfluxDBClient3 # Initialize instance of QueryApi - with InfluxDBClient(url="http://localhost:8086", token="my-token") as client: - query_api = client.query_api() + with InfluxDBClient3(host="http://localhost:8086", token="my-token", database="my-database") as client: + result = client.query("from(bucket: \"my-bucket\") |> range(start: -1h)") """ def __init__(self, diff --git a/influxdb_client_3/write_client/_sync/rest_client.py b/influxdb_client_3/write_client/_sync/rest_client.py index 354b3e7a..2d2b41dc 100644 --- a/influxdb_client_3/write_client/_sync/rest_client.py +++ b/influxdb_client_3/write_client/_sync/rest_client.py @@ -37,7 +37,7 @@ def getheader(self, name, default=None): class RestClient(object): - logger = logging.getLogger('influxdb_client.client.http') + logger = logging.getLogger('influxdb_client_3.write_client._sync.rest_client') def __init__(self, base_url, @@ -213,13 +213,13 @@ def debug(self, value): if not any(map(lambda h: isinstance(h, logging.StreamHandler) and h.stream == sys.stdout, self.logger.handlers)): self.logger.addHandler(logging.StreamHandler(sys.stdout)) - # we use 'influxdb_client.client.http' logger instead of this + # we use 'influxdb_client_3.write_client._sync.rest_client' logger instead of this # httplib.HTTPConnection.debuglevel = 1 else: # if debug status is False, turn off debug logging, # setting log level to default `logging.WARNING` self.logger.setLevel(logging.WARNING) - # we use 'influxdb_client.client.http' logger instead of this + # we use 'influxdb_client_3.write_client._sync.rest_client' logger instead of this # httplib.HTTPConnection.debuglevel = 0 @staticmethod diff --git a/influxdb_client_3/write_client/client/util/date_utils.py b/influxdb_client_3/write_client/client/util/date_utils.py index e7e42389..bf08660d 100644 --- a/influxdb_client_3/write_client/client/util/date_utils.py +++ b/influxdb_client_3/write_client/client/util/date_utils.py @@ -19,8 +19,8 @@ class DateHelper: .. code-block:: python - from influxdb_client.client.util import date_utils - from influxdb_client.client.util.date_utils import DateHelper + from influxdb_client_3.write_client.client.util import date_utils + from influxdb_client_3.write_client.client.util.date_utils import DateHelper import dateutil.parser from dateutil import tz diff --git a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py index c864f8aa..7dbb35ad 100644 --- a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py +++ b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py @@ -13,7 +13,7 @@ from influxdb_client_3.write_client import WriteOptions, WriteApi from influxdb_client_3.write_client._sync import rest_client -logger = logging.getLogger('influxdb_client.client.util.multiprocessing_helper') +logger = logging.getLogger('influxdb_client_3.write_client.client.util.multiprocessing_helper') def _success_callback(conf: (str, str, str), data: str): @@ -44,8 +44,8 @@ class MultiprocessingWriter: Example: .. code-block:: python - from influxdb_client import WriteOptions - from influxdb_client.client.util.multiprocessing_helper import MultiprocessingWriter + from influxdb_client_3 import WriteOptions + from influxdb_client_3.write_client.client.util.multiprocessing_helper import MultiprocessingWriter def main(): @@ -66,8 +66,8 @@ def main(): How to use with context_manager: .. code-block:: python - from influxdb_client import WriteOptions - from influxdb_client.client.util.multiprocessing_helper import MultiprocessingWriter + from influxdb_client_3 import WriteOptions + from influxdb_client_3.write_client.client.util.multiprocessing_helper import MultiprocessingWriter def main(): @@ -84,9 +84,9 @@ def main(): How to handle batch events: .. code-block:: python - from influxdb_client import WriteOptions - from influxdb_client.client.exceptions import InfluxDBError - from influxdb_client.client.util.multiprocessing_helper import MultiprocessingWriter + from influxdb_client_3 import WriteOptions + from influxdb_client_3.exceptions import InfluxDBError + from influxdb_client_3.write_client.client.util.multiprocessing_helper import MultiprocessingWriter class BatchingCallback(object): diff --git a/influxdb_client_3/write_client/client/warnings.py b/influxdb_client_3/write_client/client/warnings.py index b682ff86..367590d6 100644 --- a/influxdb_client_3/write_client/client/warnings.py +++ b/influxdb_client_3/write_client/client/warnings.py @@ -19,7 +19,7 @@ def print_warning(query: str): You can disable this warning by: import warnings - from influxdb_client.client.warnings import MissingPivotFunction + from influxdb_client_3.write_client.client.warnings import MissingPivotFunction warnings.simplefilter("ignore", MissingPivotFunction) @@ -45,7 +45,7 @@ def print_warning(api_name: str, doc_url: str): You can disable this warning by: import warnings - from influxdb_client.client.warnings import CloudOnlyWarning + from influxdb_client_3.write_client.client.warnings import CloudOnlyWarning warnings.simplefilter("ignore", CloudOnlyWarning) """ diff --git a/influxdb_client_3/write_client/client/write/dataframe_serializer.py b/influxdb_client_3/write_client/client/write/dataframe_serializer.py index 55d73198..4c6a41de 100644 --- a/influxdb_client_3/write_client/client/write/dataframe_serializer.py +++ b/influxdb_client_3/write_client/client/write/dataframe_serializer.py @@ -12,7 +12,7 @@ from influxdb_client_3.write_client.client.write.point import _ESCAPE_KEY, _ESCAPE_STRING, _ESCAPE_MEASUREMENT, \ DEFAULT_WRITE_PRECISION, ordered_tag_keys -logger = logging.getLogger('influxdb_client.client.write.dataframe_serializer') +logger = logging.getLogger('influxdb_client_3.write_client.client.write.dataframe_serializer') def _not_nan(x): diff --git a/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py b/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py index 7c2e4cf5..9bf2d3d9 100644 --- a/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py +++ b/influxdb_client_3/write_client/client/write/polars_dataframe_serializer.py @@ -10,7 +10,7 @@ from influxdb_client_3.write_client.client.write.point import _ESCAPE_KEY, _ESCAPE_STRING, DEFAULT_WRITE_PRECISION, \ ordered_tag_keys -logger = logging.getLogger('influxdb_client.client.write.polars_dataframe_serializer') +logger = logging.getLogger('influxdb_client_3.write_client.client.write.polars_dataframe_serializer') class PolarsDataframeSerializer: diff --git a/influxdb_client_3/write_client/client/write/retry.py b/influxdb_client_3/write_client/client/write/retry.py index a472f347..d469b224 100644 --- a/influxdb_client_3/write_client/client/write/retry.py +++ b/influxdb_client_3/write_client/client/write/retry.py @@ -11,7 +11,7 @@ from influxdb_client_3.exceptions import InfluxDBError -logger = logging.getLogger('influxdb_client.client.write.retry') +logger = logging.getLogger('influxdb_client_3.write_client.client.write.retry') class WritesRetry(Retry): From f4e24ca4e906b8b246cbea3da9d2a849ae402eae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Bedn=C3=A1=C5=99?= Date: Wed, 9 Sep 2026 13:45:23 +0200 Subject: [PATCH 2/4] docs: fix v3 examples in review feedback --- influxdb_client_3/query/query_api.py | 2 +- .../write_client/client/util/multiprocessing_helper.py | 9 ++++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/influxdb_client_3/query/query_api.py b/influxdb_client_3/query/query_api.py index c913f32b..e95a62a5 100644 --- a/influxdb_client_3/query/query_api.py +++ b/influxdb_client_3/query/query_api.py @@ -145,7 +145,7 @@ class QueryApi(object): # Initialize instance of QueryApi with InfluxDBClient3(host="http://localhost:8086", token="my-token", database="my-database") as client: - result = client.query("from(bucket: \"my-bucket\") |> range(start: -1h)") + result = client.query("SELECT * FROM my_measurement", language="sql") """ def __init__(self, diff --git a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py index 7dbb35ad..04f486b9 100644 --- a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py +++ b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py @@ -49,7 +49,8 @@ class MultiprocessingWriter: def main(): - writer = MultiprocessingWriter(url="http://localhost:8086", token="my-token", org="my-org", + writer = MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", + database="my-bucket", write_options=WriteOptions(batch_size=100)) writer.start() @@ -71,7 +72,8 @@ def main(): def main(): - with MultiprocessingWriter(url="http://localhost:8086", token="my-token", org="my-org", + with MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", + database="my-bucket", write_options=WriteOptions(batch_size=100)) as writer: for x in range(1, 1000): writer.write(bucket="my-bucket", record=f"mem,tag=a value={x}i {x}") @@ -103,7 +105,8 @@ def retry(self, conf: (str, str, str), data: str, exception: InfluxDBError): def main(): callback = BatchingCallback() - with MultiprocessingWriter(url="http://localhost:8086", token="my-token", org="my-org", + with MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", + database="my-bucket", success_callback=callback.success, error_callback=callback.error, retry_callback=callback.retry) as writer: From bcdbe38d71dcdb68b03a9228ec1049590b0154c0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Bedn=C3=A1=C5=99?= Date: Wed, 9 Sep 2026 14:05:39 +0200 Subject: [PATCH 3/4] docs: align v3 examples with client terminology --- influxdb_client_3/query/query_api.py | 2 +- influxdb_client_3/write_client/_sync/rest_client.py | 4 ++-- .../client/util/multiprocessing_helper.py | 12 ++++++------ 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/influxdb_client_3/query/query_api.py b/influxdb_client_3/query/query_api.py index e95a62a5..d2c4d17b 100644 --- a/influxdb_client_3/query/query_api.py +++ b/influxdb_client_3/query/query_api.py @@ -143,7 +143,7 @@ class QueryApi(object): from influxdb_client_3 import InfluxDBClient3 - # Initialize instance of QueryApi + # Query data from InfluxDB with InfluxDBClient3(host="http://localhost:8086", token="my-token", database="my-database") as client: result = client.query("SELECT * FROM my_measurement", language="sql") """ diff --git a/influxdb_client_3/write_client/_sync/rest_client.py b/influxdb_client_3/write_client/_sync/rest_client.py index 2d2b41dc..f124b9d0 100644 --- a/influxdb_client_3/write_client/_sync/rest_client.py +++ b/influxdb_client_3/write_client/_sync/rest_client.py @@ -213,13 +213,13 @@ def debug(self, value): if not any(map(lambda h: isinstance(h, logging.StreamHandler) and h.stream == sys.stdout, self.logger.handlers)): self.logger.addHandler(logging.StreamHandler(sys.stdout)) - # we use 'influxdb_client_3.write_client._sync.rest_client' logger instead of this + # HTTP debug logging is handled by the 'influxdb_client_3.write_client._sync.rest_client' logger. # httplib.HTTPConnection.debuglevel = 1 else: # if debug status is False, turn off debug logging, # setting log level to default `logging.WARNING` self.logger.setLevel(logging.WARNING) - # we use 'influxdb_client_3.write_client._sync.rest_client' logger instead of this + # HTTP debug logging is handled by the 'influxdb_client_3.write_client._sync.rest_client' logger. # httplib.HTTPConnection.debuglevel = 0 @staticmethod diff --git a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py index 04f486b9..bc686bcb 100644 --- a/influxdb_client_3/write_client/client/util/multiprocessing_helper.py +++ b/influxdb_client_3/write_client/client/util/multiprocessing_helper.py @@ -50,12 +50,12 @@ class MultiprocessingWriter: def main(): writer = MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", - database="my-bucket", + database="my-database", write_options=WriteOptions(batch_size=100)) writer.start() for x in range(1, 1000): - writer.write(bucket="my-bucket", record=f"mem,tag=a value={x}i {x}") + writer.write(bucket="my-database", record=f"mem,tag=a value={x}i {x}") writer.__del__() @@ -73,10 +73,10 @@ def main(): def main(): with MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", - database="my-bucket", + database="my-database", write_options=WriteOptions(batch_size=100)) as writer: for x in range(1, 1000): - writer.write(bucket="my-bucket", record=f"mem,tag=a value={x}i {x}") + writer.write(bucket="my-database", record=f"mem,tag=a value={x}i {x}") if __name__ == '__main__': @@ -106,13 +106,13 @@ def retry(self, conf: (str, str, str), data: str, exception: InfluxDBError): def main(): callback = BatchingCallback() with MultiprocessingWriter(host="http://localhost:8086", token="my-token", org="my-org", - database="my-bucket", + database="my-database", success_callback=callback.success, error_callback=callback.error, retry_callback=callback.retry) as writer: for x in range(1, 1000): - writer.write(bucket="my-bucket", record=f"mem,tag=a value={x}i {x}") + writer.write(bucket="my-database", record=f"mem,tag=a value={x}i {x}") if __name__ == '__main__': From 05325facfd6e005843e4135c77bddd7833ed85ea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Bedn=C3=A1=C5=99?= Date: Wed, 9 Sep 2026 14:18:04 +0200 Subject: [PATCH 4/4] docs: Update CHANGELOG with bug fixes and API improvements Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> --- CHANGELOG.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 9f802136..1d758e06 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,7 +4,7 @@ ### Bug Fixes -1. [#242](https://github.com/InfluxCommunity/influxdb3-python/issues/242): Remove stale `influxdb_client` references from v3 docstrings, examples, comments, and logger names. +1. [#243](https://github.com/InfluxCommunity/influxdb3-python/pull/243): Remove stale `influxdb_client` references from v3 docstrings, examples, comments, and logger names. (Closes #242) 2. [#237](https://github.com/InfluxCommunity/influxdb3-python/pull/237): Makes the writing API simpler and more consistent with other v3 clients: - Further simplifies the `WriteApi` request path by constructing v2/v3 requests directly through `RestClient`, while preserving existing write behavior.