Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/__pycache__/resultset.cpython-39.pyc
Ðазад
a p�hd � @ sb d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlmZ e � Z G dd � d e �Z dS ) z Module to prepare the resultset.� )�absolute_import)�division)�print_function)�unicode_literalsN)�InfluxDBClientErrorc @ s� e Zd ZdZd!dd�Zedd� �Zejdd� �Zedd � �Zd d � Z d"d d�Z dd� Z dd� Z e dd� �Zdd� Zdd� Zdd� Zdd � Zd d � Ze d d � �Zd S )#� ResultSetz0A wrapper around a single InfluxDB query result.Tc C s6 || _ | j �dd�| _| jdur2|du r2t| j��dS )zInitialize the ResultSet.�errorNT)�_raw�get�_errorr r )�self�series� raise_errors� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/resultset.py�__init__ s zResultSet.__init__c C s | j S )zRaw JSON from InfluxDB.�r �r r r r �raw s z ResultSet.rawc C s || _ d S )Nr )r �valuer r r r s c C s | j S )zError returned by InfluxDB.)r r r r r r $ s zResultSet.errorc C s~ t �dt� t|t�rVt|�dkr*td��|d }|d }t|t�sr|durrtd��n t|t�rjd}|}n|}d}| �||�S )a� Retrieve the series name or specific set based on key. :param key: Either a series name, or a tags_dict, or a 2-tuple(series_name, tags_dict). If the series name is None (or not given) then any serie matching the eventual given tags will be given its points one after the other. To get the points of every series in this resultset then you have to provide None as key. :return: A generator yielding `Point`s matching the given key. NB: The order in which the points are yielded is actually undefined but it might change.. zQResultSet's ``__getitem__`` method will be deprecated. Use``get_points`` instead.� zonly 2-tuples allowedr � Nztags should be a dict) �warnings�warn�DeprecationWarning� isinstance�tuple�len� TypeError�dict� get_points)r �key�name�tagsr r r � __getitem__) s" � zResultSet.__getitem__Nc c s� t |ttd�� �td�f�s$td��| �� D ]�}|�d|�dd��}|du rl|du r�| �|�D ] }|V q^q,|d|fv r,|�di �}| �|�D ]*}|du s�| �||�s�| �||�r�|V q�q,dS )a Return a generator for all the points that match the given filters. :param measurement: The measurement name :type measurement: str :param tags: Tags to look for :type tags: dict :return: Points generator � Nz"measurement must be an str or None� measurementr" �resultsr# ) r �bytes�type�decoder � _get_seriesr �_get_points_for_series� _tag_matches)r r& r# r Z series_name�itemZ series_tagsr r r r P s* � � � �zResultSet.get_pointsc C s> g }| � � D ]"}|�d|d t|d �f � q dd�|� S )z#Representation of ResultSet object.z'%s': %sr r zResultSet({%s})z, )�items�append�list�join)r r/ r. r r r �__repr__u s zResultSet.__repr__c c s" | � � D ]}t| �|��V qdS )z*Yield one dict instance per series result.N)�keysr1 r$ )r r! r r r �__iter__~ s zResultSet.__iter__c C s0 |� � D ]"\}}| �|t�}||kr dS qdS )z0Check if all key/values in filter match in tags.FT)r/ r � _sentinel)r# �filterZtag_nameZ tag_valueZseries_tag_valuer r r r- � s zResultSet._tag_matchesc C s | j �dg �S )zReturn all series.r )r r r r r r r+ � s zResultSet._get_seriesc C s t | �� �S )z,Return the len of the keys in the ResultSet.)r r4 r r r r �__len__� s zResultSet.__len__c C s< g }| � � D ]*}|�|�d|�dd��|�dd�f� q |S )zvReturn the list of keys in the ResultSet. :return: List of keys. Keys are tuples (series_name, tags) r& r" r' r# N)r+ r0 r )r r4 r r r r r4 � s � ��zResultSet.keysc C sJ g }| � � D ]8}|�d|�dd��|�dd�f}|�|| �|�f� q |S )zgReturn the set of items from the ResultSet. :return: List of tuples, (key, generator) r& r" r' r# N)r+ r r0 r, )r r/ r Z series_keyr r r r/ � s � � �zResultSet.itemsc c s( |� dg �D ]}| �|d |�V q dS )z�Return generator of dict from columns and values of a series. :param series: One series :return: Generator of dicts �values�columnsN)r �point_from_cols_vals)r r �pointr r r r, � s �z ResultSet._get_points_for_seriesc C s& i }t | �D ]\}}|| ||< q |S )z�Create a dict from columns and values lists. :param cols: List of columns :param vals: List of values :return: Dict where keys are columns. )� enumerate)�cols�valsr< Z col_indexZcol_namer r r r; � s z ResultSet.point_from_cols_vals)T)NN)�__name__� __module__� __qualname__�__doc__r �propertyr �setterr r$ r r3 r5 � staticmethodr- r+ r8 r4 r/ r, r; r r r r r s* ' % r ) rC � __future__r r r r r Zinfluxdb.exceptionsr �objectr6 r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка