U
vi(h @ s d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
ZddlmZ ddlmZ ddlmZ dd lmZ dd
lmZmZ G d d d eZdS )
a
InfluxDB OSS API Service.
The InfluxDB v2 API provides a programmatic interface for all interactions with InfluxDB. Access the InfluxDB API using the `/api/v2/` endpoint. # noqa: E501
OpenAPI spec version: 2.0.0
Generated by: https://openapi-generator.tech
)absolute_importN)
ThreadPool)quote)
SigninService)SignoutService)rest)
Configuration) _requires_create_user_session _requires_expire_user_sessionc @ s" e Zd ZdZeeeeefZ eeeeee
j e
j
e dZ
dZd7ddZdd Zedd Zed
d Zejd d Zd
d Zd8ddZdd Zdd Zdd Zd9ddZd:ddZd d Z d;d d Z d d! Z d"d# Z d$d% Z d&d' Z!d(d) Z"d*d+ Z#d,d- Z$d.d/ Z%d0d1 Z&ed2d3d4Z'd5d6 Z(dS )<ApiClientAsyncax Generic API client for OpenAPI client library Build.
OpenAPI generic API client. This client handles the client-
server communication, and is invariant across implementations. Specifics of
the methods and models for each application are generated from the OpenAPI
templates.
NOTE: This class is auto generated by OpenAPI Generator.
Ref: https://openapi-generator.tech
Do not edit the class manually.
:param configuration: .Configuration object for this client
:param header_name: a header to pass when making calls to the API.
:param header_value: a header value to pass when making calls to
the API.
:param cookie: a cookie to include in the header when making calls
to the API
:param pool_threads: The number of threads to use for async requests
to the API. More threads means more concurrent API requests.
)intlongfloatstrbooldatedatetimeobjectNc K sd |dkrt }|| _|| _tj|f|| _i | _|dk rB|| j|< || _ddlm } d| | _
dS )z Initialize generic API client.Nr )VERSIONzinfluxdb-client-python/) r
configuration pool_threadsr ZRESTClientObjectAsync rest_clientdefault_headerscookieinfluxdb_clientr
user_agent)selfr header_name header_valuer r kwargsr r R/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_async/api_client.py__init__A s
zApiClientAsync.__init__c sB | I dH | j I dH | jr>| j | j d| _dS )zDispose api client.N)_signoutr close_pooljoinr r r r! r$ R s
zApiClientAsync.closec C s | j dkrt| j| _ | j S )z`Create thread pool on first request avoids instantiating unused threadpool for blocking clients.N)r% r r r' r r r! pool\ s
zApiClientAsync.poolc C s
| j d S )z User agent for this API client.
User-Agentr r' r r r! r c s zApiClientAsync.user_agentc C s || j d< dS )z#Set User agent for this API client.r) Nr* r valuer r r! r h s c C s || j |< dS )z$Set HTTP header for this API client.Nr* )r r r r r r! set_default_headerm s z!ApiClientAsync.set_default_headerTc s | j }| j|dI d H |p i }||| || j | jrH| j|d< |rf| |}t| || }|r| |}| || }|D ]&\}}| d| t
t ||j d}q|r| |}| || }|s|r|
||}| |}| || }| |||
|r| |}|||}| j j| }|p.i }| j||f|||||
|d|I d H }|| _|}|
r| r|| || }nd }| dk r|S ||j| fS d S )N
resource_pathCookiez{%s})safe) query_paramsheaders post_paramsbody_preload_content_request_timeoutF)r _signinZ update_request_header_paramsupdater r sanitize_for_serializationdictparameters_to_tuplesreplacer r Zsafe_chars_for_path_paramprepare_post_parametersupdate_params_for_authZupdate_request_bodyhostrequestZ
last_response deserializestatus
getheaders)r r/ method path_paramsr2
header_paramsr5 r4 files
response_type
auth_settings_return_http_data_onlycollection_formatsr6 r7
urlopen_kwconfigkvurlZ
response_dataZ return_datar r r! Z
__call_apiq s~
zApiClientAsync.__call_apic s dkr dS t jr S t tr8fdd D S t trXtfdd D S t tjtjfrr S t tr }n fdd j D }fdd| D S ) a Build a JSON POST object.
If obj is None, return None.
If obj is str, int, long, float, bool, return directly.
If obj is datetime.datetime, datetime.date
convert to string in iso8601 format.
If obj is list, sanitize each element in the list.
If obj is dict, return the dict.
If obj is OpenAPI model, return the properties dict.
:param obj: The data to serialize.
:return: The serialized form of data.
Nc s g | ]} |qS r r: .0Zsub_objr' r r!
s z=ApiClientAsync.sanitize_for_serialization..c 3 s | ]} |V qd S NrR rS r' r r! s z.c s0 i | ](\}}t |d k r j| t |qS rV )getattr
attribute_map)rT attr_)objr r!
s z=ApiClientAsync.sanitize_for_serialization..c s i | ]\}}| |qS r rR )rT keyvalr' r r! r] s )
isinstancePRIMITIVE_TYPESlisttupler r isoformatr;
openapi_typesitems)r r\ Zobj_dictr )r\ r r! r: s,
z)ApiClientAsync.sanitize_for_serializationc C sJ |dkr| |S zt|j}W n tk
r< |j}Y nX | ||S )a Deserializes response into an object.
:param response: RESTResponse object to be deserialized.
:param response_type: class literal for
deserialized object, or string of class name.
:return: deserialized object.
file)!_ApiClientAsync__deserialize_filejsonloadsdata
ValueError _ApiClientAsync__deserialize)r responserI rk r r r! rB s
zApiClientAsync.deserializec s |dkr dS t |tkr|drHtd|d fdd|D S |dr|td|d fd
d | D S | jkr j| }n tt j
|}| j kr ||S |t
krƈ |S |tjkrڈ |S |tjkr |S ||S dS ) zDeserializes dict, list, str into an object.
:param data: dict, list or str.
:param klass: class literal, or string of class name.
:return: object.
Nzlist[z list\[(.*)\] c s g | ]} |qS r rm )rT Zsub_datar Zsub_klsr r! rU s z0ApiClientAsync.__deserialize..zdict(zdict\(([^,]*), (.*)\) c s i | ]\}}| |qS r rp )rT rO rP rq r r! r] s z0ApiClientAsync.__deserialize..)typer
startswithrematchgrouprf NATIVE_TYPES_MAPPINGrX r domainra &_ApiClientAsync__deserialize_primitiver #_ApiClientAsync__deserialize_objectr r !_ApiClientAsync__deserialize_date%_ApiClientAsync__deserialize_datatime"_ApiClientAsync__deserialize_modelr rk klassr rq r! Z
__deserialize s2
z ApiClientAsync.__deserializec C s\ | s*| ||||||||| |
| |
|||S | j| j ||||||||| |
| |
|||f}|S )a Make the HTTP request (synchronous) and Return deserialized data.
To make an async_req request, set the async_req parameter.
:param resource_path: Path to method endpoint.
:param method: Method to call.
:param path_params: Path parameters in the url.
:param query_params: Query parameters in the url.
:param header_params: Header parameters to be
placed in the request header.
:param body: Request body.
:param post_params dict: Request post form parameters,
for `application/x-www-form-urlencoded`, `multipart/form-data`.
:param auth_settings list: Auth Settings names for the request.
:param response: Response data type.
:param files dict: key -> filename, value -> filepath,
for `multipart/form-data`.
:param async_req bool: execute request asynchronously
:param _return_http_data_only: response data without head status code
and headers
:param collection_formats: dict of collection formats for path, query,
header, and post parameters.
:param _preload_content: if False, the urllib3.HTTPResponse object will
be returned without reading/decoding response
data. Default is True.
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
timeout. It can also be a pair (tuple) of
(connection, read) timeouts.
:param urlopen_kw: Additional parameters are passed to
:meth:`urllib3.request.RequestMethods.request`
:return:
If async_req parameter is True,
the request will be called asynchronously.
The method will return the request thread.
If parameter async_req is False or missing,
then the method will return the response directly.
)_ApiClientAsync__call_apir( Z apply_async)r r/ rE rF r2 rG r5 r4 rH rI rJ Z async_reqrK rL r6 r7 rM threadr r r! call_api* sB , zApiClientAsync.call_apic
K s, |dkr&| j j|f||||d| S |dkrL| j j|f||||d| S |dkrv| j j|f||||||d| S |dkr| j j|f||||||d| S |dkr| j j|f||||||d| S |dk r| j j|f||||||d| S |d kr | j j|f|||||d
| S td d S )
z'Make the HTTP request using RESTClient.GET)r2 r6 r7 r3 HEADOPTIONS)r2 r3 r4 r6 r7 r5 POSTPUTPATCHDELETE)r2 r3 r6 r7 r5 zQhttp method must be `GET`, `HEAD`, `OPTIONS`, `POST`, `PATCH`, `PUT` or `DELETE`.N) r r r r r r r r rl )
r rE rQ r2 r3 r4 r5 r6 r7 rM r r r! rA h s
zApiClientAsync.requestc s g }|dkri }t |tr"| n|D ]\ } |kr| }|dkr`| fdd|D q|dkrnd}n |dkr|d}n|d krd
}nd }| |d d |D f q&| |f q&|S )
a
Get parameters as list of tuples, formatting collections.
:param params: Parameters as dict or list of two-tuples
:param dict collection_formats: Parameter collection formats
:return: Parameters as list of tuples, collections formatted
Nmultic 3 s | ]} |fV qd S rV r rT r, rO r r! rW s z6ApiClientAsync.parameters_to_tuples..Zssv Ztsv Zpipes|,c s s | ]}t |V qd S rV )r r r r r! rW s )r` r; rf extendappendr& )r paramsrL
new_paramsrP Zcollection_format delimiterr r r! r< s( z#ApiClientAsync.parameters_to_tuplesc C s g }|r |}|r| D ]\}}|s&qt|tkr6|n|g}|D ]^}t|dJ}tj|j} | }
t
| d pvd} | t |t | |
| gg W 5 Q R X q@q|S )zBuild form parameters.
:param post_params: Normal form parameters.
:param files: File parameters.
:return: Form parameters with files.
rbr zapplication/octet-stream)
rf rs rb openospathbasenamenameread mimetypes
guess_typer rc ) r r4 rH r rO rP Z
file_namesnffilenameZfiledatamimetyper r r! r> s& z&ApiClientAsync.prepare_post_parametersc C s0 |sdS dd |D }d|kr"dS d |S dS )zReturn `Accept` based on an array of accepts provided.
:param accepts: List of headers.
:return: Accept (e.g. application/json).
Nc S s g | ] }| qS r lowerrT xr r r! rU s z7ApiClientAsync.select_header_accept..application/jsonz, )r& )r Zacceptsr r r! select_header_accept s z#ApiClientAsync.select_header_acceptc C s6 |sdS dd |D }d|ks&d|kr*dS |d S dS )zReturn `Content-Type` based on an array of content_types provided.
:param content_types: List of content-types.
:return: Content-Type (e.g. application/json).
r c S s g | ] }| qS r r r r r r! rU s z=ApiClientAsync.select_header_content_type..z*/*r Nr )r Z
content_typesr r r! select_header_content_type s z)ApiClientAsync.select_header_content_typec C s |sdS |D ]n}| j |}|r |d s0q q |d dkrN|d ||d < q |d dkrr||d |d f q tdq dS )a Update header and query params based on authentication setting.
:param headers: Header parameters dict to be updated.
:param querys: Query parameters tuple list to be updated.
:param auth_settings: Authentication setting identifiers list.
Nr, inheaderr^ queryz3Authentication token must be in `query` or `header`)r rJ getr rl )r r3 ZquerysrJ authZ auth_settingr r r! r? s z%ApiClientAsync.update_params_for_authc C s t j| jjd\}}t| t| |d}|r^t d|
d}tj tj
||}t|d}||j W 5 Q R X |S )zDeserializes body to file.
Saves response body into a file in a temporary folder,
using the filename from the `Content-Disposition` header if provided.
:param response: RESTResponse.
:return: file path.
)dirzContent-Dispositionz filename=[\'"]?([^\'"\s]+)[\'"]?ro wb)tempfilemkstempr Ztemp_folder_pathr r$ remove getheaderru searchrw r r& dirnamer writerk )r rn fdr content_dispositionr r r r r! Z__deserialize_file s
z!ApiClientAsync.__deserialize_filec C sB z
||W S t k
r& t| Y S tk
r< | Y S X dS )zDeserializes string to primitive type.
:param data: str.
:param klass: class literal.
:return: int, long, float, str, bool.
N)UnicodeEncodeErrorr TypeErrorr r r r! Z__deserialize_primitive6 s
z&ApiClientAsync.__deserialize_primitivec C s |S )z r r r? rh rz r{ r| r} r~ r8 r# r r r r! r s
R*(
>
D
r )r
__future__r r ri r r ru r Zmultiprocessing.poolr urllib.parser Zinfluxdb_client.domainr r r Zinfluxdb_client._asyncr Z influxdb_client.configurationr Zinfluxdb_client.restr r
r r r r r r! s