🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:46:26 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
_async
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_async/__pycache__
🔄 Refresh
✏️
Editing: api_client.cpython-38.pyc
Read Only
U v�i(h � @ s� d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl ZddlmZ ddlmZ ddlmZ dd lmZ dd lmZmZ G d d � d e�ZdS ) 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 d�Z dZd7dd�Zdd� Zedd � �Zed d � �Zejd d � �Zd d� Zd8dd�Zdd� Zdd� Zdd� Zd9dd�Zd:dd�Zd 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&ed2�d3d4�Z'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. )�int�long�float�str�bool�date�datetime�objectNc 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_client�default_headers�cookie�influxdb_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�_pool�join�r 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-Agent�r 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|d�I 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_path�Cookiez{%s})�safe)� query_params�headers� post_params�body�_preload_content�_request_timeoutF)r �_signinZ update_request_header_params�updater r �sanitize_for_serialization�dict�parameters_to_tuples�replacer r Zsafe_chars_for_path_param�prepare_post_parameters�update_params_for_authZupdate_request_body�host�requestZ last_response� deserialize�status� getheaders)r r/ �method� path_paramsr2 � header_paramsr5 r4 �files� response_type� auth_settings�_return_http_data_only�collection_formatsr6 r7 � urlopen_kw�config�k�v�urlZ response_dataZ return_datar r r! Z __call_apiq s~ � � � � � � �� �zApiClientAsync.__call_apic s� � dkr dS t � �j�r � S t � t�r8�fdd�� D �S t � t�rXt�fdd�� D ��S t � tjtjf�rr� �� S t � t�r�� }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! � <listcomp>� s �z=ApiClientAsync.sanitize_for_serialization.<locals>.<listcomp>c 3 s | ]}� � |�V qd S �NrR rS r' r r! � <genexpr>� s �z<ApiClientAsync.sanitize_for_serialization.<locals>.<genexpr>c s0 i | ](\}}t � |�d k r� j| t � |��qS rV )�getattr� attribute_map)rT �attr�_)�objr r! � <dictcomp>� s � z=ApiClientAsync.sanitize_for_serialization.<locals>.<dictcomp>c s i | ]\}}|� � |��qS r rR )rT �key�valr' r r! r] � s � ) � isinstance�PRIMITIVE_TYPES�list�tupler r � isoformatr; � openapi_types�items)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_file�json�loads�data� ValueError� _ApiClientAsync__deserialize)r �responserI rk r r r! rB � s zApiClientAsync.deserializec s� |dkr dS t |�tkr�|�d�rHt�d|��d��� �fdd�|D �S |�d�r|t�d|��d ��� �fd d �|�� D �S |� jkr�� j| }n tt j |�}|� j kr�� � ||�S |t krƈ �|�S |tjkrڈ �|�S |tjkr� �|�S � �||�S dS ) z�Deserializes 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_data�r Zsub_klsr r! rU s �z0ApiClientAsync.__deserialize.<locals>.<listcomp>zdict(zdict\(([^,]*), (.*)\)� c s i | ]\}}|� � |���qS r rp )rT rO rP rq r r! r] s � z0ApiClientAsync.__deserialize.<locals>.<dictcomp>)�typer � startswith�re�match�grouprf �NATIVE_TYPES_MAPPINGrX r �domainra �&_ApiClientAsync__deserialize_primitiver �#_ApiClientAsync__deserialize_objectr r �!_ApiClientAsync__deserialize_date�%_ApiClientAsync__deserialize_datatime�"_ApiClientAsync__deserialize_model�r 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 k�r | j j|f|||||d �| ��S td ��d S ) z'Make the HTTP request using RESTClient.�GET)r2 r6 r7 r3 �HEAD�OPTIONS)r2 r3 r4 r6 r7 r5 �POST�PUT�PATCH�DELETE)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 |t�r"|�� n|D ]�\� }� |kr�|� }|dkr`|�� fdd�|D �� q�|dkrnd}n |dkr|d}n|d kr�d }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 N�multic 3 s | ]}� |fV qd S rV r �rT r, �rO r r! rW � s z6ApiClientAsync.parameters_to_tuples.<locals>.<genexpr>Zssv� Ztsv� Zpipes�|�,c s s | ]}t |�V qd S rV )r r� r r r! rW � s )r` r; rf �extend�appendr& )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|d��J}tj�|j�} |�� } t � | �d pvd} |� t |t | | | g�g�� W 5 Q R X q@q|S )z�Build form parameters. :param post_params: Normal form parameters. :param files: File parameters. :return: Form parameters with files. �rbr zapplication/octet-stream) rf rs rb �open�os�path�basename�name�read� mimetypes� guess_typer� rc ) r r4 rH r� rO rP Z file_names�n�f�filenameZfiledata�mimetyper r r! r> � s& ��z&ApiClientAsync.prepare_post_parametersc C s0 |sdS dd� |D �}d|kr"dS d� |�S dS )z�Return `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 ��lower�rT �xr r r! rU � s z7ApiClientAsync.select_header_accept.<locals>.<listcomp>�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 )z�Return `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.<locals>.<listcomp>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 td��q 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, �in�headerr^ �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 )z�Deserializes 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)�tempfile�mkstempr 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 )z�Deserializes 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<Return an original value. :return: object. r r+ r r r! Z__deserialize_objectE s z#ApiClientAsync.__deserialize_objectc C s^ zddl m} ||��� W S tk r2 | Y S tk rX tjdd�|�d��Y nX dS )zYDeserializes string to date. :param string: str. :return: date. r ��parsez$Failed to parse `{0}` as date object�rC �reasonN)�dateutil.parserr� r � ImportErrorrl r � ApiException�format�r �stringr� r r r! Z__deserialize_dateL s �z!ApiClientAsync.__deserialize_datec C sZ zddl m} ||�W S tk r. | Y S tk rT tjdd�|�d��Y nX dS )z�Deserializes string to datetime. The string should be in iso8601 datetime format. :param string: str. :return: datetime. r r� z(Failed to parse `{0}` as datetime objectr� N)r� r� r� rl r r� r� r� r r r! Z__deserialize_datatime] s ��z%ApiClientAsync.__deserialize_datatimec C s� |j st|d�s|S i }|j dk rx|j �� D ]J\}}|dk r,|j| |kr,t|ttf�r,||j| }| �||�||< q,|f |�}t|d�r�|�|�}|r�| �||�}|S )z�Deserializes list or dict to model. :param data: dict, list. :param klass: class literal. :return: model object. �get_real_child_modelN) re �hasattrrf rY r` rb r; rm r� ) r rk r� r rZ Z attr_typer, �instance� klass_namer r r! Z__deserialize_models s( � � � z"ApiClientAsync.__deserialize_modelr. c � s8 t | j| j|�r4t| �jdd�I d H }|d d | _d S )NF)rK rr z set-cookie)r r r r Zpost_signin_async)r r/ Z http_infor r r! r8 � s zApiClientAsync._signinc � s* t | j| j�r&t| ��� I d H d | _d S rV )r r r r Zpost_signout_asyncr' r r r! r# � s zApiClientAsync._signout)NNNNN) NNNNNNNNNNTNN)NNNNNNNNNNNTNN)NNNNTN)NN))�__name__� __module__� __qualname__�__doc__r r �bytesr r ra r r r rx r% r" r$ �propertyr( r �setterr- r� r: rB rm r� rA r< r> 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! �<module> s
💾 Save Changes
❌ Cancel