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
dZd8ddZdd Zed d
Zed d Zejd
d Zdd Zd9ddZdd Zdd Zdd Zd:ddZd;dd Zd d Z d s z8ApiClient.sanitize_for_serialization..c 3 s | ]} |V qd S NrU rV r) r r! s z7ApiClient.sanitize_for_serialization..c s0 i | ](\}}t |d k r j| t |qS rY )getattr
attribute_map)rW attr_)objr r!
s z8ApiClient.sanitize_for_serialization..c s i | ]\}}| |qS r rU )rW keyvalr) r r! r` s )
isinstancePRIMITIVE_TYPESlisttupler r isoformatr>
openapi_typesitems)r r_ Zobj_dictr )r_ r r! r= s,
z$ApiClient.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) _ApiClient__deserialize_filejsonloadsdata
ValueError_ApiClient__deserialize)r responserL rn r r r! rE s
zApiClient.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 rp )rW Zsub_datar Zsub_klsr r! rX s z+ApiClient.__deserialize..zdict(zdict\(([^,]*), (.*)\) c s i | ]\}}| |qS r rs )rW rR rS rt r r! r` s z+ApiClient.__deserialize..)typer
startswithrematchgroupri NATIVE_TYPES_MAPPINGr[ r domainrd !_ApiClient__deserialize_primitiver _ApiClient__deserialize_objectr r _ApiClient__deserialize_date _ApiClient__deserialize_datatime _ApiClient__deserialize_modelr rn klassr rt r! Z
__deserialize s2
zApiClient.__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.
)_ApiClient__call_apir+ Z apply_async)r r2 rH rI r5 rJ r8 r7 rK rL rM Z async_reqrN rO r9 r: rP threadr r r! call_api* sB , zApiClient.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)r5 r9 r: r6 HEADOPTIONS)r5 r6 r7 r9 r: r8 POSTPUTPATCHDELETE)r5 r6 r9 r: r8 zQhttp method must be `GET`, `HEAD`, `OPTIONS`, `POST`, `PATCH`, `PUT` or `DELETE`.N) r r r r r r r r ro )
r rH rT r5 r6 r7 r8 r9 r: rP r r r! rD h s
zApiClient.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 rY r rW r/ rR r r! rZ s z1ApiClient.parameters_to_tuples..Zssv Ztsv Zpipes|,c s s | ]}t |V qd S rY )r r r r r! rZ s )rc r> ri extendappendr' )r paramsrO
new_paramsrS Zcollection_format delimiterr r r! r? s( z ApiClient.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)
ri rv re openospathbasenamenameread mimetypes
guess_typer rf ) r r7 rK r rR rS Z
file_namesnffilenameZfiledatamimetyper r r! rA s& z!ApiClient.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 lowerrW xr r r! rX s z2ApiClient.select_header_accept..application/jsonz, )r' )r Zacceptsr r r! select_header_accept s z ApiClient.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! rX s z8ApiClient.select_header_content_type..z*/*r Nr )r Z
content_typesr r r! select_header_content_type s z$ApiClient.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/ inheaderra queryz3Authentication token must be in `query` or `header`)r rM getr ro )r r6 ZquerysrM authZ auth_settingr r r! rB s z ApiClient.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]+)[\'"]?rr wb)tempfilemkstempr Ztemp_folder_pathr r& remove getheaderrx searchrz r r' dirnamer writern )r rq fdr content_dispositionr r r r r! Z__deserialize_file s
z ApiClient.__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!ApiClient.__deserialize_primitivec C s |S )z rp r ) r rn r kwargsr] Z attr_typer/ instance
klass_namer r r! Z__deserialize_models s(
z ApiClient.__deserialize_modelr1 c C s. t | j| j|r*t| }|d d | _d S )Nru z
set-cookie)r r r r Zpost_signin_with_http_info)r r2 Z http_infor r r! r; s zApiClient._signinc C s$ t | j| jr t| d | _d S rY )r
r r r Z post_signoutr) r r r! r$ s zApiClient._signout)NNNNNF)
NNNNNNNNNNTNN)NNNNNNNNNNNTNN)NNNNTN)NN))__name__
__module__ __qualname____doc__r r bytesr r rd r r r r{ r% r" r* propertyr+ r setterr0 r r= rE rp r rD r? rA r r rB rk r} r~ r r r r; r$ r r r r! r s
R*(
>
D
r )r
__future__r r rl r r rx r Zmultiprocessing.poolr urllib.parser Zinfluxdb_client.domainr r r Zinfluxdb_client._syncr Z influxdb_client.configurationr Zinfluxdb_client.restr r
r r r r r r! s