| Server IP : 93.86.61.54 / Your IP : 216.73.216.156 Web Server : Apache/2.4.62 (Ubuntu) System : Linux rasin.ddns.net 6.8.0-124-generic #124~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Tue May 26 21:05:19 UTC x86_64 User : www-data ( 33) PHP Version : 8.4.22 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/influxdb/__pycache__/ |
Upload File : |
o
$��^i � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
dd l m Z dd
l
mZmZmZmZ e
�e�d��Zd d � Zd#dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Z d$d d �Z d%d d �Z d#d!d"�Z d
S )&z!Define the line_protocol handler.� )�absolute_import)�division)�print_function)�unicode_literals)�datetime)�Integral)�UTC)�parse)� binary_type� text_type�
integer_types�PY2c C s6 | t }|jd d }|jd }|jd }|| | S )Ni�Q � ʚ;�� )�EPOCH�days�seconds� microseconds)� timestamp�delta�
nanos_in_days�nanos_in_seconds�nanos_in_micros� r �8/usr/lib/python3/dist-packages/influxdb/line_protocol.py� _to_nanos s
r Nc C s� t | t�r| S t t| �t�rt| �} t | t�rY| js t�| �} t | �}|d u s+|dkr-|S |dkr5|d S |dkr=|d S |dkrE|d S |dkrO|d d S |d
krY|d d S t
| ��) N�n�ur �msi@B �sr �m�< �hi ) �
isinstancer � _get_unicoder r r �tzinfor �localizer �
ValueError)r � precision�nsr r r �_convert_timestamp s*
r* c C s8 t | dd�} | �dd��dd��dd��d d
��d d �S )
NT)�force�\�\\� z\ �,z\,�=z\=�
�\n)r$ �replace)�tagr r r � _escape_tag< s" ������r5 c C s t | �}|�d�r
|d7 }|S )Nr, r. )r5 �endswith)�value�retr r r �_escape_tag_valueK s
r9 c C s" d� | �dd��dd��dd��S )zIndent the quotes.z"{}"r, r- �"z\"r1 r2 ��formatr3 �r7 r r r � quote_identR s
�r> c C s d� | �dd��dd��S )zQuote provided literal.z'{}'r, r- �'z\'r; r= r r r �
quote_literalZ s �r@ c C s( zt | � W dS ttfy Y dS w )NFT)�float� TypeErrorr' r= r r r � _is_floata s
��rC c C st | d u rdS t | �} t| t�rt| �S t| t�r#t| t�s#t| �d S t| t�r,t| �S t| �r6tt | ��S t| �S )N� �i)
r$ r# r r> r �bool�strrC �reprrA r= r r r �
_escape_valuej s
rI Fc C s< t | t�r
| �d�S | du rdS |r trt| �S t| �S | S )z<Try to return a text aka unicode object from the given data.zutf-8NrD )r# r
�decoder
�unicoderG )�datar+ r r r r$ ~ s
r$ c
C s |pi }|pi }t t| ��}g }t|�� �D ] }t |�}t || �} |dkr4| dkr4|�dj|| d�� q|r@|dd�|� 7 }g }
t|�� �D ] } t | �}t|| �} |dkrf| dkrf|
�dj|| d�� qH|
rr|dd�|
� 7 }|dur�ttt t
||����} |d| 7 }|S )z7Extract the actual point from a given measurement line.rD z
{key}={value})�keyr7 r/ r. N) r5 r$ �sorted�keys�appendr< �joinrI rG �intr* )
� measurement�tags�fields�timer( �line�tag_list�tag_keyrM r7 �
field_list� field_keyr r r r � make_line� s@ �� ��� r\ c C s� g }| � d�}| d D ]5}|r t|�}|�|� d�pi � n|� d�p$i }t|� d| � d��||� d�||� d�d�}|�|� q d�|�d S )z�Extract points from given dict.
Extracts the points from the given dict and returns a Unicode string
matching the line protocol introduced in InfluxDB 0.9.0.
rT �pointsrS rU rV )rT rU r( rV r1 )�get�dict�updater\ rP rQ )rL r( �lines� static_tags�pointrT rW r r r �
make_lines� s
� rd )N)F)NNNN) �__doc__�
__future__r r r r r �numbersr �pytzr �dateutil.parserr �sixr
r r r
r& �utcfromtimestampr r r* r5 r9 r> r@ rC rI r$ r\ rd r r r r �<module> s,
!
,