3
ܓiA
@ s. d dl Z d dlmZmZ G dd deeZdS ) N)PluginIndependentPluginc @ s0 e Zd ZdZdZd Zd
Zd Zdd Zdd Z dS )
OpenSearchzOpenSearch service
opensearchservicesc C s d}d}yt |dd}x||D ]t}tjd|}tjd|}|rnt|j dkrn|j d j }tjd d
|}q |r t|j dkr |j d j }q W W d Q R X W n8 tk
r } z | jd | d
| W Y d d }~X nX ||fS )z Get hostname and port number Z localhostZ9200zUTF-8)encodingz(^network.host):(.*)z(^http.port):(.*) z"|\' NzFailed to parse z: r ) openresearchlengroupsstripsub ExceptionZ _log_info) selfopensearch_config_fileZhostnameportZfreadlineZ network_hostZ network_porterr r /usr/lib/python3.6/opensearch.pyget_hostname_port s
"(z OpenSearch.get_hostname_portc
C s | j d}| j| | jdr*| jd n
| jd | j|\}}|d | }| jd| dd| dd| d d| d
d| d d| d d| d
g d S )Nz /etc/opensearch/opensearch.ymlZall_logsz/var/log/opensearch/*z/var/log/opensearch/*.log:z
curl -X GET 'z/_cluster/settings?pretty'z/_cluster/health?pretty'z/_cluster/stats?pretty'z/_cat/nodes?v'z/_cat/indices'z
/_cat/shards'z/_cat/aliases')Z path_joinZ
add_copy_specZ
get_optionr Zadd_cmd_output)r r hostr Zendpointr r r setup+ s
zOpenSearch.setupN)r )r )r )
__name__
__module__ __qualname__Z
short_descZ plugin_nameZprofilesZpackagesr r r r r r r r s r )r
Zsos.report.pluginsr r r r r r r s