Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/tests/influxdb08/__pycache__/client_test.cpython-39.pyc
Ðазад
a p�h~ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Z ddl m Z ddlm Z ddlmZ ddlmZ ejdk r�ddlZdd � Znd d � Zdd d�Zddd�ZG dd� dej�ZdS )zClient unit tests.� N)�raises)�patch)�InfluxDBClient)�session�3c C s t �| �d S )� Test codec.r )�codecs�unicode_escape_decode��x� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/tests/influxdb08/client_test.py�u s r c C s | S )r r r r r r r s �� � c C s t �� }| |_|�d�|_|S )N�utf8)�requests�Response� status_code�encode�_content)r �content�respr r r �_build_response_object" s r �GETc s, �� � �� ��fdd�}tjtd|d�}|S )Nc s| � }�|� dd�ksJ ��dkr\|� dd�}|dur\t|t�sBJ �|tj|dd�ksXJ �|}t|t�spt�|�}t�|d�S ) z)Define a request for the _mocked_session.�methodr �POST�dataNT��strict)r r )�get� isinstance�str�json�loads�dumpsr )�args�kwargs�cr �r r r r r �request, s z _mocked_session.<locals>.requestr* )� side_effect)�upperr �objectr )r r r r* �mockedr r) r �_mocked_session) s �r/ c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zee �d d � �Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zee�d d � �Zd d!� Zd"d#� Zee�d$d%� �Zd&d'� Zee�d(d)� �Zee�d*d+� �Z ee�d,d-� �Z ee�d.d/� �Z d0d1� Z d2d3� Z d4d5� Z!ee�d6d7� �Z"d8d9� Z#d:d;� Z$ee�d<d=� �Z%d>d?� Z&ee�d@dA� �Z'dBdC� Z(ee�dDdE� �Z)ee �dFdG� �Z*dHdI� Z+ee�dJdK� �Z,dLdM� Z-dNdO� Z.dPdQ� Z/dRdS� Z0dTdU� Z1dVdW� Z2dXdY� Z3dZd[� Z4d\d]� Z5ee�d^d_� �Z6ee�d`da� �Z7ee�dbdc� �Z8ee�ddde� �Z9dfdg� Z:dhdi� Z;djdk� Z<dldm� Z=dndo� Z>dpdq� Z?drds� Z@dtdu� ZAee�dvdw� �ZBeC�Ddx�dydz� �ZEeC�Ddx�d{d|� �ZFd}S )~�TestInfluxDBClientz#Define a TestInfluxDBClient object.c C s6 t �dt� g d�g d�gdg d�d�g| _d| _dS ) z#Set up a TestInfluxDBClient object.�error��1� g �?��2� g @�foo)� column_oneZ column_twoZ column_three��points�name�columnsz influxdb://uSr:pWd@host:1886/dbN)�warnings� simplefilter� FutureWarning� dummy_points� dsn_string��selfr r r �setUpQ s ��� zTestInfluxDBClient.setUpc C sD t ddddd�}| �|jd� t ddddddd�}| �|jd � d S ) z3Test database scheme for TestInfluxDBClient object.�host� �username�password�databasezhttp://host:8086T)�sslzhttps://host:8086N)r � assertEqual�_baseurl�rD �clir r r � test_schemec s �z TestInfluxDBClient.test_schemec C s� t �| j�}| �d|j� | �d|j� | �d|j� | �d|j� | �|j � t �d| j �}| � |j � t �d| j �}| �d|j� t jd| j fi dd i��}| �d|j� d S ) z3Test datasource name for TestInfluxDBClient object.zhttp://host:1886ZuSrZpWd�dbzudp+zhttps+zhttps://host:1886rK FN) r Zfrom_dsnrB rL rM � _username� _password� _databaseZ assertFalseZ_use_udp� assertTruerN r r r �test_dsnm s �zTestInfluxDBClient.test_dsnc C s, t ddddd�}|�d� | �|jd� dS )z3Test switch database for TestInfluxDBClient object.rF rG rH rI rJ �another_databaseN)r Zswitch_databaserL rT rN r r r �test_switch_database� s z'TestInfluxDBClient.test_switch_databasec C s, t ddddd�}|�d� | �|jd� dS )z>Test deprecated switch database for TestInfluxDBClient object.rF rG rH rI rJ rW N)r Z switch_dbrL rT rN r r r �test_switch_db_deprecated� s z,TestInfluxDBClient.test_switch_db_deprecatedc C s< t ddddd�}|�dd� | �|jd� | �|jd� dS ) z/Test switch user for TestInfluxDBClient object.rF rG rH rI rJ Zanother_usernameZanother_passwordN)r Z switch_userrL rR rS rN r r r �test_switch_user� s z#TestInfluxDBClient.test_switch_userc C s� t �� ��}|�t jd� tdd�}|�dddddd �d d d id �gd�� | �t�|j j �dddddd �d d d id �gd�� W d � n1 s�0 Y dS )z5Test write to database for TestInfluxDBClient object.zhttp://localhost:8086/writerQ �rJ ZmydbZmypolicyZcpu_load_shortZserver01zus-west)rF �regionz2009-11-10T23:00:00Z�valueg{�G�z�?)r< �tags� timestamp�values)rJ ZretentionPolicyr; N) � requests_mock�Mocker� register_urir r �writerL r# r$ � last_request�body�rD �mrO r r r � test_write� s> � ���� ����z TestInfluxDBClient.test_writec C sh t �� �L}|�t jd� tdd�}|�| j� | �t� |j j �| j� W d � n1 sZ0 Y dS )z0Test write points for TestInfluxDBClient object.�"http://localhost:8086/db/db/seriesrQ r[ N) ra rb rc r r � write_pointsrA �assertListEqualr# r$ re rf rg r r r �test_write_points� s � � �z$TestInfluxDBClient.test_write_pointsc C sr t �� �V}|�t jd� tdd�}|�tt�| j ��� | � t� |j j �| j � W d � n1 sd0 Y dS )z7Test write string points for TestInfluxDBClient object.rj rQ r[ N)ra rb rc r r rk r" r# r% rA rl r$ re rf rg r r r �test_write_points_string� s � � �z+TestInfluxDBClient.test_write_points_stringc C sh t �� �>}|�t jd� tddddd�}|j| jdd� W d � n1 sL0 Y | �d |j� d S ) z6Test write batch points for TestInfluxDBClient object.rj � localhostrG rH rI rQ r7 �r Z batch_sizeNr4 � ra rb rc r r rk rA rL � call_countrg r r r �test_write_points_batch� s ��.z*TestInfluxDBClient.test_write_points_batchc C sh t �� �>}|�t jd� tddddd�}|j| jdd� W d � n1 sL0 Y | �d |j� d S ) z<Test write batch points invalid size for TestInfluxDBClient.rj ro rG rH rI rQ ���rp Nr4 rq rg r r r �$test_write_points_batch_invalid_size� s ��.z7TestInfluxDBClient.test_write_points_batch_invalid_sizec C s g d�g d�g d�g d�g d�gdg d�d�g d�g d�g d�g d�g d�g d �g d �g d �gd g d�d�g}g d �g d �gd g d�d�g}t �� �<}|�t jd � tddddd�}|j|dd� W d � n1 s�0 Y | �|jd� | �||jd � � � dS )z(Test write points batch multiple series.r2 r5 )r � g @)�4� g @)�5� g @r8 )Zval1Zval2Zval3r: )�6� g @)�7� g @)�8� g @�barrj ro rG rH rI rQ rv rp Nrz rx ) ra rb rc r r rk rL rr Zrequest_historyr# )rD rA Zexpected_last_bodyrh rO r r r �'test_write_points_batch_multiple_series� s8 �� ��� � ��,z:TestInfluxDBClient.test_write_points_batch_multiple_seriesc C sz t � t jt j�}t�dd�}|�d|f� tdddddd|d �}|�| j� |� d �\}}| � | jt j |� � dd �� d S ) z4Test write points UDP for TestInfluxDBClient object.i� i@ z0.0.0.0ro rG �root�testT�Zuse_udpZudp_porti r N)�socket�AF_INET� SOCK_DGRAM�random�randint�bindr rk rA �recvfromrL r# r$ �decode)rD �s�portrO Z received_data�addrr r r �test_write_points_udp s � �z(TestInfluxDBClient.test_write_points_udpc C sV t dddddddd�}| �td�� |j| jd d � W d � n1 sH0 Y d S ) z Test write UDP w/bad precision.ro rG r� r� Ti\ r� z7InfluxDB only supports seconds precision for udp writes�ms�Ztime_precisionN�r �assertRaisesRegexp� Exceptionrk rA rN r r r � test_write_bad_precision_udp s ���z/TestInfluxDBClient.test_write_bad_precision_udpc C sH t dd��* tddddd�}|�g � W d � n1 s:0 Y dS ) z7Test failed write points for TestInfluxDBClient object.�post�� rF rG rH rI rQ N)r/ r rk rN r r r �test_write_points_fails# s z*TestInfluxDBClient.test_write_points_failsc C sT t dd| j��2 tddddd�}| �|�| j�� W d � n1 sF0 Y dS ) z!Test write points with precision.r� r rF rG rH rI rQ N)r/ rA r rU rk rN r r r � test_write_points_with_precision* s z3TestInfluxDBClient.test_write_points_with_precisionc C sF t � }| �td�� |j| jdd� W d � n1 s80 Y dS )z%Test write points with bad precision.�>Invalid time precision is given. \(use 's', 'm', 'ms' or 'u'\)�gr� Nr� rN r r r � test_write_points_bad_precision0 s ��z2TestInfluxDBClient.test_write_points_bad_precisionc C sH t dd��* tddddd�}|�g � W d � n1 s:0 Y dS ) z(Test write points where precision fails.r� r� rF rG rH rI rQ N)r/ r Zwrite_points_with_precisionrN r r r �&test_write_points_with_precision_fails< s z9TestInfluxDBClient.test_write_points_with_precision_failsc C s� t dd��v}tddddd�}| �|�d�� | �t|j�d � |jd \}}| �|d ddd �� | �|d d� W d � n1 s�0 Y dS )z1Test delete points for TestInfluxDBClient object.�delete�� rF rG rH rI rQ r8 r4 r �params)r �p�urlz!http://host:8086/db/db/series/fooN)r/ r rU � delete_pointsrL �lenZcall_args_list)rD r. rO r& �kwdsr r r �test_delete_pointsC s �z%TestInfluxDBClient.test_delete_pointsc C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z#Test delete points with wrong name.r� i� rF rG rH rI rQ ZnonexistN)r/ r r� rN r r r �"test_delete_points_with_wrong_nameP s z5TestInfluxDBClient.test_delete_points_with_wrong_namec C s t ddddd�}|�g � dS )z Test create scheduled deletes.rF rG rH rI rQ N)r Zcreate_scheduled_deleterN r r r � test_create_scheduled_deleteW s z/TestInfluxDBClient.test_create_scheduled_deletec C s t ddddd�}|�� dS )z5Test get schedule list of deletes TestInfluxDBClient.rF rG rH rI rQ N)r Zget_list_scheduled_deleterN r r r � test_get_list_scheduled_delete] s z1TestInfluxDBClient.test_get_list_scheduled_deletec C s t ddddd�}|�d� dS )z0Test remove scheduled delete TestInfluxDBClient.rF rG rH rI rQ r4 N)r Zremove_scheduled_deleterN r r r � test_remove_scheduled_deletec s z/TestInfluxDBClient.test_remove_scheduled_deletec C s� dg d�g d�g d�g d�g d�gd�g}t dd |��B td d d d d�}|�d�}| �t|d d �d� W d � n1 s~0 Y dS )z)Test query for TestInfluxDBClient object.r8 )�time�sequence_numberr9 )��E|R� r6 )r� � r3 )��E|R� r6 )r� � r3 )r< r= r; r r rF rG rH rI rQ �select column_one from foo;r r; rx N)r/ r �queryrL r� )rD r rO �resultr r r � test_queryi s ��� z TestInfluxDBClient.test_queryc C s� t dd�}g d�g d�g d�g d�g d�gdg d �d �}t�|�t�|� }t�� �<}|jtjd |d � | �|jd dd�||g� W d � n1 s�0 Y dS )z1Test chunked query for TestInfluxDBClient object.rQ r[ )l �&�&iA� i� )l ��&i1u r~ )l Q�&i!N i )� t�&�' i+ )� "&� &r� � r8 �r� r� �valr: rj ��text�select * from fooT��chunkedN) r r# r% ra rb rc r rl r� �rD rO Zexample_object�example_responserh r r r �test_query_chunkedz s, ��� � �z%TestInfluxDBClient.test_query_chunkedc C s� t dd�}ddtd�gddtd�ggdg d �d �}t�|�t�|� }t�� �<}|jtjd |d � | �|j d dd�||g� W d � n1 s�0 Y dS )z9Test unicode chunked query for TestInfluxDBClient object.rQ r[ r� r� u unicode-Ïr� u more-unicode-Ïr8 r� r: rj r� r� Tr� N) r r r# r% ra rb rc r rl r� r� r r r �test_query_chunked_unicode� s& �� � � �z-TestInfluxDBClient.test_query_chunked_unicodec C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z)Test failed query for TestInfluxDBClient.r � rF rG rH rI rQ r� N)r/ r r� rN r r r �test_query_fail� s z"TestInfluxDBClient.test_query_failc C sD t � }| �td�� |jddd� W d � n1 s60 Y dS )z5Test query with bad precision for TestInfluxDBClient.r� zselect column_one from foor� r� N)r r� r� r� rN r r r �test_query_bad_precision� s �z+TestInfluxDBClient.test_query_bad_precisionc C sT t ddddi��0 tddddd �}| �|�d�� W d � n1 sF0 Y d S ) z,Test create database for TestInfluxDBClient.r� �� r< �new_dbrF rG rH rI rQ N)r/ r rU �create_databaserN r r r �test_create_database� s z'TestInfluxDBClient.test_create_databasec C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z3Test failed create database for TestInfluxDBClient.r� r� rF rG rH rI rQ r� N)r/ r r� rN r r r �test_create_database_fails� s z-TestInfluxDBClient.test_create_database_failsc C sN t dd��0 tddddd�}| �|�d�� W d � n1 s@0 Y d S ) z,Test delete database for TestInfluxDBClient.r� r� rF rG rH rI rQ �old_dbN)r/ r rU �delete_databaserN r r r �test_delete_database� s z'TestInfluxDBClient.test_delete_databasec C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z3Test failed delete database for TestInfluxDBClient.r� r� rF rG rH rI rQ r� N)r/ r r� rN r r r �test_delete_database_fails� s z-TestInfluxDBClient.test_delete_database_failsc C st ddig}t dd|��J tdddd�}| �t|�� �d � | �|�� d d d� W d � n1 sf0 Y d S ) z2Test get list of databases for TestInfluxDBClient.r< �a_dbr r rF rG rH rI r4 r N)r/ r rL r� �get_list_database�rD r rO r r r �test_get_list_database� s �z)TestInfluxDBClient.test_get_list_databasec C sD t dd��& tdddd�}|�� W d � n1 s60 Y dS )z9Test failed get list of databases for TestInfluxDBClient.r r� rF rG rH rI N)r/ r r� rN r r r � test_get_list_database_fails� s z/TestInfluxDBClient.test_get_list_database_failsc C st ddig}t dd|��J tdddd�}| �t|�� �d � | �|�� d d d� W d � n1 sf0 Y d S ) z9Test deprecated get database list for TestInfluxDBClient.r< r� r r rF rG rH rI r4 r N)r/ r rL r� Zget_database_listr� r r r �!test_get_database_list_deprecated� s �z4TestInfluxDBClient.test_get_database_list_deprecatedc C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z*Test delete series for TestInfluxDBClient.r� r� rF rG rH rI rQ � old_seriesN�r/ r Z delete_seriesrN r r r �test_delete_series� s z%TestInfluxDBClient.test_delete_seriesc C sH t dd��* tddddd�}|�d� W d � n1 s:0 Y d S ) z1Test failed delete series for TestInfluxDBClient.r� r� rF rG rH rI rQ r� Nr� rN r r r �test_delete_series_fails s z+TestInfluxDBClient.test_delete_series_failsc C s` t dd�}t�� �:}d}|jtjd|d� | �|�� ddg� W d � n1 sR0 Y dS ) z/Test get list of series for TestInfluxDBClient.rQ r[ zX[{"name":"list_series_result","columns":["time","name"],"points":[[0,"foo"],[0,"bar"]]}]rj r� r8 r� N)r ra rb rc r rl Zget_list_series�rD rO rh r� r r r �test_get_series_list s ���z'TestInfluxDBClient.test_get_series_listc C s` t dd�}t�� �:}d}|jtjd|d� | �|�� ddg� W d � n1 sR0 Y dS ) z3Test get continuous queries for TestInfluxDBClient.rQ r[ a; [ { "name": "continuous queries", "columns": [ "time", "id", "query" ], "points": [ [ 0, 1, "select foo(bar,95) from \"foo_bars\" group by time(5m) into response_times.percentiles.5m.95" ], [ 0, 2, "select percentile(value,95) from \"response_times\" group by time(5m) into response_times.percentiles.5m.95" ] ] } ]rj r� zZselect foo(bar,95) from "foo_bars" group by time(5m) into response_times.percentiles.5m.95ziselect percentile(value,95) from "response_times" group by time(5m) into response_times.percentiles.5m.95N)r ra rb rc r rl Zget_list_continuous_queriesr� r r r �test_get_continuous_queries s ���z.TestInfluxDBClient.test_get_continuous_queriesc C s dS )z1Test get list of cluster admins, not implemented.Nr rC r r r � test_get_list_cluster_adminsA s z/TestInfluxDBClient.test_get_list_cluster_adminsc C sn t �� �R}|�t jd� tdd�}|jddd� | �t�|j j �ddd�� W d � n1 s`0 Y dS ) z.Test add cluster admin for TestInfluxDBClient.z$http://localhost:8086/cluster_adminsrQ r[ �paul�laup)� new_username� new_password)r< rI N) ra rb rc r r Zadd_cluster_admin�assertDictEqualr# r$ re rf rg r r r �test_add_cluster_adminE s � � ��z)TestInfluxDBClient.test_add_cluster_adminc C sl t �� �P}|�t jd� tdd�}|jddd� | �t�|j j �ddi� W d � n1 s^0 Y dS ) z6Test update cluster admin pass for TestInfluxDBClient.�)http://localhost:8086/cluster_admins/paulrQ r[ r� r� �rH r� rI N) ra rb rc r r Z update_cluster_admin_passwordr� r# r$ re rf rg r r r �"test_update_cluster_admin_password[ s � � �z5TestInfluxDBClient.test_update_cluster_admin_passwordc C sb t �� �F}|jt jddd� tdd�}|jdd� | �|jj� W d � n1 sT0 Y dS ) z1Test delete cluster admin for TestInfluxDBClient.r� r )r rQ r[ r� �rH N) ra rb rc �DELETEr Zdelete_cluster_admin� assertIsNonere rf rg r r r �test_delete_cluster_adminn s � z,TestInfluxDBClient.test_delete_cluster_adminc C s dS )z/Test set database admin for TestInfluxDBClient.Nr rC r r r �test_set_database_admin| s z*TestInfluxDBClient.test_set_database_adminc C s dS )z1Test unset database admin for TestInfluxDBClient.Nr rC r r r �test_unset_database_admin� s z,TestInfluxDBClient.test_unset_database_adminc C sl t �� �P}|�t jd� tdd�}|jddd� | �t�|j j �ddi� W d � n1 s^0 Y dS ) z1Test alter database admin for TestInfluxDBClient.�&http://localhost:8086/db/db/users/paulrQ r[ r� F)rH Zis_admin�adminN) ra rb rc r r Zalter_database_adminr� r# r$ re rf rg r r r �test_alter_database_admin� s � � ��z,TestInfluxDBClient.test_alter_database_adminc C s t ddddd�}|�� dS )z8Test get list of database admins for TestInfluxDBClient.rF rG rH rI rQ N)r Zget_list_database_adminsrN r r r � test_get_list_database_admins� s z0TestInfluxDBClient.test_get_list_database_adminsc C s t ddddd�}|�dd� dS ) z0Test add database admins for TestInfluxDBClient.rF rG rH rI rQ r� �admin_secret_passwordN)r Zadd_database_adminrN r r r �test_add_database_admin� s z*TestInfluxDBClient.test_add_database_adminc C s t ddddd�}|�dd� dS ) z7Test update database admin pass for TestInfluxDBClient.rF rG rH rI rQ r� r� N)r Z update_database_admin_passwordrN r r r �#test_update_database_admin_password� s z6TestInfluxDBClient.test_update_database_admin_passwordc C s t ddddd�}|�d� dS )z2Test delete database admin for TestInfluxDBClient.rF rG rH rI rQ r� N)r Zdelete_database_adminrN r r r �test_delete_database_admin� s z-TestInfluxDBClient.test_delete_database_adminc C sl t ddddd�}d}t�� �*}|jtjd|d� |�� }W d � n1 sL0 Y | �t�|�|� d S ) z/Test get database users for TestInfluxDBClient.ro rG rH rI rQ z�[{"name":"paul","isAdmin":false,"writeTo":".*","readFrom":".*"},{"name":"bobby","isAdmin":false,"writeTo":".*","readFrom":".*"}]�!http://localhost:8086/db/db/usersr� N) r ra rb rc r Zget_database_usersrL r# r$ )rD rO r� rh Zusersr r r �test_get_database_users� s � �&z*TestInfluxDBClient.test_get_database_usersc C st t �� �X}|�t jd� tdd�}|jdddd� | �t�|j j �ddddd �� W d � n1 sf0 Y d S ) z.Test add database user for TestInfluxDBClient.r� rQ r[ r� r� )�.*r� )r� r� � permissionsr� )�writeTorI �readFromr< N) ra rb rc r r �add_database_userr� r# r$ re rf rg r r r �test_add_database_user� s& � � ��z)TestInfluxDBClient.test_add_database_userc C sF t � }| �td�� |jdddd� W d � n1 s80 Y dS )z=Test add database user with bad perms for TestInfluxDBClient.z1'permissions' must be \(readFrom, writeTo\) tupler� )�hellor r )r� r� r� N)r r� r� r� rN r r r �&test_add_database_user_bad_permissions� s ��z9TestInfluxDBClient.test_add_database_user_bad_permissionsc C sl t �� �P}|�t jd� tdd�}|jddd� | �t�|j j �ddi� W d � n1 s^0 Y dS ) z5Test alter database user pass for TestInfluxDBClient.r� rQ r[ r� �n3wp4ss!)rH rI rI N� ra rb rc r r Zalter_database_userr� r# r$ re rf rg r r r �!test_alter_database_user_password� s � � ��z4TestInfluxDBClient.test_alter_database_user_passwordc C sn t �� �R}|�t jd� tdd�}|jddd� | �t�|j j �ddd �� W d � n1 s`0 Y d S ) z6Test alter database user perms for TestInfluxDBClient.r� rQ r[ r� ��^$r� )rH r� r r� )r� r� Nr rg r r r �$test_alter_database_user_permissions� s � � ��z7TestInfluxDBClient.test_alter_database_user_permissionsc C sr t �� �V}|�t jd� tdd�}|jdddd� | �t�|j j �ddd d �� W d � n1 sd0 Y d S ) z?Test alter database user pass and perms for TestInfluxDBClient.r� rQ r[ r� r r )rH rI r� r r� )rI r� r� Nr rg r r r �1test_alter_database_user_password_and_permissions s$ � � ��zDTestInfluxDBClient.test_alter_database_user_password_and_permissionsc C sd t dddd�}t�� �:}|�tjd� |jddd� | �|jd� W d � n1 sV0 Y dS ) z6Test update database user pass for TestInfluxDBClient.r� r rJ )rH rI rJ z,http://localhost:8086/db/database/users/rootZbyer� N)r ra rb rc r Z update_database_user_passwordrL rS )rD rO rh r r r �/test_update_database_user_password_current_user, s � ��zBTestInfluxDBClient.test_update_database_user_password_current_userc C s^ t �� �B}|�t jd� tdd�}|jdd� | �|jj� W d � n1 sP0 Y dS )z1Test delete database user for TestInfluxDBClient.r� rQ r[ r� r� N) ra rb rc r� r Zdelete_database_userr� re rf rg r r r �test_delete_database_user@ s � z,TestInfluxDBClient.test_delete_database_userc C s t ddddd�}|�dg � dS )z.Test update permission for TestInfluxDBClient.rF rG rH rI rQ r� N)r Zupdate_permissionrN r r r �test_update_permissionM s z)TestInfluxDBClient.test_update_permissionzrequests.Session.requestc C s4 G dd� dt �}|� j|_tdd�}|�| j� dS )z0Test that two connection errors will be handled.c @ s e Zd ZdZdd� Zdd� ZdS )z9TestInfluxDBClient.test_request_retry.<locals>.CustomMock�Define CustomMock object.c S s d| _ d S )Nr ��irC r r r �__init__Y s zBTestInfluxDBClient.test_request_retry.<locals>.CustomMock.__init__c _ s8 | j d7 _ | j dk r"tjj�nt�� }d|_|S dS )z$Test connection error in CustomMock.r4 rv r N�r r � exceptions�ConnectionErrorr r �rD r& r' �rr r r �connection_error\ s zJTestInfluxDBClient.test_request_retry.<locals>.CustomMock.connection_errorN��__name__� __module__� __qualname__�__doc__r r r r r r � CustomMockV s r rQ r[ N)r- r r+ r rk rA �rD Z mock_requestr rO r r r �test_request_retryS s �z%TestInfluxDBClient.test_request_retryc C sb G dd� dt �}|� j|_tdd�}| �tjj�� |�| j � W d � n1 sT0 Y dS )z6Test that three connection errors will not be handled.c @ s e Zd ZdZdd� Zdd� ZdS )z@TestInfluxDBClient.test_request_retry_raises.<locals>.CustomMockr c S s d| _ dS )zInitialize the object.r Nr rC r r r r t s zITestInfluxDBClient.test_request_retry_raises.<locals>.CustomMock.__init__c _ s8 | j d7 _ | j dk r"tjj�nt�� }d|_|S dS )z)Test the connection error for CustomMock.r4 rx r Nr r r r r r x s zQTestInfluxDBClient.test_request_retry_raises.<locals>.CustomMock.connection_errorNr r r r r r q s r rQ r[ N) r- r r+ r Z assertRaisesr r r rk rA r r r r �test_request_retry_raisesn s z,TestInfluxDBClient.test_request_retry_raisesN)Gr r r r rE rP rV rX r r@ rY rZ ri rm rn rs ru r� r� r� r� r� r� r� r� r� r� �NotImplementedErrorr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r �mockr r r r r r r r0 N s� ! ! r0 )r r )r r r )r r# r� �sysZunittestr� r> r! r Zrequests.exceptionsra Z nose.toolsr r Zinfluxdb.influxdb08r Zinfluxdb.influxdb08.clientr �versionr r r r/ ZTestCaser0 r r r r �<module> s* %
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка