feat: add support to configure redirects

Author: bednar

README.rst

@@ -1483,6 +1483,37 @@ Management API
         asyncio.run(main())
 
 
+Proxy and redirects
+"""""""""""""""""""
+
+You can configure the client to tunnel requests through an HTTP proxy.
+The following proxy options are supported:
+
+- ``proxy`` - Set this to configure the http proxy to be used, ex. ``http://localhost:3128``
+- ``proxy_headers`` - A dictionary containing headers that will be sent to the proxy. Could be used for proxy authentication.
+
+.. code-block:: python
+
+   from influxdb_client.client.influxdb_client_async import InfluxDBClientAsync
+
+
+   async with InfluxDBClientAsync(url="http://localhost:8086",
+                                  token="my-token",
+                                  org="my-org",
+                                  proxy="http://localhost:3128") as client:
+
+.. note::
+
+    If your proxy notify the client with permanent redirect (``HTTP 301``) to **different host**.
+    The client removes ``Authorization`` header, because otherwise the contents of ``Authorization`` is sent to third parties
+    which is a security vulnerability.
+
+Client automatically follows HTTP redirects. The default redirect policy is to follow up to ``10`` consecutive requests. The redirects can be configured via:
+
+- ``allow_redirects`` - If set to ``False``, do not follow HTTP redirects. ``True`` by default.
+- ``max_redirects`` - Maximum number of HTTP redirects to follow. ``10`` by default.
+
+
 .. marker-asyncio-end
 
 Local tests

influxdb_client/_async/api_client.py

@@ -63,14 +63,14 @@ class ApiClientAsync(object):
     _pool = None
 
     def __init__(self, configuration=None, header_name=None, header_value=None,
-                 cookie=None, pool_threads=None, retries=False):
+                 cookie=None, pool_threads=None, **kwargs):
         """Initialize generic API client."""
         if configuration is None:
             configuration = Configuration()
         self.configuration = configuration
         self.pool_threads = pool_threads
 
-        self.rest_client = rest.RESTClientObjectAsync(configuration)
+        self.rest_client = rest.RESTClientObjectAsync(configuration, **kwargs)
         self.default_headers = {}
         if header_name is not None:
             self.default_headers[header_name] = header_value

influxdb_client/_async/rest.py

@@ -81,7 +81,7 @@ class RESTClientObjectAsync(object):
     Do not edit the class manually.
     """
 
-    def __init__(self, configuration, pools_size=4, maxsize=None):
+    def __init__(self, configuration, pools_size=4, maxsize=None, **kwargs):
         """Initialize REST client."""
         # maxsize is number of requests to host that are allowed in parallel
         if maxsize is None:
@@ -104,6 +104,8 @@ def __init__(self, configuration, pools_size=4, maxsize=None):
 
         self.proxy = configuration.proxy
         self.proxy_headers = configuration.proxy_headers
+        self.allow_redirects = kwargs.get('allow_redirects', True)
+        self.max_redirects = kwargs.get('max_redirects', 10)
 
         # configure tracing
         trace_config = aiohttp.TraceConfig()
@@ -169,7 +171,9 @@ async def request(self, method, url, query_params=None, headers=None,
         args = {
             "method": method,
             "url": url,
-            "headers": headers
+            "headers": headers,
+            "allow_redirects": self.allow_redirects,
+            "max_redirects": self.max_redirects
         }
 
         if self.proxy:

influxdb_client/client/influxdb_client_async.py

@@ -38,13 +38,15 @@ def __init__(self, url, token, org: str = None, debug=None, timeout=10_000, enab
         :key bool auth_basic: Set this to true to enable basic authentication when talking to a InfluxDB 1.8.x that
                               does not use auth-enabled but is protected by a reverse proxy with basic authentication.
                               (defaults to false, don't set to true when talking to InfluxDB 2)
+        :key bool allow_redirects: If set to ``False``, do not follow HTTP redirects. ``True`` by default.
+        :key int max_redirects: Maximum number of HTTP redirects to follow. ``10`` by default.
         :key list[str] profilers: list of enabled Flux profilers
         """
         super().__init__(url=url, token=token, org=org, debug=debug, timeout=timeout, enable_gzip=enable_gzip, **kwargs)
 
         from .._async.api_client import ApiClientAsync
         self.api_client = ApiClientAsync(configuration=self.conf, header_name=self.auth_header_name,
-                                         header_value=self.auth_header_value, retries=self.retries)
+                                         header_value=self.auth_header_value, retries=self.retries, **kwargs)
 
     async def __aenter__(self) -> 'InfluxDBClientAsync':
         """