File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/telemetry.cpython-310.pyc
Back
o ;j�3 � @ s� d Z ddlZddlZddlZzddlZdZW n ey! dZY nw e�e �Z dZ dd� Z dd � Z d d d �Zd d � Zd dd�Z d dd�Zd dd�Zd dd�Zd dd�Zd dd�Z d dd�ZdS ) af Connection module for Telemetry .. versionadded:: 2016.3.0 https://github.com/mongolab/mongolab-telemetry-api-docs/blob/master/alerts.md :configuration: This module accepts explicit telemetry credentials or can also read api key credentials from a pillar. More Information available here__. .. __: https://github.com/mongolab/mongolab-telemetry-api-docs/blob/master/alerts.md In the minion's config file: .. code-block:: yaml telemetry.telemetry_api_keys: - abc123 # Key 1 - efg321 # Backup Key 1 telemetry_api_base_url: https://telemetry-api.mongolab.com/v0 :depends: requests � NTF� telemetryc C s t sdS tS )NF)� HAS_REQUESTS�__virtualname__� r r �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/telemetry.py� __virtual__, s r c C s t d | �}|�d�S )N� config.optionZtelemetry_api_base_url)�__salt__�get)�profileZconfigr r r �_get_telemetry_base3 s r c C sh | d u r |d u r t d��|r/t|t�rtd |�}nt|t�r!|}|r+|�d�d } nt d��| dd�S )NzMissing api_key and profiler Ztelemetry_api_keysr zMissing api_keyzapplication/json)zTelemetry-API-Keyz content-type)� Exception� isinstance�strr �dictr )�api_keyr Z_profiler r r �_auth8 s r c C s8 d| � d�}|t v rt | }|||< |t |< t �|g �S )N� telemetry.�.alerts)� __context__r )� deployment_id� metric_name�alert�key�alertsr r r � _update_cacheJ s r c C s� d}t |d�}|tvr:t|�d }tj||dd�}|jdkr:i }t|�� �D ]\}}|�dd�||�d �< q&|t|< t| �| d �S ) z� Given an email address, checks the local cache if corresponding email address: channel_id mapping exists email Email escalation policy profile A dict of telemetry config information. �telemetry.channels�r z5/notification-channels?_type=EmailNotificationChannel�x ��headers�timeout�� �_id�false�emailF)r r r �requestsr � status_code� enumerate�json) r% r r �auth�get_url�responseZ cache_result�indexr r r r �_retrieve_channel_idU s �� r. c C s� t |d�}d}d| � d�}|tvr^zt|�d�| � }tj||dd�}W n tjjy@ } zt� t | �� W Y d} ~ dS d} ~ ww i } |j d kr^|� � D ]}|| |�d i ��d �< | t|< qLt�|�seg S t| � � } |rtt| �|�S d d � | D �S )a� Get all alert definitions associated with a given deployment or if metric_name is specified, obtain the specific alert config Returns dictionary or list of dictionaries. CLI Example: .. code-block:: bash salt myminion telemetry.get_alert_config rs-ds033197 currentConnections profile=telemetry salt myminion telemetry.get_alert_config rs-ds033197 profile=telemetry r Fr r z/alerts?deployment={}r r Nr" � condition�metricc S s g | ] }d |v r|d �qS )r# r )�.0r r r r � <listcomp>� s z$get_alert_config.<locals>.<listcomp>)r r r �formatr& r � exceptions�RequestException�log�errorr r' r) �values) r r r r r* r r r+ r, �eZ http_resultr r r r �get_alert_configt s2 ��� r: c C s� t |d�}t| �}|sYt�d| � t|�d }d| d| �d�� d | d�}tj|tj j � |�|d d �}|j d krRt�d |� d �| � |� � � d�}|td | < |S td| � ���|S )a� Given an email address, creates a notification-channels if one is not found and also returns the corresponding notification channel id. notify_channel Email escalation policy profile A dict of telemetry config information. CLI Example: .. code-block:: bash salt myminion telemetry.get_notification_channel_id userx@company.com profile=telemetry r z$%s channel does not exist, creating.z/notification-channelsZEmailNotificationChannelN�@ZEscalationPolicy)Z_type�namer% r ��datar r! r" zISuccessfully created EscalationPolicy %s with EmailNotificationChannel %sr< r# r z'Failed to created notification channel )r r. r6 �infor �findr& �post�salt�utilsr) �dumpsr' r r r )Znotify_channelr r* Znotification_channel_idZpost_urlr> r, r r r �get_notification_channel_id� s. �� � �rE c C s� t |d�}ztjt|�d| � � |dd�}W n tjjy2 } zt�t|�� W Y d}~dS d}~ww |j dkrE|� � }|r@|S d| � �S |j t j j � |j��d d �d �S ) z� get all the alarms set up against the current deployment Returns dictionary of alarm information CLI Example: .. code-block:: bash salt myminion telemetry.get_alarms rs-ds033197 profile=telemetry r z/alerts?deployment=r r NFr" z"No alarms defined for deployment: �err� )Zerr_code�err_msg)r r& r r r4 r5 r6 r7 r r' r) rB rC �loads�text)r r r* r, r9 Zalarmsr r r � get_alarms� s( ��� �rK c C s. t ||�}t|�d }d| � d�}| |�d�t|�d���� ||�d�|�d�d�d �}ztj|tjj � |�|d d �} W n tj j yW } z t �t| �� W Y d } ~ nd } ~ ww | jd kr|| jdk r|t �d|| � t �d|| | � � � t| || � � � n t �d|| tjj � |�� | jd ko�| jdk | � � fS )a create an telemetry alarms. data is a dict of alert configuration data. Returns (bool success, str message) tuple. CLI Example: .. code-block:: bash salt myminion telemetry.create_alarm rs-ds033197 {} profile=telemetry z/alertsr r �filter� escalate_to�max�min�r0 rN rO �Z deploymentrL ZnotificationChannelr/ r r= Nr" �, z-Created alarm on metric: %s in deployment: %s�1Updating cache for metric %s in deployment %s: %szBFailed to create alarm on metric: %s in deployment %s: payload: %s)r r r rE �splitr& rA rB rC r) rD r4 r5 r6 r7 r r' r? �debugr ) r r r> r r r* � request_urir � post_bodyr, r9 r r r � create_alarm sV ��� ����� � rX c C sh t ||�}t| |||�}|sdd�| |�fS t|�d |d }| |�d�t|�d���� ||�d�|�d�d �d �}ztj|t j j � |�|d d �} W n tj jyk } zt�d | � dt| �fW Y d} ~ S d} ~ ww | jdkr�| jdk r�t�d|| | � � � t| || � � � t�d|| � d| � � fS d�t j j�|�t j j�| �t j j � |��} t�| � d| fS )z� update an telemetry alarms. data is a dict of alert configuration data. Returns (bool success, str message) tuple. CLI Example: .. code-block:: bash salt myminion telemetry.update_alarm rs-ds033197 {} profile=telemetry Fz4No entity found matching deployment {} and alarms {}�/alerts/r# rL rM rN rO rP rQ r r= zUpdate failed: %sNr" rR rS z-Updated alarm on metric: %s in deployment: %sTzBFailed to create alarm on metric: {} in deployment: {} payload: {})r r: r3 r r rE rT r& �putrB rC r) rD r4 r5 r6 r7 r r' rU r r? Z stringutilsZ to_unicode) r r r> r r r* r rV rW r, r9 rH r r r � update_alarmF sh ����� � ���� �� r[ c C s t |d�}|du rt| ||d�}n|g}|s dd| � �fS g }|D ]I}t|�d|� � } ztj| |dd�} |rDt�d || � t| |d� W n tjj y_ } z t� d | � W Y d} ~ nd} ~ ww | j d krj|� |� q!|rxdd � d �|�| �fS dd� d �|�| �fS )a& delete an alert specified by alert_id or if not specified blows away all the alerts in the current deployment. Returns (bool success, str message) tuple. CLI Example: .. code-block:: bash salt myminion telemetry.delete_alarms rs-ds033197 profile=telemetry r N)r r Fz1failed to find alert associated with deployment: rY r r z(updating cache and delete %s key from %szDelete failed: %sr" z,Failed to delete {} alarms in deployment: {}z, Tz0Successfully deleted {} alerts in deployment: {})r r: r r& �deleter6 rU r r4 r5 r7 r' �appendr3 �join) r Zalert_idr r r r* Z alert_idsZfailed_to_delete�idZ delete_urlr, r9 r r r � delete_alarms� sN �� ��� � �� ��r` )Nr )r )NNr )NNNr )�__doc__�loggingZsalt.utils.jsonrB Zsalt.utils.stringutilsr& r � ImportError� getLogger�__name__r6 r r r r r r. r: rE rK rX r[ r` r r r r �<module> s2 � � 1 4 ( EM�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings