Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/__pycache__/dataframe_client.cpython-39.pyc
Ðазад
a p�h{ � @ sd d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddlm Z G d d � d e �Z dS ) z#DataFrame client for InfluxDB v0.8.� )�absolute_import)�division)�print_function)�unicode_literalsN� )�InfluxDBClientc sf e Zd ZdZd� fdd� Zdd� Zddd �Zdd d �Zed d� �Z ddd�Z dd� Z ddd�Z � Z S )�DataFrameClienta Primary defintion of the DataFrameClient for v0.8. The ``DataFrameClient`` object holds information necessary to connect to InfluxDB. Requests can be made to InfluxDB directly through the client. The client reads and writes from pandas DataFrames. Tc sr t t| �j|i |�� z ddlaW n8 tyZ } z tdjt|�d���W Y d}~n d}~0 0 t�d�| _ || _ dS )z.Initialize an instance of the DataFrameClient.r Nz9DataFrameClient requires Pandas, "{ex}" problem importing��exz 1970-01-01 00:00:00.000+00:00) �superr �__init__Zpandas�pd� ImportError�format�str� Timestamp�EPOCH� ignore_nan)�selfr �args�kwargsr �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/influxdb08/dataframe_client.pyr s � zDataFrameClient.__init__c s� |� d�}|� dd��|r�|�d� |�� D ]~\}}tt�t|�t|� ��}t|�D ]R}|| } |d | } � j ||j | | � � � �d�g} t j � | g|�R i |�� qVq,dS � �fdd�|�� D �} t j � | g|�R i |��S ) a� Write to multiple time series names. :param data: A dictionary mapping series names to pandas DataFrames :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 � batch_size�time_precision�sr ��name� dataframer Tc s g | ]\}}� j ||�d ��qS )r )�_convert_dataframe_to_json)�.0�keyr �r r r r � <listcomp>C s ��z0DataFrameClient.write_points.<locals>.<listcomp>)�get�pop�items�int�math�ceil�len�float�ranger! Ziloc�copyr � write_points) r �datar r r r# Z data_frameZnumber_batches�batch� start_indexZ end_indexZoutdatar r$ r r0 % s2 � ��� �z DataFrameClient.write_pointsr c C s t �dt� | j|dd�S )zAWrite to multiple time series names. DEPRECATED z�write_points_with_precision is deprecated, and will be removed in future versions. Please use ``DataFrameClient.write_points(time_precision='..')`` instead.r )r )�warnings�warn� FutureWarningr0 )r r1 r r r r �write_points_with_precisionI s �z+DataFrameClient.write_points_with_precisionFc C sh t j| |||d�}t|�dkr"|S t|�dkr>| �|d |�S i }|D ]}| �||�||d < qF|S dS )a� Query data into DataFrames. Returns a DataFrame for a single time series and a map for multiple time series with the time series as value and its name as key. :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. )�queryr �chunkedr r r N)r r8 r, � _to_dataframe)r r8 r r9 �result�retZ time_seriesr r r r8 U s � �zDataFrameClient.queryc C s� t j| d | d d�}d|�� v r6|jddgdd� n|jdgdd� |}|dkrXd }n |d krdd }t jt|d �|dd �|_|d= |S ) N�points�columns)r1 r> Zsequence_number�timeT)Zinplace�m�ms�u�us)�unit�utc)r � DataFrame�keysZ sort_values� to_datetime�list�index)Z json_resultr r Zpandas_time_unitr r r r: n s" � �z DataFrameClient._to_dataframec s� t |tj�s td�t|����t |jtj�sBt |jtj�sBtd��t |jtj�r^|j� � |_nt� |j�|_|jj d u r�|j� d�|_� �fdd�|jD �|d< |dd� |j D �� fdd�|jD �d �}|S ) Nz%Must be DataFrame, but type was: {0}.zPMust be DataFrame with DatetimeIndex or PeriodIndex.�UTCc s g | ]}� � |���qS r )�_datetime_to_epoch)r" �dtr$ r r r% � s �z>DataFrameClient._convert_dataframe_to_json.<locals>.<listcomp>r? c S s g | ] }t |��qS r )r )r" �columnr r r r% � � c s g | ]}� � |��qS r )�_convert_array)r" �x)r r r r% � rO )r r> r= )� isinstancer rF � TypeErrorr �typerJ Z PeriodIndexZ DatetimeIndexZ to_timestamprH �tzinfoZ tz_localizer> �values)r r r r r1 r r$ r r! � s* � � � �z*DataFrameClient._convert_dataframe_to_jsonc s� z dd l aW n8 tyD } z tdjt|�d���W Y d }~n d }~0 0 | jr�tttjf� t � fdd�|D ��ovt� |�}t t� |d |��S t |�S )Nr z8DataFrameClient requires Numpy, "{ex}" problem importingr c 3 s | ]}t |� �V qd S )N)rR )r" �el�Z number_typesr r � <genexpr>� rO z1DataFrameClient._convert_array.<locals>.<genexpr>) �numpy�npr r r r r) r- �number�all�isnanrI �where)r �arrayr � conditionr rX r rP � s � �z DataFrameClient._convert_arrayc C sF || j �� }|dkr|S |dks*|dkr2|d S |dkrB|d S d S )Nr r@ rA i� rB i@B )r � total_seconds)r �datetimer �secondsr r r rL � s z"DataFrameClient._datetime_to_epoch)T)r )r F)r )r )�__name__� __module__� __qualname__�__doc__r r0 r7 r8 � staticmethodr: r! rP rL � __classcell__r r r r r s $ r ) rh � __future__r r r r r* r4 �clientr r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка