File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/influxdbmod.cpython-310.pyc
Back
o ;jy@ � @ sf d Z ddlZddlZddlmZ ddlZddlmZ zddl Z dZ W n e y- dZ Y nw e� e�ZdZdd � Z d@d d �Zd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� ZdAdd�Zd d � Zd d � Z d d!� Z d"d#� Z d$d%� Z d&d'� Z d(d)� Z! dAd*d+�Z" dAd,d-�Z#d.d/� Z$d0d1� Z%d2d3� Z&d4d5� Z'd6d7� Z( dBd8d9�Z)d:d;� Z*d<d=� Z+d>d?� Z,dS )Ca� InfluxDB - A distributed time series database Module to provide InfluxDB compatibility to Salt (compatible with InfluxDB version 0.9+) :depends: - influxdb Python module (>= 3.0.0) :configuration: This module accepts connection configuration details either as parameters or as configuration settings in /etc/salt/minion on the relevant minions:: influxdb.host: 'localhost' influxdb.port: 8086 influxdb.user: 'root' influxdb.password: 'root' This data can also be passed into pillar. Options passed into opts will overwrite options passed into pillar. Most functions in this module allow you to override or provide some or all of these settings via keyword arguments:: salt '*' influxdb.foo_function influxdb_user='influxadmin' influxdb_password='s3cr1t' would override ``user`` and ``password`` while still using the defaults for ``host`` and ``port``. � N)�Sequence)�STATE_INTERNAL_KEYWORDSTF�influxdbc C s t rtS dS )z. Only load if influxdb lib is present )FzQThe influxdb execution module could not be loaded:influxdb library not available.)� HAS_INFLUXDB�__virtualname__� r r �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/influxdbmod.py� __virtual__3 s r c K sz | s t d dd�} |st d dd�}|st d dd�}|s$t d dd�}tD ] }||v r/||= q&tjd ||| |d �|��S ) Nz config.optionz influxdb.user�rootzinfluxdb.passwordz influxdb.hostZ localhostz influxdb.porti� )�host�port�username�passwordr )Z__salt__�_STATE_INTERNAL_KEYWORDSr ZInfluxDBClient)Z influxdb_userZinfluxdb_passwordZ influxdb_hostZ influxdb_port� client_args�ignorer r r �_client@ s( ���r c K � t di | ��}|�� S )zv List all InfluxDB databases. CLI Example: .. code-block:: bash salt '*' influxdb.list_dbs Nr )r Zget_list_database�r �clientr r r �list_dbs[ � r c K s$ | dd� t di |��D �v rdS dS )z� Checks if a database exists in InfluxDB. name Name of the database to check. CLI Example: .. code-block:: bash salt '*' influxdb.db_exists <name> c S s g | ]}|d �qS ��namer )�.0�dbr r r � <listcomp>w s z db_exists.<locals>.<listcomp>TFNr )r �r r r r r � db_existsj s r c K s< t | fi |��rt�d| � dS tdi |��}|�| � dS )z� Create a database. name Name of the database to create. CLI Example: .. code-block:: bash salt '*' influxdb.create_db <name> zDB '%s' already existsFTNr )r �log�infor Zcreate_database�r r r r r r � create_db} � r" c K �< t | fi |��st�d| � dS tdi |��}|�| � dS )z� Drop a database. name Name of the database to drop. CLI Example: .. code-block:: bash salt '*' influxdb.drop_db <name> zDB '%s' does not existFTNr )r r r r Z drop_databaser! r r r �drop_db� r# r% c K r )zk List all users. CLI Example: .. code-block:: bash salt '*' influxdb.list_users Nr )r Zget_list_usersr r r r � list_users� r r& c K s t | fi |��r dS dS )z� Check if a user exists. name Name of the user to check. CLI Example: .. code-block:: bash salt '*' influxdb.user_exists <name> TF)� user_infor r r r � user_exists� s r( c s< � fdd�t di |��D �}zt|�W S ty Y dS w )z� Get information about given user. name Name of the user for which to get information. CLI Example: .. code-block:: bash salt '*' influxdb.user_info <name> c 3 �" � | ] }|� d �� kr|V qdS )�userN��get)r r* r r r � <genexpr>� s � �z user_info.<locals>.<genexpr>Nr )r& �next� StopIteration)r r Zmatching_usersr r r r' � s � �r' c K s@ t | fi |��rt�d| � dS tdi |��}|�| ||� dS )a� Create a user. name Name of the user to create. passwd Password of the new user. admin : False Whether the user should have cluster administration privileges or not. CLI Example: .. code-block:: bash salt '*' influxdb.create_user <name> <password> salt '*' influxdb.create_user <name> <password> admin=True zUser '%s' already existsFTNr )r( r r r � create_user)r �passwdZadminr r r r r r0 � s r0 c K s> t | fi |��st�d| � dS tdi |��}|�| |� dS )z� Change password of a user. name Name of the user for whom to set the password. passwd New password of the user. CLI Example: .. code-block:: bash salt '*' influxdb.set_user_password <name> <password> �User '%s' does not existFTNr )r( r r r �set_user_password)r r1 r r r r r r3 s r3 c K � t di |��}|�| � dS )z� Grant cluster administration privileges to a user. name Name of the user to whom admin privileges will be granted. CLI Example: .. code-block:: bash salt '*' influxdb.grant_admin_privileges <name> TNr )r �grant_admin_privilegesr! r r r r5 � r5 c K r4 )z� Revoke cluster administration privileges from a user. name Name of the user from whom admin privileges will be revoked. CLI Example: .. code-block:: bash salt '*' influxdb.revoke_admin_privileges <name> TNr )r �revoke_admin_privilegesr! r r r r7 0 r6 r7 c K r$ )z� Remove a user. name Name of the user to remove CLI Example: .. code-block:: bash salt '*' influxdb.remove_user <name> r2 FTNr )r( r r r Z drop_userr! r r r � remove_userC r# r8 c sD t di |��}zt� fdd�|�| �D ��W S ty! i Y S w )a& Get an existing retention policy. database Name of the database for which the retention policy was defined. name Name of the retention policy. CLI Example: .. code-block:: bash salt '*' influxdb.get_retention_policy metrics default c 3 r) �r Nr+ )r �pr r r r- n s � ��z'get_retention_policy.<locals>.<genexpr>Nr )r r. Zget_list_retention_policiesr/ ��databaser r r r r r �get_retention_policyZ s � �r= c K � t | |fi |��r dS dS )aB Check if retention policy with given name exists. database Name of the database for which the retention policy was defined. name Name of the retention policy to check. CLI Example: .. code-block:: bash salt '*' influxdb.retention_policy_exists metrics default TF)r= �r< r r r r r �retention_policy_existsw � r@ c K s t di |��}|�|| � dS )a Drop a retention policy. database Name of the database for which the retention policy will be dropped. name Name of the retention policy to drop. CLI Example: .. code-block:: bash salt '*' influxdb.drop_retention_policy mydb mypr TNr )r �drop_retention_policyr; r r r rB � s rB c K s$ t di |��}|�|||| |� dS )u� Create a retention policy. database Name of the database for which the retention policy will be created. name Name of the new retention policy. duration Duration of the new retention policy. Durations such as 1h, 90m, 12h, 7d, and 4w, are all supported and mean 1 hour, 90 minutes, 12 hours, 7 day, and 4 weeks, respectively. For infinite retention – meaning the data will never be deleted – use 'INF' for duration. The minimum retention period is 1 hour. replication Replication factor of the retention policy. This determines how many independent copies of each data point are stored in a cluster. default : False Whether or not the policy as default will be set as default. CLI Example: .. code-block:: bash salt '*' influxdb.create_retention_policy metrics default 1d 1 TNr )r �create_retention_policy�r< r ZdurationZ replication�defaultr r r r r rC � s #rC c K s$ t di |��}|�|| |||� dS )u� Modify an existing retention policy. name Name of the retention policy to modify. database Name of the database for which the retention policy was defined. duration New duration of given retention policy. Durations such as 1h, 90m, 12h, 7d, and 4w, are all supported and mean 1 hour, 90 minutes, 12 hours, 7 day, and 4 weeks, respectively. For infinite retention – meaning the data will never be deleted – use 'INF' for duration. The minimum retention period is 1 hour. replication New replication of given retention policy. This determines how many independent copies of each data point are stored in a cluster. default : False Whether or not to set the modified policy as default. CLI Example: .. code-block:: bash salt '*' influxdb.alter_retention_policy metrics default 1d 1 TNr )r �alter_retention_policyrD r r r rF � s $rF c K sB t di |��}i }|�| �D ]}|d �� d �� ||d < q|S )z� List privileges from a user. name Name of the user from whom privileges will be listed. CLI Example: .. code-block:: bash salt '*' influxdb.list_privileges <name> � privileger r< Nr )r Zget_list_privileges�split�lower)r r r �res�itemr r r �list_privileges� s rL c K � t di |��}|�|| |� dS )a Grant a privilege on a database to a user. database Name of the database to grant the privilege on. privilege Privilege to grant. Can be one of 'read', 'write' or 'all'. username Name of the user to grant the privilege to. TNr )r �grant_privilege�r< rG r r r r r r rN � rN c K rM )a Revoke a privilege on a database from a user. database Name of the database to grant the privilege on. privilege Privilege to grant. Can be one of 'read', 'write' or 'all'. username Name of the user to grant the privilege to. TNr )r �revoke_privilegerO r r r rQ rP rQ c K r> )aR Check if continuous query with given name exists on the database. database Name of the database for which the continuous query was defined. name Name of the continuous query to check. CLI Example: .. code-block:: bash salt '*' influxdb.continuous_query_exists metrics default TF)�get_continuous_queryr? r r r �continuous_query_exists1 rA rS c sl t di |��}z#|�d��� D ]\}}|d | kr't� fdd�|D �� W S qW i S ty5 i Y S w )a+ Get an existing continuous query. database Name of the database for which the continuous query was defined. name Name of the continuous query to get. CLI Example: .. code-block:: bash salt '*' influxdb.get_continuous_query mydb cq_month zSHOW CONTINUOUS QUERIESr c 3 r) r9 r+ )r Zcqr r r r- ^ s � z'get_continuous_query.<locals>.<genexpr>Nr )r �query�itemsr. r/ )r< r r r r Zcqsr r r rR H s �� ��rR c K sT t di |��}d}|r|d7 }|r|d7 }|d7 }|j|| |||d�}|�|� dS ) a\ Create a continuous query. database Name of the database for which the continuous query will be created on. name Name of the continuous query to create. query The continuous query string. resample_time : None Duration between continuous query resampling. coverage_period : None Duration specifying time period per sample. CLI Example: .. code-block:: bash salt '*' influxdb.create_continuous_query mydb cq_month 'SELECT mean(*) INTO mydb.a_month.:MEASUREMENT FROM mydb.a_week./.*/ GROUP BY time(5m), *' z,CREATE CONTINUOUS QUERY {name} ON {database}z RESAMPLE EVERY {resample_time}z FOR {coverage_period}z BEGIN {query} END)r r< rT � resample_time�coverage_periodTNr )r �formatrT )r< r rT rV rW r r Z full_queryr r r �create_continuous_queryd s � rY c K s, t di |��}d|� d| � �}|�|� dS )a' Drop a continuous query. database Name of the database for which the continuous query will be drop from. name Name of the continuous query to drop. CLI Example: .. code-block:: bash salt '*' influxdb.drop_continuous_query mydb my_cq zDROP CONTINUOUS QUERY z ON TNr )r rT )r< r r r rT r r r �drop_continuous_query� s rZ c C sl t �t�}| �� D ]$\}}|\}}|r$dd� |D �|| tjj�|�< q dd� |D �||< q tt|�� ��S )z� Parses a ResultSet returned from InfluxDB into a dictionary of results, grouped by series names and optional JSON-encoded grouping tags. c S � g | ]}|�qS r r �r �_valuer r r r � s �z'_pull_query_results.<locals>.<listcomp>c S r[ r r r\ r r r r � s ) � collections� defaultdict�dictrU �salt�utils�json�dumps�sorted)Z resultsetZ_resultsZ_headerZ_valuesZ _group_tagsr r r �_pull_query_results� s �rf c K sH t di |��}|j|| d�}t|t�rdd� |D �S |r!t|�gS i gS )z| Execute a query. database Name of the database to query on. query InfluxQL query string. )r< c S s g | ]}|rt |��qS r )rf )r Z _query_resultr r r r � s ��zquery.<locals>.<listcomp>Nr )r rT � isinstancer rf )r< rT r r Z_resultr r r rT � s �rT )NNNN)F)NN)-�__doc__r^ �logging�collections.abcr Zsalt.utils.jsonra Z salt.stater r r r � ImportError� getLogger�__name__r r r r r r r" r% r& r( r' r0 r3 r5 r7 r8 r= r@ rB rC rF rL rN rQ rS rR rY rZ rf rT r r r r �<module> sb � � �* �) �.
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings