File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/kapacitor.cpython-310.pyc
Back
o ;j � @ s� d Z ddlZddlZddlZddlZddlmZ e� e �Z dd� Z edd� �Z dd � Zd d � Zd d � Z ddd�Zdd� Zdd� Zdd� ZdS )aJ Kapacitor execution module. :configuration: This module accepts connection configuration details either as parameters or as configuration settings in /etc/salt/minion on the relevant minions:: kapacitor.host: 'localhost' kapacitor.port: 9092 .. versionadded:: 2016.11.0 Also protocol and SSL settings could be configured:: kapacitor.unsafe_ssl: 'false' kapacitor.protocol: 'http' .. versionadded:: 2019.2.0 This data can also be passed into pillar. Options passed into opts will overwrite options passed into pillar. � N)�memoizec C s t jj�d�r dS dS )N� kapacitor)Fz Missing dependency: kapacitor)�salt�utils�path�which� r r �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/kapacitor.py� __virtual__& s r c C s& t d d�} | stt d dd��} | S )z$ Get the kapacitor version. z pkg.versionr � config.optionzkapacitor.versionZlatest)�__salt__�str)�versionr r r r - s r c C s> t d dd�} t d dd�}t d dd�}| � d|� d |� �S ) z Get the kapacitor URL. r zkapacitor.protocol�httpzkapacitor.hostZ localhostzkapacitor.porti�# z://�:)r )�protocol�host�portr r r �_get_url8 s r c C s� t � }t� dk r|� d| � �}n|� d| � d�}tjjj|dd�}|d dkr)d S tjj�|d �}t� dk rF|d |d |d |d d�S |d |d |d |d dkd�S )z� Get a dict of data on a task. name Name of the task to get information about. CLI Example: .. code-block:: bash salt '*' kapacitor.get_task cpu �0.13z /task?name=z/kapacitor/v1/tasks/z?skip-format=trueT)�statusr i� N�bodyZ TICKscript�TypeZDBRPsZEnabled)�script�type�dbrps�enabledr r r r )r r r r r �query�json�loads)�name�urlZtask_url�response�datar r r �get_taskC s& � �r$ c C sj i }t � td dd�d�}td | |d�}|�d�r |d |d< |�d�r+|d |d< |d d k|d < |S ) z? Run a Kapacitor task and return a dictionary of info. r zkapacitor.unsafe_ssl�false)Z KAPACITOR_URLZKAPACITOR_UNSAFE_SSLz cmd.run_all)�env�stdout�stderr�retcoder �success)r r �get)�cmd�retZenv_vars�resultr r r �_run_cmdn s �� r/ �stream�defaultc C s� |s |s t �d� dS t� dk rd| � �}nd| � �}|�d�r'td |t�}|d|� �7 }|r7|d |� �7 }|s;g }|rK|rK|� d |� �}|�|� |rY|D ] }|d |� �7 }qOt|�S ) a Define a task. Serves as both create/update. name Name of the task. tick_script Path to the TICK script for the task. Can be a salt:// source. task_type Task type. Defaults to 'stream' dbrps A list of databases and retention policies in "dbname"."rpname" format to fetch data from. For backward compatibility, the value of 'database' and 'retention_policy' will be merged as part of dbrps. .. versionadded:: 2019.2.0 database Which database to fetch data from. retention_policy Which retention policy to fetch data from. Defaults to 'default'. CLI Example: .. code-block:: bash salt '*' kapacitor.define_task cpu salt://kapacitor/cpu.tick database=telegraf z.Providing database name or dbrps is mandatory.Fr zkapacitor define -name zkapacitor define zsalt://z cp.cache_filez -tick z -type �.z -dbrp )�log�errorr � startswithr Z__env__�appendr/ )r Z tick_scriptZ task_typeZdatabaseZretention_policyr r, Zdbrpr r r � define_task� s( ' r7 c C � t d| � ��S )z� Delete a kapacitor task. name Name of the task to delete. CLI Example: .. code-block:: bash salt '*' kapacitor.delete_task cpu zkapacitor delete tasks �r/ �r r r r � delete_task� � r; c C r8 )z� Enable a kapacitor task. name Name of the task to enable. CLI Example: .. code-block:: bash salt '*' kapacitor.enable_task cpu zkapacitor enable r9 r: r r r � enable_task� r< r= c C r8 )z� Disable a kapacitor task. name Name of the task to disable. CLI Example: .. code-block:: bash salt '*' kapacitor.disable_task cpu zkapacitor disable r9 r: r r r � disable_task� r< r> )r0 Nr1 N)�__doc__�logging�loggerZsalt.utils.httpr Zsalt.utils.jsonZsalt.utils.pathZsalt.utils.decoratorsr � getLogger�__name__r3 r r r r$ r/ r7 r; r= r> r r r r �<module> s* + �F
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings