🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 23:22:24 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
client
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/__pycache__
🔄 Refresh
✏️
Editing: _base.cpython-38.pyc
Read Only
U v�i�^ � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZmZ ddl m Z m Z m Z m Z mZmZ ddlmZ ddlmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z* ddl+m,Z,m-Z-m.Z. dd l/m0Z0m1Z1m2Z2 dd l3m4Z4 dd l5m6Z6 dd l7m8Z8 dd l9m:Z: ddl;m<Z< zddl=Z=dZ>W n e?k �rb dZ>Y nX dddddddddg Z@G dd� deA�ZBG d d � d eA�ZCG d d � d eA�ZDG d d!� d!eA�ZEG d"d#� d#e�ZFd$d%� ZGd&d'� ZHdS )(z+Commons function for Sync and Async client.� )�absolute_importN)�datetime� timedelta)�List� Generator�Any�Union�Iterable�AsyncGenerator)� HTTPResponse)� Configuration�Dialect�Query�OptionStatement�VariableAssignment� Identifier� Expression�BooleanLiteral�IntegerLiteral� FloatLiteral�DateTimeLiteral�UnaryExpression�DurationLiteral�Duration� StringLiteral�ArrayExpression�ImportDeclaration�MemberExpression�MemberAssignment�File� WriteService� QueryService� DeleteService�DeletePredicateRequest)�FluxResponseMetadataMode� FluxCsvParser�FluxSerializationMode)� FluxRecord� TableList� CSVIterator)�get_date_helper)�get_org_query_param)�MissingPivotFunction)�DataframeSerializer)�_UTF_8_encodingTFz&influxdb_client.client.influxdb_clientz,influxdb_client.client.influxdb_client_asyncz influxdb_client.client.write_apiz&influxdb_client.client.write_api_asyncz"influxdb_client.client.write.retryz1influxdb_client.client.write.dataframe_serializerz2influxdb_client.client.util.multiprocessing_helperzinfluxdb_client.client.httpz!influxdb_client.client.exceptionsc @ sD e Zd Zd eeedd�dd�Zeded�d d ��Zedd d ��ZdS )� _BaseClientN�' F)�org� default_tags�http_client_logger�returnc K s� || _ || _|| _|| _t� | _t| j t�s4td��| j � d�rT| j d d� | j_ n | j | j_ || j_ | � dd�| j_ | � dd �| j_| � dd �| j_| � dd �| j_| � d d �| j_| � d d �| j_| � d d �| j_| � d d �| j_| � d | jj�| j_|| j_t�|�| jjd< tD ]} t�| �| jj| < �q|| j_| � dd �| j_ | � dd �| j_ d | _ d | _ | j�r�d| _ d| j | _ | � dd�} | �r�d| _ dt �!|�"� ��#� | _ | jj �r�| jj �r�d | _ d | _ | � dd�| _$| � dd �| _%d S )Nz#"url" attribute is not str instance�/���� verify_sslT� ssl_ca_cert� cert_file� cert_key_file�cert_key_password� ssl_context�proxy� proxy_headers�connection_pool_maxsizer3 �username�password� AuthorizationzToken � auth_basicFzBasic �retries� profilers)&�url�tokenr1 r2 �_Configuration�conf� isinstance�str� ValueError�endswith�host� enable_gzip�getr7 r8 r9 r: r; r< r= r> r? �timeout�logging� getLogger�loggers� LOGGERS_NAMES�debugr@ rA Zauth_header_nameZauth_header_value�base64� b64encode�encode�decoderD rE ) �selfrF rG rV rQ rO r1 r2 r3 �kwargsZ client_loggerrC � r] �M/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/_base.py�__init__/ sT z_BaseClient.__init__� config.ini)� config_filec s. t �� � |�dd��d�z� �|� W n@ t jk rf t|�� }dd l}|�|�� d�W 5 Q R X Y nX td�� ��fdd� }td�� ��fd d � }td�� �fd d � } |d �} |d�} d } |d�r�|d�} d } |d�r�|d�} d}|d�r�|d�}d }|d��r |d�}d }|d��r |d�}d }|d��r6|d�}d }|d��rL|d�}d }|d��rb|d�}d}|d��rx|d�}d }| d��r���r�� d }n dd� � � d�D �}t |�}d }|d��r�d d � |d�� d �D �}d }|d ��r�|d �}| | | f|t | �| ||t |�||||t |�t |�||d �|��S )!N� config_nameZinflux2Fr T��keyc s& �rt � | �n � � | }|�d�S )N�")rK �strip)rd �value��configrb �is_jsonr] r^ � _config_valuet s z4_BaseClient._from_config_file.<locals>._config_valuec s �r | � kS � � �| �S �N)� has_optionrc rh r] r^ � _has_optionx s z2_BaseClient._from_config_file.<locals>._has_optionc s �r | � kS � � | �S rl )� has_sectionrc )ri rj r] r^ � _has_section{ s z3_BaseClient._from_config_file.<locals>._has_sectionrF rG rQ r1 r7 r8 r9 r: r; r? rC �tagsc S s i | ]\}}||� d ��qS )re �rf )�.0�k�vr] r] r^ � <dictcomp>� s z1_BaseClient._from_config_file.<locals>.<dictcomp>rE c S s g | ] }|� � �qS r] rr �rs �xr] r] r^ � <listcomp>� s z1_BaseClient._from_config_file.<locals>.<listcomp>�,r= )rV rQ r1 r2 rO r7 r8 r9 r: r; r? rC rE r= )� configparser� ConfigParserrP �read� ParsingError�open�json�loadrK �items�dict�split�_to_int�_to_bool)�clsra rV rO r\ Z json_filer� rk rn rp rF rG rQ r1 r7 r8 r9 r: r; r? rC r2 rq rE r= r] rh r^ �_from_config_fileg s� ��z _BaseClient._from_config_filec K s& t �dd�}t �dd�}t �dd�}t �dd�}t �d d �}t �d d �} t �d d �} t �d d �} t �dd �} t �dd �} t �dd�}t �dd �}d }|d k r�dd� |�d�D �}t� }t j�� D ]&\}}|�d�r�|||dd � �� < q�| ||f|t|�|||t |�| | | | t| �t |�|d� |��S )NZINFLUXDB_V2_URLzhttp://localhost:8086ZINFLUXDB_V2_TOKENzmy-tokenZINFLUXDB_V2_TIMEOUTZ10000ZINFLUXDB_V2_ORGzmy-orgZINFLUXDB_V2_VERIFY_SSL�TrueZINFLUXDB_V2_SSL_CA_CERTZINFLUXDB_V2_CERT_FILEZINFLUXDB_V2_CERT_KEY_FILEZ INFLUXDB_V2_CERT_KEY_PASSWORDZ#INFLUXDB_V2_CONNECTION_POOL_MAXSIZEZINFLUXDB_V2_AUTH_BASIC�FalseZINFLUXDB_V2_PROFILERSc S s g | ] }|� � �qS r] rr rw r] r] r^ ry � s z4_BaseClient._from_env_properties.<locals>.<listcomp>rz ZINFLUXDB_V2_TAG_� ) rV rQ r1 r2 rO r7 r8 r9 r: r; r? rC rE ) �os�getenvr� r� �environr� � startswith�lowerr� r� )r� rV rO r\ rF rG rQ r1 r7 r8 r9 r: r; r? rC �profrE r2 rd rg r] r] r^ �_from_env_properties� s@ ��z _BaseClient._from_env_properties)Nr0 FNNN)r` NF)NF) �__name__� __module__� __qualname__rK r� r_ � classmethodr� r� r] r] r] r^ r/ . s � � 8Sr/ c @ sl e Zd Zeddddddgdd�Zd8d d �Zd ejfeed �d d�Z d ejfeed �dd�Z e e d�dd�Z d ejfeeeed f d �dd�Zd ejfeed d �dd�Zd ejdfed�dd �Zd ejdfed�d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zed fe d+�d,d-�Z e e e d. d/�d0d1��Z e e!e"d f d2�d3d4��Z#e d9e e e$ d5�d6d7��Z%d S ):� _BaseQueryApiTrz �#�datatype�group�defaultZRFC3339)�header� delimiterZcomment_prefix� annotationsZdate_time_formatNc C s6 ddl m} |d kr|� n|| _|| _t|j�| _d S )Nr �� QueryOptions)� influxdb_client.client.query_apir� �_query_options�_influxdb_clientr! � api_clientZ _query_api)r[ �influxdb_client� query_optionsr� r] r] r^ r_ � s z_BaseQueryApi.__init__)�response_metadata_moder4 c C s" | � |||�}t|�� � |�� S )z� Parse HTTP response to TableList. :param response: HTTP response from an HTTP client. Expected type: `urllib3.response.HTTPResponse`. )�_to_tables_parser�list� generator� table_list�r[ �responser� r� �_parserr] r] r^ � _to_tables� s z_BaseQueryApi._to_tablesc � sZ | � |||�4 I dH �4}|�� 2 z 3 dH W }q 6 |�� W 5 Q I dH R � S Q I dH R X dS )z� Parse HTTP response to TableList. :param response: HTTP response from an HTTP client. Expected type: `aiohttp.client_reqrep.ClientResponse`. N)r� �generator_asyncr� )r[ r� r� r� �parser�_r] r] r^ �_to_tables_async� s z _BaseQueryApi._to_tables_async)r� r4 c C s t |�S )zParse HTTP response to CSV.)r) )r[ r� r] r] r^ �_to_csv� s z_BaseQueryApi._to_csvc C s | � |||�}|�� S )z� Parse HTTP response to FluxRecord stream. :param response: HTTP response from an HTTP client. Expected type: `urllib3.response.HTTPResponse`. )� _to_flux_record_stream_parserr� r� r] r] r^ �_to_flux_record_stream s z$_BaseQueryApi._to_flux_record_stream)r' Nc � s | � |||�}|�� I dH �� S )z� Parse HTTP response to FluxRecord stream. :param response: HTTP response from an HTTP client. Expected type: `aiohttp.client_reqrep.ClientResponse`. N)r� � __aenter__r� r� r] r] r^ � _to_flux_record_stream_async s z*_BaseQueryApi._to_flux_record_stream_asyncF)r� c C s | � |||||�}|�� S )z� Parse HTTP response to DataFrame stream. :param response: HTTP response from an HTTP client. Expected type: `urllib3.response.HTTPResponse`. )� _to_data_frame_stream_parserr� �r[ �data_frame_indexr� r� r� �use_extension_dtypesr� r] r] r^ �_to_data_frame_stream s �z#_BaseQueryApi._to_data_frame_streamc � s$ | � |||||�}|�� I dH �� S )z� Parse HTTP response to DataFrame stream. :param response: HTTP response from an HTTP client. Expected type: `aiohttp.client_reqrep.ClientResponse`. N)r� r� r� r� r] r] r^ �_to_data_frame_stream_async% s �z)_BaseQueryApi._to_data_frame_stream_asyncc C s t |tj||d�S �N)r� �serialization_moder� r� )r% r& Ztables)r[ r� r� r� r] r] r^ r� 1 s �z _BaseQueryApi._to_tables_parserc C s t |tj||d�S r� )r% r& �stream)r[ r� r� r� r] r] r^ r� 5 s �z+_BaseQueryApi._to_flux_record_stream_parserc C s t |tj||||d�S )N)r� r� r� r� r� r� )r% r& Z dataFrame)r[ r� r� r� r� r� r] r] r^ r� 9 s �z*_BaseQueryApi._to_data_frame_stream_parserc C sZ ddl m} t|t�r |}nt|�}t|�dkr>|jg dd�S t|�dkrR|d S |S dS )z.Parse stream of DataFrames into expected type.� )�pdr N)�columns�index� )�extrasr� rJ r� �len� DataFrame)r[ Z _generatorr� Z _dataFramesr] r] r^ �_to_data_frames@ s z _BaseQueryApi._to_data_framesc C s t || jd�S )N)r1 �client)r+ r� )r[ r1 r] r] r^ � _org_paramO s z_BaseQueryApi._org_paramc C s: | j r| j jr| j S | jjr6ddlm} || jjd�S d S )Nr r� )rE )r� rE r� r� r� )r[ r� r] r] r^ �_get_query_optionsR s z _BaseQueryApi._get_query_options)�paramsc K sn | � � }|d k r|jnd }t||t�||�d�}|rTtd� td� td� t|� |�dd�rjt�|� |S )N)�query�dialectZexternz ===============zProfiler: queryz===============Zdataframe_queryF) r� rE r r� �_build_flux_ast�printrP r, Z print_warning)r[ r� r� r� r\ r� rE �qr] r] r^ � _create_queryY s z_BaseQueryApi._create_queryr )r� r4 c C sL g }| � � D ]:\}}t�|�}|d kr(q |�tdtdtd|�|��� q |S )Nr r r )r� r� �_parm_to_extern_ast�appendr r r )r� Z statementsrd rg Z expressionr] r] r^ �_params_to_extern_asti s ��z#_BaseQueryApi._params_to_extern_ast)r4 c C s< | d kr d S t | t�r td| �S t | t�r8tdt| ��S t | t�rLtd| �S t | t�r�t � � | �} t | dd�}| j d | d�}t d| �d �| d �S t | t�� r�t| td d � �}|dk r�td tdt| dd�g�dd�S tdt|dd�g�S nDt | t��rtdt| ��S t | t��r4tdttdd� | ��d�S | S d S )Nr r r Z nanosecondr i� Z09dr z%Y-%m-%dT%H:%M:%S.�Zr� )� microsecondsr r �us)Z magnitude�unit�-)�argument�operatorr r c S s t �| �S rl )r� r� )�itr] r] r^ �<lambda>� � z3_BaseQueryApi._parm_to_extern_ast.<locals>.<lambda>��elements)rJ �boolr �intr rK �floatr r r* �to_utc�getattr� microsecondr �strftimer r r r r r r r� �map)rg � nanoseconds�fractionZ _micro_deltar] r] r^ r� w s: �� �z!_BaseQueryApi._parm_to_extern_ast)r� rE c C s� g }g }|d k r�t |�dkr�|�tdtdd�d�� g }|D ]}|�td|d�� q<tdtdd�tdd �d �}td td |td |d�d�d�}|�|� | d k r�|� t � | �� t d d d ||d�S )Nr r r �profiler��path)rg r r ZenabledProfilers)�objectZ _propertyr r r r� )�member�init)Z assignment)�package�name�type�imports�body) r� r� r r r r r r r �extendr� r� r )r� rE r� r� r� r� r� r� r] r] r^ r� � s< ����� z _BaseQueryApi._build_flux_ast)N)NN)&r� r� r� r Zdefault_dialectr_ r$ �fullr( r� r� r r) r� r r' r r� r r� r� r� r� r� r� r� r� r� r� r� � staticmethodr r� r r r� rK r� r] r] r] r^ r� � sn � � � � � � � �� �� �� r� c @ s. e Zd Zd dd�Zdd� Zdd� Zdd � ZdS ) � _BaseWriteApiNc C sD || _ || _t|j�| _|jr@|j�� D ]\}}| j�||� q(d S rl )r� �_point_settingsr r� Z_write_servicer2 r� Zadd_default_tag)r[ r� Zpoint_settingsrd rg r] r] r^ r_ � s z_BaseWriteApi.__init__c C s� ddl m} t|t�s�t|t�r"n`t||�r:|�||� nHt|t�r`|�di � ||�d�|< n"t|t �r�|D ]}| � |||� qnd S )Nr ��Pointrq ) r� r� rJ �bytesrK �tagr� � setdefaultrP r �_append_default_tag)r[ rd �val�recordr� �itemr] r] r^ r � s z!_BaseWriteApi._append_default_tagc C s8 | j jr4|d k r4| j j�� D ]\}}| �|||� q d S rl )r� Z defaultTagsr� r )r[ r rd r r] r] r^ �_append_default_tags� s z"_BaseWriteApi._append_default_tagsc K st ddl m} t|t�r(|| �|� �nHt|t�rN| j|�t�||f|� �n"t||�r�|� dd�}|rn|j n|}| j|j |d�||f|� n�t|t �r�| j|j |fd|i|��||f|� n�dt|�jkr�t|| j|f|�}| j|�� ||f|� nzt|d��r| j|�� ||f|� nVt�rFt�|��rF| jt�|�||f|� n*t|t��rp|D ]} | j| ||f|� �qVd S ) Nr r� �precision_from_pointT)� precision�write_precisionr� �_asdict)r� r� rJ r r� rK � _serializerY r. rP r Zto_line_protocolr� � from_dictr� r� r- r� � serialize�hasattrr �_HAS_DATACLASS� dataclasses� is_dataclass�asdictr ) r[ r r �payloadr\ r� r r � serializerr r] r] r^ r � s4 �� z_BaseWriteApi._serialize)N)r� r� r� r_ r r r r] r] r] r^ r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�_BaseDeleteApic C s || _ t|j�| _d S rl )r� r" r� Z_service)r[ r� r] r] r^ r_ � s z_BaseDeleteApi.__init__c C s@ t � }t|t�r|�|�}t|t�r.|�|�}t|||d�}|S )N)�start�stop� predicate)r* rJ r r� r# )r[ r r r Z date_helperZpredicate_requestr] r] r^ �_prepare_predicate_request� s z)_BaseDeleteApi._prepare_predicate_requestN)r� r� r� r_ r r] r] r] r^ r � s r c s> e Zd Zdd� Zeed�� fdd� Zed�� fdd� Z� ZS ) rH c C s t �| � d| _d | _d | _d S )NF)r r_ rO r@ rA )r[ r] r] r^ r_ s z_Configuration.__init__)r� r� c s@ t � �||� | jr<|dkr,d|d< d|d< |dkr<d|d< d S )N� /api/v2/write�gzipzContent-Encoding�identityzAccept-Encodingz /api/v2/query)�super� update_request_header_paramsrO )r[ r� r� �� __class__r] r^ r s z+_Configuration.update_request_header_paramsr� c sN t � �||�}| jrJ|dkrJdd l}t|t�r:|j|d�S |�t|t��S |S )Nr r )�data)r �update_request_bodyrO r rJ r �compressr. )r[ r� r� �_bodyr r r] r^ r# s z"_Configuration.update_request_body) r� r� r� r_ rK r� r r# � __classcell__r] r] r r^ rH s rH c C s t | ��� dkS )N)�yes�true)rK r� )Z bool_valuer] r] r^ r� ' s r� c C s | d k rt | �S d S rl )r� )Z int_valuer] r] r^ r� + s r� )I�__doc__� __future__r rW r{ rR r� r r �typingr r r r r r �urllib3r r� r r r r r r r r r r r r r r r r r r r r r r! r" r# Z&influxdb_client.client.flux_csv_parserr$ r% r& Z!influxdb_client.client.flux_tabler' r( r) Z&influxdb_client.client.util.date_utilsr* Z#influxdb_client.client.util.helpersr+ Z influxdb_client.client.warningsr, Z1influxdb_client.client.write.dataframe_serializerr- Zinfluxdb_client.restr. r r �ModuleNotFoundErrorrU r� r/ r� r� r rH r� r� r] r] r] r^ �<module> sP h � / _9%
💾 Save Changes
❌ Cancel