Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/tests/__pycache__/helper_test.cpython-39.pyc
Ðазад
a p�hA � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZmZ ddlZddl Z ddl Z ddl m Z m Z dd lmZ G d d � d ej�ZdS ) z(Set of series helper functions for test.� )�absolute_import)�division)�print_function)�unicode_literals)�datetime� timedeltaN)� SeriesHelper�InfluxDBClient)�ConnectionErrorc s� e Zd ZdZe� fdd��Z� fdd�Z� fdd�Zdd � Ze � d �d d � �Z e � d �d d� �Z e � d �dd� �Z dd� Ze � d �dd� �Zdd� Ze�d�dd� �Zdd� Zd d � Zd d � Z� ZS ) �TestSeriesHelperz$Define the SeriesHelper test object.c s: t t| ��� tddddd�t_G dd� dt�}|t_dS ) z#Set up the TestSeriesHelper object.�hosti� �username�passwordZdatabasec @ s e Zd ZdZG dd� d�ZdS )z3TestSeriesHelper.setUpClass.<locals>.MySeriesHelperz Define a SeriesHelper object.c @ s0 e Zd ZdZejZdZdgZddgZdZ dZ dS ) z8TestSeriesHelper.setUpClass.<locals>.MySeriesHelper.Metaz,Define metadata for the SeriesHelper object.�events.stats.{server_name}� some_stat� server_name� other_tag� TN) �__name__� __module__� __qualname__�__doc__r �client� series_name�fields�tags� bulk_size� autocommit� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/tests/helper_test.py�Meta& s r N�r r r r r r r r r �MySeriesHelper# s r" N)�superr � setUpClassr r r r" )�clsr" �� __class__r r r$ s � zTestSeriesHelper.setUpClassc s& t t| ��� | �tj�� g d� dS )z/Check that MySeriesHelper has empty datapoints.z6Resetting helper in teardown did not empty datapoints.N)r# r �setUp� assertEqualr" � _json_body_��selfr& r r r( 2 s �zTestSeriesHelper.setUpc s0 t t| ��� tj�� | �tj�� g d� dS )z(Deconstruct the TestSeriesHelper object.z*Resetting helper did not empty datapoints.N)r# r �tearDownr" Z_reset_r) r* r+ r& r r r- : s �zTestSeriesHelper.tearDownc C s� G dd� dt �}t�� }|dddd� ||j_|dddd� |dddd� |dd dd� | �|j� |dd dd� | �|j� d S ) z6Test write_points called after valid number of events.c @ s e Zd ZdZG dd� d�ZdS )z9TestSeriesHelper.test_auto_commit.<locals>.AutoCommitTestz2Define a SeriesHelper instance to test autocommit.c @ s0 e Zd ZdZdZdgZddgZdZe� Z dZ dS ) z>TestSeriesHelper.test_auto_commit.<locals>.AutoCommitTest.Metaz#Define metadata for AutoCommitTest.r r r r r TN) r r r r r r r r r r r r r r r r H s r Nr! r r r r �AutoCommitTestE s r. � us.east-1� �gg�r r r � � � is N)r �mock� MagicMock�_client� write_pointsZ assertFalseZcalled� assertTrue)r, r. �fake_write_pointsr r r �test_auto_commitC s z!TestSeriesHelper.test_auto_commitz/influxdb.helper.SeriesHelper._current_timestampc s� t �� |_}tjdddd� tjdddd� tjdddd� tjdddd� dddd �d di|d �dddd �d di|d �dddd �d di|d �dddd �d di|d �g� tj�� �| �t� fd d ��D ��o�t�fdd �� D ��d���� dS )z8Test JSON conversion when there is only one series name.r/ �ellor0 �r r r r3 r4 r5 �events.stats.us.east-1�r r r )� measurementr r �timec s g | ] }|� v �qS r r ��.0�el�� expectationr r � <listcomp>� � z9TestSeriesHelper.testSingleSeriesName.<locals>.<listcomp>c s g | ] }|� v �qS r r rC ��rcvdr r rH � rI zTInvalid JSON body of time series returned from _json_body_ for one series name: {0}.N� r �today� return_valuer r" r* r: �all�format�r, �current_timestamp� current_dater �rG rK r �testSingleSeriesName\ sj ������� ��� ��� ����/ ��z%TestSeriesHelper.testSingleSeriesNamec s� t �� |_}tjdddd� tjdddd� tjdddd� tjd d dd� d did ddd �|d�d d iddd d �|d�d didddd �|d�d didddd �|d�g� tj�� �| �t� fdd��D ��o�t�fdd�� D ��d���� dS )z:Test JSON conversion when there are multiple series names.r/ r0 r= r2 z fr.paris-10r3 zlu.luxr4 z uk.londonr5 r zevents.stats.lu.luxr@ )r rA r rB zevents.stats.uk.londonzevents.stats.fr.paris-10r? c s g | ] }|� v �qS r r rC rF r r rH � rI z;TestSeriesHelper.testSeveralSeriesNames.<locals>.<listcomp>c s g | ] }|� v �qS r r rC rJ r r rH � rI zYInvalid JSON body of time series returned from _json_body_ for several series names: {0}.NrL rQ r rT r �testSeveralSeriesNames� sj ������� ��� ��� ����/ ��z'TestSeriesHelper.testSeveralSeriesNamesc C s� t �� }|tdd� }||_tjddd|d� tjdddd� tj�� \}}| �d |v o^d |v � | �|d |� | �|d |� d S ) z<Test that time is optional on a series without a time field.� ��daysr/ r= r0 �r r r rB r3 r> rB N) r rM r rN r r" r* r: r) )r, rR rS � yesterday�point1�point2r r r �testSeriesWithoutTimeField� s ��z+TestSeriesHelper.testSeriesWithoutTimeFieldc C s. G dd� dt �}| jt|fi ddd��� dS )z>Test that creating a data point without a tag throws an error.c @ s e Zd ZG dd� d�ZdS )zJTestSeriesHelper.testSeriesWithoutAllTags.<locals>.MyTimeFieldSeriesHelperc @ s. e Zd ZejZdZddgZddgZdZdZ dS ) zOTestSeriesHelper.testSeriesWithoutAllTags.<locals>.MyTimeFieldSeriesHelper.Metar r rB r r r TN� r r r r r r r r r r r r r r r � s r N�r r r r r r r r �MyTimeFieldSeriesHelper� s ra r/ r3 )r r N)r � assertRaises� NameError)r, ra r r r �testSeriesWithoutAllTags� s ��z)TestSeriesHelper.testSeriesWithoutAllTagsc C s� t �� }|tdd� }||_G dd� dt�}|ddd|d� |ddd d � |�� \}}| �d |v ohd |v � | �|d |� | �|d |� d S ) z9Test that time is optional on a series with a time field.rW rX c @ s e Zd ZG dd� d�ZdS )zITestSeriesHelper.testSeriesWithTimeField.<locals>.MyTimeFieldSeriesHelperc @ s. e Zd ZejZdZddgZddgZdZdZ dS ) zNTestSeriesHelper.testSeriesWithTimeField.<locals>.MyTimeFieldSeriesHelper.Metar r rB r r r TNr_ r r r r r s r Nr` r r r r ra s ra r/ r= r0 rZ r3 r> rB N)r rM r rN r r* r: r) )r, rR rS r[ ra r\ r] r r r �testSeriesWithTimeField s �� z(TestSeriesHelper.testSeriesWithTimeFieldc C s� G dd� dt �}G dd� dt �}G dd� dt �}G dd� dt �}G d d � d t �}|||||fD ] }| jt|fi d d d ��� q^dS )z Test errors in invalid helpers.c @ s e Zd ZdZdS )z8TestSeriesHelper.testInvalidHelpers.<locals>.MissingMetaz1Define instance of SeriesHelper for missing meta.N)r r r r r r r r � MissingMeta" s rf c @ s e Zd ZdZG dd� d�ZdS )z:TestSeriesHelper.testInvalidHelpers.<locals>.MissingClientz,Define SeriesHelper for missing client data.c @ s e Zd ZdZdZddgZdZdS )z?TestSeriesHelper.testInvalidHelpers.<locals>.MissingClient.Metaz!Define metadat for MissingClient.r rB r TN)r r r r r r r r r r r r * s r Nr! r r r r � MissingClient' s rg c @ s e Zd ZdZG dd� d�ZdS )z>TestSeriesHelper.testInvalidHelpers.<locals>.MissingSeriesNamez3Define instance of SeriesHelper for missing series.c @ s e Zd ZdZddgZdS )zCTestSeriesHelper.testInvalidHelpers.<locals>.MissingSeriesName.Metaz&Define metadata for MissingSeriesName.rB r N)r r r r r r r r r r 4 s r Nr! r r r r �MissingSeriesName1 s rh c @ s e Zd ZdZG dd� d�ZdS )z:TestSeriesHelper.testInvalidHelpers.<locals>.MissingFieldsz3Define instance of SeriesHelper for missing fields.c @ s e Zd ZdZdZdS )z?TestSeriesHelper.testInvalidHelpers.<locals>.MissingFields.Metaz"Define metadata for MissingFields.r N)r r r r r r r r r r < s r Nr! r r r r � MissingFields9 s ri c @ s e Zd ZdZG dd� d�ZdS )zATestSeriesHelper.testInvalidHelpers.<locals>.InvalidTimePrecisionz;Define instance of SeriesHelper for invalid time precision.c @ s$ e Zd ZdZdZdZddgZdZdS )zFTestSeriesHelper.testInvalidHelpers.<locals>.InvalidTimePrecision.Metaz)Define metadata for InvalidTimePrecision.r �ksrB r TN)r r r r r Ztime_precisionr r r r r r r D s r Nr! r r r r �InvalidTimePrecisionA s rk r0 r/ �rB r N)r rb �AttributeError)r, rf rg rh ri rk r% r r r �testInvalidHelpers s ����z#TestSeriesHelper.testInvalidHelpersz Fails on py32c C s� G dd� dt �}tjdd��n}t�d� z|ddd� W n tyJ Y n0 | �t|�d d �|�� | �d t |d j �d � W d � n1 s�0 Y dS )z&Test warning for an invalid bulk size.c @ s e Zd ZG dd� d�ZdS )z?TestSeriesHelper.testWarnBulkSizeZero.<locals>.WarnBulkSizeZeroc @ s* e Zd ZejZdZddgZg ZdZdZ dS )zDTestSeriesHelper.testWarnBulkSizeZero.<locals>.WarnBulkSizeZero.Metar rB r r TNr_ r r r r r W s r Nr` r r r r �WarnBulkSizeZeroU s ro T��record�alwaysr0 r/ rl rW �+{0} call should have generated one warning.z forced to 1���z.Warning message did not contain "forced to 1".N) r �warnings�catch_warnings� simplefilterr r) �lenrP �assertIn�str�message)r, ro �wr r r �testWarnBulkSizeZeroR s ���z%TestSeriesHelper.testWarnBulkSizeZeroc C s� G dd� dt �}tjdd��V}t�d� |ddd� | �t|�d d �|�� | �d t|d j �d � W d � n1 sx0 Y dS )z6Test warning for a set bulk size but autocommit False.c @ s e Zd ZdZG dd� d�ZdS )zGTestSeriesHelper.testWarnBulkSizeNoEffect.<locals>.WarnBulkSizeNoEffectz-Define SeriesHelper for warning on bulk size.c @ s( e Zd ZdZdZddgZdZg ZdZdS )zLTestSeriesHelper.testWarnBulkSizeNoEffect.<locals>.WarnBulkSizeNoEffect.Metaz(Define metadat for WarnBulkSizeNoEffect.r rB r r FN) r r r r r r r r r r r r r r r s r Nr! r r r r �WarnBulkSizeNoEffecto s r~ Trp rr r0 r/ rl rW rs z has no affectrt z1Warning message did not contain "has not affect".N) r ru rv rw r) rx rP ry rz r{ )r, r~ r| r r r �testWarnBulkSizeNoEffectm s ���z)TestSeriesHelper.testWarnBulkSizeNoEffectc st d� G � fdd�dt �}t�� }|dddd� ||j_|ddd d� |j}|\}}| �d |v � | �|d � � d S ) z@Test that the data is saved with the specified retention policy.� my_policyc s e Zd ZG � fdd�d�ZdS )zSTestSeriesHelper.testSeriesWithRetentionPolicy.<locals>.RetentionPolicySeriesHelperc s2 e Zd Ze� ZdZddgZddgZdZdZ � Z dS ) zXTestSeriesHelper.testSeriesWithRetentionPolicy.<locals>.RetentionPolicySeriesHelper.Metar r rB r r � TN) r r r r r r r r r r �retention_policyr �r� r r r � s r Nr` r r� r r �RetentionPolicySeriesHelper� s r� r/ r0 r1 r2 r3 �aar� N�r r6 r7 r8 r9 Z call_argsr: r) )r, r� r; �kall�args�kwargsr r� r � testSeriesWithRetentionPolicy� s ��z.TestSeriesHelper.testSeriesWithRetentionPolicyc C sl G dd� dt �}t�� }|dddd� ||j_|dddd� |j}|\}}| �d |v � | �|d d � d S ) z9Test that the data is saved without any retention policy.c @ s e Zd ZG dd� d�ZdS )zXTestSeriesHelper.testSeriesWithoutRetentionPolicy.<locals>.NoRetentionPolicySeriesHelperc @ s. e Zd Ze� ZdZddgZddgZdZdZ dS ) z]TestSeriesHelper.testSeriesWithoutRetentionPolicy.<locals>.NoRetentionPolicySeriesHelper.Metar r rB r r r� TN) r r r r r r r r r r r r r r r � s r Nr` r r r r � NoRetentionPolicySeriesHelper� s r� r/ r0 r1 r2 r3 r� r� Nr� )r, r� r; r� r� r� r r r � testSeriesWithoutRetentionPolicy� s ��z1TestSeriesHelper.testSeriesWithoutRetentionPolicy)r r r r � classmethodr$ r( r- r< r6 �patchrU rV r^ rd re rn �unittest�skipr} r r� r� � __classcell__r r r& r r s* @ A 2 r )r � __future__r r r r r r r� ru r6 Zinfluxdbr r Zrequests.exceptionsr ZTestCaser r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка