🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:12:00 | 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: rest.cpython-38.pyc
Read Only
U v�ih1 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlZddlm Z ddlm Z ddlm Z dd� Z d d � Z d d � ZG d d� dej�ZG dd� de�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 � N)� urlencode)� ApiException)�_BaseRESTClient)�_UTF_8_encodingc � s" t �|j|j� t �|jd� d S �Nz>>>)r Z log_request�method�url� log_headers�headers)�session�trace_config_ctx�params� r �L/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_async/rest.py�_on_request_start s r c � s |j rt�|j d� d S r )�chunkr �log_body)r �contextr r r r �_on_request_chunk_sent s r c � sp t �|jj� t �|jd� |jj}t� }|�d�I d H }|s@qJ||7 }q*|rlt � |� t �d� |j |d� d S )Nz<<<�d )�data) r Z log_response�response�statusr r �content� bytearray�readr �decoder Z unread_data)r r r Zresponse_contentr r r r r �_on_request_end" s r c @ s* e Zd ZdZdd� Zdd� Zd dd�ZdS ) �RESTResponseAsync��NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. c C s || _ |j| _|j| _|| _dS )z Initialize with HTTP response.N)�aiohttp_responser �reasonr )�self�respr r r r �__init__9 s zRESTResponseAsync.__init__c C s | j jS )z2Return a CIMultiDictProxy of the response headers.)r r �r" r r r � getheaders@ s z RESTResponseAsync.getheadersNc C s | j j�||�S )z Return a given response header.)r r �get)r" �name�defaultr r r � getheaderD s zRESTResponseAsync.getheader)N)�__name__� __module__� __qualname__�__doc__r$ r& r* r r r r r 2 s r c @ sr e Zd ZdZddd�Zdd� Zdd d �Zdd d �Zd d d�Zd dd�Z d dd�Z d dd�Z d dd�Z d!dd�Z dS )"�RESTClientObjectAsyncr � Nc K sJ |dkr|j }|jdkrXtj|jd�}|jrB|j|j|j|jd� |j s^d|_ tj |_ n|j}t j||d�}|j| _|j| _|�dd�| _|�dd �| _t �� }|j�t� |j�t� |j�t� t |j t t f�r�t j |j d d �}n t |j t j �r�|j }nt j!j"}|�d t j#�} |�d i �} | f |||j$�r6|gndd�| ��| _%dS )zInitialize REST client.N)�cafile)�certfile�keyfile�passwordF)�limit�ssl�allow_redirectsT� max_redirects� i� )�totalZclient_session_typeZclient_session_kwargs)� connector�timeoutZ trace_configs)&Zconnection_pool_maxsize� ssl_contextr6 �create_default_contextZ ssl_ca_cert� cert_file�load_cert_chainZ cert_key_fileZcert_key_passwordZ verify_ssl�check_hostname� CERT_NONE� verify_mode�aiohttpZ TCPConnector�proxy� proxy_headersr' r7 r8 Z TraceConfigZon_request_start�appendr Zon_request_chunk_sentr Zon_request_endr � isinstancer< �int�floatZ ClientTimeout�client�DEFAULT_TIMEOUTZ ClientSession�debug� pool_manager) r" � configurationZ pools_size�maxsize�kwargsr= r; Z trace_configr< Z_client_session_typeZ_client_session_kwargsr r r r$ P sP � � ��z RESTClientObjectAsync.__init__c � s | j �� I dH dS )z Dispose connection pool manager.N)rN �closer% r r r rR � s zRESTClientObjectAsync.closeTc � s� |� � }|dkst�|r$|r$td��|p*i }|p2i }d|krDd|d< |||| j| jd�} | jrh| j| d< | jrx| j| d< |r�| d d t|� 7 < |d k�r�t� d |d tj �r�|d k r�t � |�}|| d < n�|d dkr�t �|�| d < n�|d dk�rj|d= t �� } |D ]T} | \} } t| t��rPt| �dk�rP| j| | d | d | d d� n | �| | � �q | | d < n&t|t��r�|| d < nd}td|d��| jjf | �I d H }|�r�|�� I d H } t|| �}d|j k�r�dk�s�n t|d��|S )aP Execute request. :param method: http request method :param url: http request url :param query_params: query parameters in the url :param headers: http request headers :param body: request json body, for `application/json` :param post_params: request post parameters, `application/x-www-form-urlencoded` and `multipart/form-data` :param _preload_content: this is a non-applicable field for the AiohttpClient. :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. )�GET�HEAD�DELETE�POST�PUT�PATCH�OPTIONSz9body parameter cannot be used with post_params parameter.z Content-Typezapplication/json)r r r r7 r8 rE rF r �?)rV rW rX rY rU �jsonNr z!application/x-www-form-urlencodedzmultipart/form-data� � r � )�value�filename� content_typez�Cannot prepare a request message for provided arguments. Please check that your arguments match declared content type.)r r! �� i+ )Z http_resp)�upper�AssertionError� ValueErrorr7 r8 rE rF r �re�search� IGNORECASEr[ �dumpsrD ZFormDatarH �tuple�lenZ add_field�bytesr rN �requestr r r )r" r r � query_paramsr �body� post_params�_preload_content�_request_timeout�argsr �param�k�v�msg�rr r r rm � sj �� � z RESTClientObjectAsync.requestc � s | j d|||||d�I dH S )zPerform GET HTTP request.rS �r rq rr rn N�rm �r" r r rn rq rr r r r rS � s �zRESTClientObjectAsync.GETc � s | j d|||||d�I dH S )zPerform HEAD HTTP request.rT ry Nrz r{ r r r rT � s �zRESTClientObjectAsync.HEADc � s | j d|||||||d�I dH S )z Perform OPTIONS HTTP request.rY �r rn rp rq rr ro Nrz �r" r r rn rp ro rq rr r r r rY � s �z RESTClientObjectAsync.OPTIONSc � s | j d||||||d�I dH S )z Perform DELETE HTTP request.rU )r rn rq rr ro Nrz )r" r r rn ro rq rr r r r rU s �z RESTClientObjectAsync.DELETEc � s | j d|||||||d�I dH S )zPerform POST HTTP request.rV r| Nrz r} r r r rV s �zRESTClientObjectAsync.POSTc � s | j d|||||||d�I dH S )zPerform PUT HTTP request.rW r| Nrz r} r r r rW s �zRESTClientObjectAsync.PUTc � s | j d|||||||d�I dH S )zPerform PATCH HTTP request.rX r| Nrz r} r r r rX + s �zRESTClientObjectAsync.PATCH)r0 N)NNNNTN)NNTN)NNTN)NNNNTN)NNNTN)NNNNTN)NNNNTN)NNNNTN)r+ r, r- r. r$ rR rm rS rT rY rU rV rW rX r r r r r/ I sX 6 � b � � � � � � �r/ )r. �ior[ rf r6 � urllib.parser rD Zinfluxdb_client.restr r r r r r �IOBaser �objectr/ r r r r �<module> s
💾 Save Changes
❌ Cancel