Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/influxdb/tests/server_tests/__pycache__/influxdb_instance.cpython-39.pyc
Ðазад
a p�h� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZmZ dee �vr�d d � Zee _G d d � d e�ZdS ) z0Define the test module for an influxdb instance.� )�absolute_import)�division)�print_function)�unicode_literalsN)� is_port_open�get_free_ports� check_outputc O sh d|v rt d��tj| dtji|��}|�� \}}|�� }|rd|�d�}|du rX| d }t�||��|S )zCheck for output.�stdoutz3stdout argument not allowed, it will be overridden.�argsNr )� ValueError� subprocess�Popen�PIPE� communicate�poll�get�CalledProcessError)� popenargs�kwargs�process�outputZ unused_err�retcode�cmd� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/influxdb/tests/server_tests/influxdb_instance.py�f s" ��� r c @ s< e Zd ZdZddd�Zdd� Zdd� Zd d � Zdd d �ZdS )�InfluxDbInstancez�Define an instance of InfluxDB. A class to launch of fresh influxdb server instance in a temporary place, using a config file template. Fc C s~ t j�dd�dkr t�d��| �� | _d}z| �||� W qzW q* tyv } z |d7 }|dkrb|�W Y d}~q*d}~0 0 q*dS )z+Initialize an instance of InfluxDbInstance.Z!INFLUXDB_PYTHON_SKIP_SERVER_TESTSN�Truez8Skipping server test (INFLUXDB_PYTHON_SKIP_SERVER_TESTS)r � � ) �os�environr �unittest�SkipTest�find_influxd_path� influxd_path� _start_server� RuntimeError)�self� conf_template� udp_enabled�errors�er r r �__init__2 s � zInfluxDbInstance.__init__c C sj t �� | _t j| jd� }| _td�}i }dD ]}|�� ||d < q.|sPd|d< ttj� |d�tj� |d�tj� |d �tj� |d �tj� |d �tj� | jd �|r�d ndd�}|� |� | j � |� tj� | jd�}t |d��T} t |��*} | � | �� jf i |��� W d � n1 �s0 Y W d � n1 �s80 Y tj| jd|gtjtjd�| _tdtj�� | j| j| jf � t�� d } z�t�� | k �r�t| j��r�t| j��r�|�rt� d� �qt� d� | j� � d u�r�t d���q�| j� � | j� � t d| ��W nT t �yd } z:| �!� } t"| �| d< tj�� | d< t d| ��W Y d } ~ n d } ~ 0 0 d S ) N)�dir� )�http�global�metaZudpZ_port���Zudp_portr2 �dataZwal�stateZhandoffzlogs.txt�true�false)Zmeta_dir�data_dirZwal_dirZ cluster_dirZ handoff_dir� logs_filer* z influxdb.conf�wz-config)r �stderrz6%s > Started influxdb bin in %r with ports %s and %s..� g �?zinfluxdb prematurely exitedz8Timeout waiting for influxdb to listen on its ports (%s)�reason�nowzK%(now)s > %(reason)s. RC=%(rc)s stdout=%(out)s stderr=%(err)s logs=%(logs)r)#�tempfile�mkdtemp� temp_dir_baseZtemp_dir_influxdbr �pop�dictr �path�join�update�__dict__�open�write�read�formatr r r% r �proc�print�datetimer> Z global_portZ http_port�timer �sleepr r' � terminate�wait�get_logs_and_output�str)r( r) r* �tempdirZ free_portsZportsZserviceZ conf_dataZ conf_file�fhZ fh_template�timeout�errr4 r r r r& F s| � � Z ��� � � �z InfluxDbInstance._start_serverc C s� t j�dd�}|du rVtj�d�}|sVzt�ddg��� }W n tj yT d}Y n0 t j � |�slt � d��t�|dg�}td| tjd � |S ) zFind the path for InfluxDB.Z INFLUXDB_PYTHON_INFLUXD_PATHNZinfluxd�whichz/opt/influxdb/influxdz Could not find influxd binary�versionzInfluxDB version: %s)�file)r r! r � distutils�spawn�find_executabler r �stripr rD �isfiler" r# rM �sysr; )r( Zinfluxdb_bin_pathrZ r r r r$ � s$ � � z"InfluxDbInstance.find_influxd_pathc C s� | j }z6t| j��}|�� }W d � n1 s00 Y W n, tyh } zd| }W Y d}~n d}~0 0 |j|j�� |j�� |d�S )zQuery for logs and output.NzCouldn't read logs: %s)�rc�outrX �logs)rL rH r9 rJ �IOError� returncoder r; )r( rL rV rd rX r r r rS � s * �z$InfluxDbInstance.get_logs_and_outputTc C s( | j �� | j �� |r$t�| j� dS )z Close an instance of InfluxDB.N)rL rQ rR �shutil�rmtreerA )r( � remove_treer r r �close� s zInfluxDbInstance.closeN)F)T) �__name__� __module__� __qualname__�__doc__r- r& r$ rS rj r r r r r + s Rr )rn � __future__r r r r rN �distutils.spawnr\ r r? rg r ra rO r" Zinfluxdb.tests.miscr r r. r r �objectr r r r r �<module> s$
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка