Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/__pycache__/helper.cpython-39.pyc
Ðазад
a p�h� � @ sl d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZmZ ddl m Z ddl Z G d d � d e �Z dS ) z#Helper class for InfluxDB for v0.8.� )�absolute_import)�division)�print_function)�unicode_literals)� namedtuple� defaultdict)�warnNc sR e Zd ZdZdZ� fdd�Zdd� Zeddd ��Zed d � �Z ed d � �Z � Z S )� SeriesHelpera� Define the SeriesHelper object for InfluxDB v0.8. Subclassing this helper eases writing data points in bulk. All data points are immutable, ensuring they do not get overwritten. Each subclass can write to its own database. The time series names can also be based on one or more defined fields. Annotated example:: class MySeriesHelper(SeriesHelper): class Meta: # Meta class stores time series helper configuration. series_name = 'events.stats.{server_name}' # Series name must be a string, curly brackets for dynamic use. fields = ['time', 'server_name'] # Defines all the fields in this time series. ### Following attributes are optional. ### client = TestSeriesHelper.client # Client should be an instance of InfluxDBClient. :warning: Only used if autocommit is True. bulk_size = 5 # Defines the number of data points to write simultaneously. # Only applicable if autocommit is True. autocommit = True # If True and no bulk_size, then will set bulk_size to 1. Fc sV | j �sFd| _ zt| d�}W n" ty> td�| j���Y n0 dD ]D}zt| d| t||�� W qD ty� td�|| j���Y qD0 qDt|dd�| _t|d d �| _| jr�| js�td �| j���z6t|d �| _| jd k r�| jr�t d�| j�� d | _W n t�y d| _Y n0 | j�s,t d�| j�� t t �| _ t | j| j�| _tt| ��| �S )z�Initialize class attributes for subsequent constructor calls. :note: *args and **kwargs are not explicitly used in this function, but needed for Python 2 compatibility. TZMetazMissing Meta class in {0}.)� series_name�fields�_z Missing {0} in {1} Meta class.Z autocommitF�clientNz8In {0}, autocommit is set to True, but no client is set.Z bulk_size� z<Definition of bulk_size in {0} forced to 1, was less than 1.���zIDefinition of bulk_size in {0} has no affect because autocommit is false.)�__initialized__�getattr�AttributeError�format�__name__�setattr� _autocommit�_client� _bulk_sizer r �list� _datapointsr �_fields�_type�superr �__new__)�cls�args�kwargs�_meta�attr�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/helper.pyr . s` �� �� �� �� �� zSeriesHelper.__new__c K s� | j }t|j�t|�� �kr2td�|j|�� ���|j|jjf i |�� �|j f i |��� |j r�t dd� |j� � D ��|j kr�|�� dS )z�Create a new data point. All fields must be present. :note: Data points written when `bulk_size` is reached per Helper. :warning: Data points are *immutable* (`namedtuples`). zExpected {0}, got {1}.c s s | ]}t |�V qd S )N)�len)�.0Zseriesr& r& r' � <genexpr>u � z(SeriesHelper.__init__.<locals>.<genexpr>N)r% �sortedr �keys� NameErrorr r Z _series_name�appendr r �sum�valuesr �commit)�self�kwr r& r& r' �__init__b s ��*��zSeriesHelper.__init__Nc C s$ |s | j }|�| �� �}| �� |S )a Commit everything from datapoints via the client. :param client: InfluxDBClient instance for writing points to InfluxDB. :attention: any provided client will supersede the class client. :return: result of client.write_points. )r Z write_points� _json_body_�_reset_)r r Zrtnr& r& r' r2 y s zSeriesHelper.commitc sN g }� j s� �� t�� j�D ]*\}}|�|� j� fdd�|D �d�� q |S )z[Return JSON body of the datapoints. :return: JSON body of the datapoints. c s g | ]� � fd d��j D ��qS )c s g | ]}t � |��qS r& )r )r) �k��pointr& r' � <listcomp>� r+ z7SeriesHelper._json_body_.<locals>.<listcomp>.<listcomp>)r )r) �r r9 r' r; � s �z,SeriesHelper._json_body_.<locals>.<listcomp>)�name�columnsZpoints)r r7 �six� iteritemsr r/ r )r �jsonr �datar& r< r' r6 � s �� zSeriesHelper._json_body_c C s t t�| _dS )zReset data storage.N)r r r r< r& r& r' r7 � s zSeriesHelper._reset_)N) r � __module__� __qualname__�__doc__r r r5 � classmethodr2 r6 r7 � __classcell__r& r& r$ r' r s 4 r )rE � __future__r r r r � collectionsr r �warningsr r? �objectr r& r& r& r' �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка