refactor: write rest client

Author: NguyenHoangSon96

influxdb_client_3/__init__.py

@@ -309,9 +309,10 @@ def __init__(
 
         auth_schema = 'Token' if auth_scheme is None else auth_scheme
         default_header = {
-            'Authorization': f'{auth_schema} {self._token}',
             'User-Agent': USER_AGENT
         }
+        if self._token is not None:
+            default_header['Authorization'] = f'{auth_schema} {self._token}'
         self.base_url = f"{scheme}://{hostname}:{port}"
         self.default_header = default_header
         self.rest_client = rest.RestClient(

influxdb_client_3/write_client/client/write_api.py

@@ -768,10 +768,10 @@ def _post_write(self, _async_req, bucket, org, body, precision, no_sync, accept_
                 query_params,
                 header_params,
                 body=body_params,
-                async_req=local_var_params.get('async_req'),
+                async_req=_async_req,
                 _request_timeout=local_var_params.get('_request_timeout'),
                 urlopen_kw=http_kwargs.get('urlopen_kw', None))
-            if local_var_params.get('async_req'):
+            if _async_req:
                 original_get = result.get
 
                 def translated_get(timeout=None):