Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/__pycache__/client.cpython-39.pyc
Ðазад
a p�h<e � @ s| d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z ddl m Z e� � Z G dd� de�ZG dd � d e�ZdS ) z Python client for InfluxDB v0.8.� N)�xrange)�urlparse)� chunked_jsonc s" e Zd ZdZd� fdd� Z� ZS )�InfluxDBClientErrorz+Raised when an error occurs in the request.���c s( t t| ��d�||�� || _|| _dS )z*Initialize an InfluxDBClientError handler.z{0}: {1}N)�superr �__init__�format�content�code)�selfr r �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/client.pyr s �z InfluxDBClientError.__init__)r )�__name__� __module__� __qualname__�__doc__r � __classcell__r r r r r s r c @ sl e Zd ZdZd^d d �Zed d � �Zd d� Zdd� Zdd� Z d_dd�Z dd� Z d`dd�Z dad d �Z d d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zdbd(d)�Zdcd*d+�Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Zd6d7� Zd8d9� Zd:d;� Z d<d=� Z d>d?� Z d@dA� Z dBdC� Z dDdE� Z!dFdG� Z"dHdI� Z#dJdK� Z$dLdM� Z%dNdO� Z&dPdQ� Z'dddRdS�Z(dTdU� Z)dedVdW�Z*dXdY� Z+dZd[� Z,d\d]� Z-dS )f�InfluxDBClientap Define the standard InfluxDBClient for influxdb v0.8. The ``InfluxDBClient`` object holds information necessary to connect to InfluxDB. Requests can be made to InfluxDB directly through the client. :param host: hostname to connect to InfluxDB, defaults to 'localhost' :type host: string :param port: port to connect to InfluxDB, defaults to 'localhost' :type port: int :param username: user to connect, defaults to 'root' :type username: string :param password: password of the user, defaults to 'root' :type password: string :param database: database name to connect to, defaults is None :type database: string :param ssl: use https instead of http to connect to InfluxDB, defaults is False :type ssl: boolean :param verify_ssl: verify SSL certificates for HTTPS requests, defaults is False :type verify_ssl: boolean :param retries: number of retries your client will try before aborting, defaults to 3. 0 indicates try until success :type retries: int :param timeout: number of seconds Requests will wait for your client to establish a connection, defaults to None :type timeout: int :param use_udp: use UDP to connect to InfluxDB, defaults is False :type use_udp: int :param udp_port: UDP port to connect to InfluxDB, defaults is 4444 :type udp_port: int � localhost� �rootNF� �\ c C s� || _ || _|| _|| _|| _|| _| | _|| _| | _| | _ | rRt � t j t j �| _ d| _|du rfd| _d�| j| j | j�| _ddd�| _dS ) z&Construct a new InfluxDBClient object.�httpT�httpsz {0}://{1}:{2}zapplication/jsonz text/plain)z Content-type�AcceptN)�_hostZ_port� _username� _password� _database�_timeout�_retries� _verify_ssl�_use_udp� _udp_port�socket�AF_INET� SOCK_DGRAM� udp_socketZ_schemer �_baseurl�_headers) r �host�port�username�password�database�sslZ verify_ssl�timeout�retries�use_udpZudp_portr r r r ? s. ��zInfluxDBClient.__init__c K s i }t | �}|j�d�}t|�dkr2|d }d}n|\}}|dkrPtd�|���|r�|dkrfd|d < n |d krxd|d < ntd �|���|jr�|j|d < |jr�|j|d< |jr�|j|d< |j r�|j |d< |j r�t|j �dkr�|j dd� |d< |� |� t f i |��S )a@ Return an instaance of InfluxDBClient from given data source name. Returns an instance of InfluxDBClient from the provided data source name. Supported schemes are "influxdb", "https+influxdb", "udp+influxdb". Parameters for the InfluxDBClient constructor may be also be passed to this function. Examples: >> cli = InfluxDBClient.from_dsn('influxdb://username:password@\ ... localhost:8086/databasename', timeout=5) >> type(cli) <class 'influxdb.client.InfluxDBClient'> >> cli = InfluxDBClient.from_dsn('udp+influxdb://username:pass@\ ... localhost:8086/databasename', timeout=5, udp_port=159) >> print('{0._baseurl} - {0.use_udp} {0.udp_port}'.format(cli)) http://localhost:8086 - True 159 :param dsn: data source name :type dsn: string :param **kwargs: additional parameters for InfluxDBClient. :type **kwargs: dict :note: parameters provided in **kwargs may override dsn parameters. :note: when using "udp+influxdb" the specified port (if any) will be used for the TCP connection; specify the udp port with the additional udp_port parameter (cf. examples). :raise ValueError: if the provided DSN has any unexpected value. �+� r N�influxdbzUnknown scheme "{0}".ZudpTr6 r r3 zUnknown modifier "{0}".r. r/ r0 r1 r2 ) r �scheme�split�len� ValueErrorr �hostnamer/ r0 r1 �path�updater )Zdsn�kwargsZ init_argsZ conn_paramsZ scheme_infor: �modifierr r r �from_dsni s6 zInfluxDBClient.from_dsnc C s || _ dS )z|Change client database. :param database: the new database name to switch to :type database: string N)r" �r r2 r r r �switch_database� s z InfluxDBClient.switch_databasec C s t �dt� | �|�S )z5Change client database. DEPRECATED. z�switch_db is deprecated, and will be removed in future versions. Please use ``InfluxDBClient.switch_database(database)`` instead.)�warnings�warn� FutureWarningrE rD r r r � switch_db� s �zInfluxDBClient.switch_dbc C s || _ || _dS )z�Change client username. :param username: the new username to switch to :type username: string :param password: the new password to switch to :type password: string N)r r! )r r0 r1 r r r � switch_user� s zInfluxDBClient.switch_user�GET�� c C s� d� | j|�}|du ri }| j| jd�}|�|� |durNt|t�sNt�|�}d}d}|r�z&t j ||||| j | j | j d�} W q�W qV tjjtjjfy� |d7 }| jdkr�|| jk }Y qV0 qVtjj�| j|kr�| S t| j| j��dS )zMake a http request to API.z{0}/{1}N)�u�pTr )�method�url�params�data�headers�verifyr4 r8 )r r, r r! r@ � isinstance�str�json�dumps�session�requestr- r% r# �requests� exceptions�ConnectionError�Timeoutr$ � status_coder r ) r rP rO rQ rR �expected_response_code�auth�retryZ_try�responser r r rZ � sB � � � zInfluxDBClient.requestc C s | j ddd|dd� dS )z<Provide as convenience for influxdb v0.9.0, this may change.�write�POSTNrL �rP rO rQ rR r` T�rZ )r rR r r r rd � s �zInfluxDBClient.write�sc O s� dd� }|� d�}|rx|dkrx|D ]P}|� d�}|� d�} |� dg �} || |�D ] } | || d�g}| j||d � qPq"d S | j||d �S ) a Write to multiple time series names. An example data blob is: data = [ { "points": [ [ 12 ] ], "name": "cpu_load_short", "columns": [ "value" ] } ] :param data: A list of dicts in InfluxDB 0.8.x data format. :param time_precision: [Optional, default 's'] Either 's', 'm', 'ms' or 'u'. :param batch_size: [Optional] Value to write the points in batches instead of all at one time. Useful for when doing data dumps from one database to another or when doing a massive write operation :type batch_size: int c s s, t dt| �|�D ]}| ||| � V qdS )z'Yield successive n-sized chunks from l.r N)r r< )Z data_list�n�ir r r � list_chunks' s z0InfluxDBClient.write_points.<locals>.list_chunks� batch_sizer �name�columns�points)ro rm rn �rR �time_precisionT)�get� _write_points) r rR rq �argsrA rk rl �itemrm rn Z point_list�batchr r r � write_points s( �� �zInfluxDBClient.write_pointsc C s t �dt� | j||d�S )zBWrite to multiple time series names. DEPRECATED. z�write_points_with_precision is deprecated, and will be removed in future versions. Please use ``InfluxDBClient.write_points(time_precision='..')`` instead.rp )rF rG rH rs )r rR rq r r r �write_points_with_precisionA s �z*InfluxDBClient.write_points_with_precisionc C sd |dvrt d��| jr&|dkr&t d��d�| j�}d|i}| jrL| �|� n| j|d||dd � d S ) N�rh �m�msrM �<Invalid time precision is given. (use 's', 'm', 'ms' or 'u')rh z7InfluxDB only supports seconds precision for udp writes� db/{0}/seriesrq re rL rf T)� Exceptionr& r r" � send_packetrZ )r rR rq rP rQ r r r rs M s* �� � �z InfluxDBClient._write_pointsc C s" d� | j|�}| j|ddd� dS )zDelete an entire series.�db/{0}/series/{1}�DELETE�� �rP rO r` T�r r" rZ )r rm rP r r r � delete_pointsl s �z InfluxDBClient.delete_pointsc C s t � �dS )z�Create schedule delete from database. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 N��NotImplementedError)r � json_bodyr r r �create_scheduled_deletez s z&InfluxDBClient.create_scheduled_deletec C s t � �dS )z�Get list of scheduled deletes. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� �r r r r �get_list_scheduled_delete� s z(InfluxDBClient.get_list_scheduled_deletec C s t � �dS )z�Remove scheduled delete. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� )r Z delete_idr r r �remove_scheduled_delete� s z&InfluxDBClient.remove_scheduled_deletec C s | j |||d�S )a Query data from the influxdb v0.8 database. :param time_precision: [Optional, default 's'] Either 's', 'm', 'ms' or 'u'. :param chunked: [Optional, default=False] True if the data shall be retrieved in chunks, False otherwise. )rq �chunked��_query)r �queryrq r� r r r r� � s �zInfluxDBClient.queryc C s� |dvrt d��|du r d}nd}d�| j�}|||d�}| j|d|d d �}|r�zt�|j�� �}W n$ ty� t�|j�d ��}Y n0 t |�S |� � S ) Nry r| T�true�falser} )�qrq r� rK rL )rP rO rQ r` �utf-8) r~ r r" rZ r �loadsr �decode�UnicodeDecodeError�listrW ) r r� rq r� Z chunked_paramrP rQ rc �decodedr r r r� � s2 � �� zInfluxDBClient._queryc C s" d}d|i}| j |d|dd� dS )z�Create a database on the InfluxDB server. :param database: the name of the database to create :type database: string :rtype: boolean �dbrm re �� �rP rO rR r` Trg )r r2 rP rR r r r �create_database� s �z InfluxDBClient.create_databasec C s d� |�}| j|ddd� dS )z�Drop a database on the InfluxDB server. :param database: the name of the database to delete :type database: string :rtype: boolean zdb/{0}r� r� r� T�r rZ )r r2 rP r r r �delete_database� s �z InfluxDBClient.delete_databasec C s d}| j |ddd�}|�� S )zGet the list of databases.r� rK rL r� �rZ rW �r rP rc r r r �get_list_database s �z InfluxDBClient.get_list_databasec C s t �dt� | �� S )z8Get the list of databases. DEPRECATED. z�get_database_list is deprecated, and will be removed in future versions. Please use ``InfluxDBClient.get_list_database`` instead.)rF rG rH r� r� r r r �get_database_list s �z InfluxDBClient.get_database_listc C s" d� | j|�}| j|ddd� dS )z�Drop a series on the InfluxDB server. :param series: the name of the series to delete :type series: string :rtype: boolean r� r� r� r� Tr� )r �seriesrP r r r � delete_series s ��z InfluxDBClient.delete_seriesc C s | � d�}dd� |d d D �S )z,Get a list of all time series in a database.z list seriesc S s g | ] }|d �qS )r8 r )�.0r� r r r � <listcomp>/ � z2InfluxDBClient.get_list_series.<locals>.<listcomp>r ro r� �r rc r r r �get_list_series, s z InfluxDBClient.get_list_seriesc C s | � d�}dd� |d d D �S )z!Get a list of continuous queries.zlist continuous queriesc S s g | ] }|d �qS )� r )r� r� r r r r� 4 r� z>InfluxDBClient.get_list_continuous_queries.<locals>.<listcomp>r ro r� r� r r r �get_list_continuous_queries1 s z*InfluxDBClient.get_list_continuous_queriesc C s | j dddd�}|�� S )zGet list of cluster admins.�cluster_adminsrK rL r� r� r� r r r �get_list_cluster_adminsU s �z&InfluxDBClient.get_list_cluster_adminsc C s ||d�}| j dd|dd� dS )zAdd cluster admin.�rm r1 r� re rL r� Trg )r � new_username� new_passwordrR r r r �add_cluster_admin_ s ��z InfluxDBClient.add_cluster_adminc C s( d� |�}d|i}| j|d|dd� dS )z Update cluster admin password.�cluster_admins/{0}r1 re rL r� Tr� )r r0 r� rP rR r r r � update_cluster_admin_passwordo s ��z,InfluxDBClient.update_cluster_admin_passwordc C s d� |�}| j|ddd� dS )zDelete cluster admin.r� r� rL r� Tr� �r r0 rP r r r �delete_cluster_admin� s �z#InfluxDBClient.delete_cluster_adminc C s | � |d�S )zSet user as database admin.T��alter_database_admin�r r0 r r r �set_database_admin� s z!InfluxDBClient.set_database_adminc C s | � |d�S )z Unset user as database admin.Fr� r� r r r �unset_database_admin� s z#InfluxDBClient.unset_database_adminc C s, d� | j|�}d|i}| j|d|dd� dS )zAlter the database admin.�db/{0}/users/{1}Zadminre rL r� Tr� )r r0 Zis_adminrP rR r r r r� � s �z#InfluxDBClient.alter_database_adminc C s t � �dS )z�Get list of database admins. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� r� r r r �get_list_database_admins� s z'InfluxDBClient.get_list_database_adminsc C s t � �dS )z�Add cluster admin. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� )r r� r� r r r �add_database_admin� s z!InfluxDBClient.add_database_adminc C s t � �dS )z�Update database admin password. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� �r r0 r� r r r � update_database_admin_password� s z-InfluxDBClient.update_database_admin_passwordc C s t � �dS )z�Delete database admin. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� r� r r r �delete_database_admin� s z$InfluxDBClient.delete_database_adminc C s$ d� | j�}| j|ddd�}|�� S )zGet list of database users.� db/{0}/usersrK rL r� )r r" rZ rW r� r r r �get_database_users� s �z!InfluxDBClient.get_database_usersc C sd d� | j�}||d�}|rNz|\|d< |d< W n ttfyL td��Y n0 | j|d|dd� d S ) zXAdd database user. :param permissions: A ``(readFrom, writeTo)`` tuple r� r� �readFrom�writeTo�/'permissions' must be (readFrom, writeTo) tuplere rL r� T)r r" r= � TypeErrorrZ )r r� r� � permissionsrP rR r r r �add_database_user� s$ �� �z InfluxDBClient.add_database_userc C s | � ||�S )zUpdate password.)�alter_database_userr� r r r � update_database_user_password s z,InfluxDBClient.update_database_user_passwordc C s� d� | j|�}|s$|s$td� |���i }|r4||d< |rlz|\|d< |d< W n ttfyj td��Y n0 | j|d|dd � || jkr�|| _d S ) z�Alter a database user and/or their permissions. :param permissions: A ``(readFrom, writeTo)`` tuple :raise TypeError: if permissions cannot be read. :raise ValueError: if neither password nor permissions provided. r� z Nothing to alter for user {0}.r1 r� r� r� re rL r� T)r r" r= r� rZ r r! )r r0 r1 r� rP rR r r r r� s, � � z"InfluxDBClient.alter_database_userc C s" d� | j|�}| j|ddd� dS )zDelete database user.r� r� rL r� Tr� r� r r r �delete_database_user/ s �z#InfluxDBClient.delete_database_userc C s t � �dS )z�Update read/write permission. 2013-11-08: This endpoint has not been implemented yet in ver0.0.8, but it is documented in http://influxdb.org/docs/api/http.html. See also: src/api/http/api.go:l57 Nr� )r r0 r� r r r �update_permission= s z InfluxDBClient.update_permissionc C s. t �|�}|�d�}| j�|| j| jf� dS )z!Send a UDP packet along the wire.r� N)rW rX �encoder+ �sendtor r' )r �packetrR �byter r r r G s zInfluxDBClient.send_packet) r r r r NFFNr Fr )rK NNrL )rh )rh )rh F)rh F)N)NN).r r r r r � staticmethodrC rE rI rJ rZ rd rw rx rs 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� r� r� r� r� r� r r r r r r sp " � * C � . 6 , $ % r )r rF rW r( r[ Zrequests.exceptionsZ six.movesr Zsix.moves.urllib.parser r9 r �SessionrY r~ r �objectr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка