🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 08:04:37 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
_sync
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_sync/__pycache__
🔄 Refresh
✏️
Editing: rest.cpython-38.pyc
Read Only
U v�i�; � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m Z ddl m Z z ddl Z W n e k r| e d��Y nX G dd � d ej�ZG 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)� urlencode)� ApiException)�_BaseRESTClientz'OpenAPI Python client requires urllib3.c @ s* e Zd ZdZdd� Zdd� Zd dd�ZdS ) � RESTResponse��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| _|j| _dS )z Initialize with HTTP response.N)�urllib3_response�status�reason�data)�self�resp� r �K/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_sync/rest.py�__init__% s zRESTResponse.__init__c C s | j jS )z,Return a dictionary of the response headers.)r �headers)r r r r � getheaders, s zRESTResponse.getheadersNc C s | j j�||�S )z Return a given response header.)r r �get)r �name�defaultr r r � getheader0 s zRESTResponse.getheader)N)�__name__� __module__� __qualname__�__doc__r r r r r r r r s r c @ sz e Zd ZdZd dd�Zd dd �Zd d d �Zd d d �Zd dd�Zd!dd�Z d"dd�Z d#dd�Z d$dd�Z dd� Z dd� ZdS )%�RESTClientObjectr � NFc C s� || _ || _|| _|| _|jr&tj}ntj}|jr:|j}nd}i }|j dk rV|j |d< | j|d< |dkr~|j dk rz|j }nd}|j r�t j f |||||j|j|j|j |j|jd� |��| _n,t jf |||||j|j|j|jd�|��| _dS )zInitialize REST client.N�assert_hostname�retriesr ) � num_pools�maxsize� cert_reqs�ca_certs� cert_file�key_file� key_password� proxy_url� proxy_headers� ssl_context)r r r! r" r# r$ r% r( )� configuration� pools_sizer r Z verify_ssl�ssl� CERT_REQUIRED� CERT_NONEZ ssl_ca_certr Zconnection_pool_maxsize�proxy�urllib3� ProxyManagerr# Z cert_key_fileZcert_key_passwordr' r( � pool_manager� PoolManager)r r) r* r r r! r" Zaddition_pool_argsr r r r < sZ � � � �zRESTClientObject.__init__Tc K s0 |� � }|dkst�|r$|r$td��|p*i }|p2i }d} |pB| jj} | r�t| ttf�rhtj | d d�} n4t| t �r�t | �dkr�tj | d d | d d d �} d |kr�d |d < | jj r�t �||� |dkr�d n d t|� � �� t �|d� t �|d� �zN|dk�r"|�r|d t|� 7 }t�d|d tj��rhd} |dk �rFt�|�} | jj||f| || |d�| ��} n�|d dk�r�| jj||f|d|| |d�| ��} n�|d dk�r�|d = | jj||f|d|| |d�| ��} nNt|t��s�t|t��r|} | jj||f| || |d�| ��} nd}td|d��n | jj||f||| |d�| ��} W nJ tj j k �r� } z&d� t |�j t|��}td|d��W 5 d}~X Y nX |�r�t!| �} | j"�#d�| _"| jj �rt �$| j%� t&| d ��r�t �| j'd � t&| d ��r�t �| j(j'd � t �| j"d � d | j% k�r d k�s,n t| d!��| S )"a9 Perform requests. :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: 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` )�GET�HEAD�DELETE�POST�PUT�PATCH�OPTIONSz9body parameter cannot be used with post_params parameter.Ni� )�total� r � )�connect�readz Content-Typezapplication/json� �?z>>>)r6 r7 r8 r9 r5 �json)�body�preload_content�timeoutr z!application/x-www-form-urlencodedF)�fields�encode_multipartrC rD r zmultipart/form-dataTz�Cannot prepare a request message for provided arguments. Please check that your arguments match declared content type.)r r )rE rC rD r z{0} {1}�utf8r z<<<r �� i+ )Z http_resp))�upper�AssertionError� ValueErrorr) rD � isinstance�int�floatr/ �Timeout�tuple�len�debugr Z log_requestr Z log_headersZlog_body�re�search� IGNORECASErA �dumpsr1 �request�str�bytesr � exceptions�SSLError�format�typer r r �decodeZ log_responser �hasattrr r )r �method�url� query_paramsr rB � post_params�_preload_content�_request_timeout� urlopen_kwrD Z_configured_timeout� request_body�r�msg�er r r rW | s� � � �( ��� ��� ��� ��� �� zRESTClientObject.requestc K s | j d|f||||d�|��S )zPerform GET HTTP request.r3 �r rd re rb �rW �r ra r rb rd re rf r r r r3 s ��zRESTClientObject.GETc K s | j d|f||||d�|��S )zPerform HEAD HTTP request.r4 rk rl rm r r r r4 s ��zRESTClientObject.HEADc K s" | j d|f||||||d�|��S )z Perform OPTIONS HTTP request.r9 �r rb rc rd re rB rl � r ra r rb rc rB rd re rf r r r r9 s ��zRESTClientObject.OPTIONSc K s | j d|f|||||d�|��S )z Perform DELETE HTTP request.r5 )r rb rd re rB rl )r ra r rb rB rd re rf r r r r5 ) s ��zRESTClientObject.DELETEc K s" | j d|f||||||d�|��S )zPerform POST HTTP request.r6 rn rl ro r r r r6 4 s ��zRESTClientObject.POSTc K s" | j d|f||||||d�|��S )zPerform PUT HTTP request.r7 rn rl ro r r r r7 @ s ��zRESTClientObject.PUTc K s" | j d|f||||||d�|��S )zPerform PATCH HTTP request.r8 rn rl ro r r r r8 L s ��zRESTClientObject.PATCHc C s | j �� }|d= |S )z4Return a dict of attributes that you want to pickle.r1 )�__dict__�copy�r �stater r r � __getstate__X s z RESTClientObject.__getstate__c C s( | j �|� | �| j| j| j| j� dS )z'Set your object with the provided dict.N)rp �updater r) r* r r rr r r r � __setstate___ s z RESTClientObject.__setstate__)r NF)NNNNTN)NNTN)NNTN)NNNNTN)NNNTN)NNNNTN)NNNNTN)NNNNTN)r r r r r rW r3 r4 r9 r5 r6 r7 r8 rt rv r r r r r 5 sR @ � � � � � � � � r )r � __future__r �iorA rS r+ � urllib.parser Zinfluxdb_client.restr r r/ � ImportError�IOBaser �objectr r r r r �<module> s
💾 Save Changes
❌ Cancel